Class: Fluent::Plugin::KubernetesObjectsInput

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

Constant Summary collapse

VERSION = 
'1.1.2'.freeze

Instance Method Summary collapse

Instance Method Details

#close ⇒ Object 



107
108
109
 
# File 'lib/fluent/plugin/in_kubernetes_objects.rb', line 107

def close
  super
end

#configure(conf) ⇒ Object

Raises:

  • (Fluent::ConfigError) 


90
91
92
93
94
95
96
97
98
99
 
# File 'lib/fluent/plugin/in_kubernetes_objects.rb', line 90

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 



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

def start
  super
  start_pullers
  start_watchers
end