Class: Fluent::Plugin::KubernetesObjectsInput

Inherits:
Input
  • Object
show all
Defined in:
lib/fluent/plugin/in_kubernetes_objects.rb

Constant Summary collapse

VERSION = 
'1.1.0'.freeze

Instance Method Summary collapse

Instance Method Details

#close ⇒ Object 



101
102
103
104
 
# File 'lib/fluent/plugin/in_kubernetes_objects.rb', line 101

def close
  @watchers.each &:finish if @watchers
  super
end

#configure(conf) ⇒ Object

Raises:

  • (Fluent::ConfigError) 


84
85
86
87
88
89
90
91
92
93
 
# File 'lib/fluent/plugin/in_kubernetes_objects.rb', line 84

def configure(conf)
  super

  raise Fluent::ConfigError, 'At least one <pull> or <watch> is required, but found none.' if @pull_objects.empty? && @watch_objects.empty?

  @storage = storage_create usage: 'checkpoints'

  parse_tag
  initialize_client
end

#start ⇒ Object 



95
96
97
98
99
 
# File 'lib/fluent/plugin/in_kubernetes_objects.rb', line 95

def start
  super
  start_pullers
  start_watchers
end