k8s

Documentation

Index

• func NewIdProvider(clusterID, nodeID string) dataprovider.IdProvider
• type ClientGetter
  • func (ClientGetter) GetClient(log *logp.Logger, kubeConfig string, options kubernetes.KubeClientOptions) (k8s.Interface, error)
• type ClientGetterAPI
• type ClusterNameProviderAPI
• type DataProvider
  • func New(options ...Option) DataProvider
  • func (k DataProvider) EnrichEvent(event *beat.Event, _ fetching.ResourceMetadata) error
• type EKSClusterNameProvider
  • func (provider EKSClusterNameProvider) GetClusterName(ctx context.Context, _ *config.Config) (string, error)
• type KubernetesClusterNameProvider
  • func (provider KubernetesClusterNameProvider) GetClusterName(_ context.Context, cfg *config.Config) (string, error)
• type MockClientGetterAPI
  • func NewMockClientGetterAPI(t interface{ ... }) *MockClientGetterAPI
  • func (_m *MockClientGetterAPI) EXPECT() *MockClientGetterAPI_Expecter
  • func (_m *MockClientGetterAPI) GetClient(log *logp.Logger, kubeConfig string, options kubernetes.KubeClientOptions) (client_gokubernetes.Interface, error)
• type MockClientGetterAPI_Expecter
  • func (_e *MockClientGetterAPI_Expecter) GetClient(log interface{}, kubeConfig interface{}, options interface{}) *MockClientGetterAPI_GetClient_Call
• type MockClientGetterAPI_GetClient_Call
  • func (_c *MockClientGetterAPI_GetClient_Call) Return(_a0 client_gokubernetes.Interface, _a1 error) *MockClientGetterAPI_GetClient_Call
  • func (_c *MockClientGetterAPI_GetClient_Call) Run(...) *MockClientGetterAPI_GetClient_Call
  • func (_c *MockClientGetterAPI_GetClient_Call) RunAndReturn(...) *MockClientGetterAPI_GetClient_Call
• type MockClusterNameProviderAPI
  • func NewMockClusterNameProviderAPI(t interface{ ... }) *MockClusterNameProviderAPI
  • func (_m *MockClusterNameProviderAPI) EXPECT() *MockClusterNameProviderAPI_Expecter
  • func (_m *MockClusterNameProviderAPI) GetClusterName(ctx context.Context, cfg *config.Config) (string, error)
• type MockClusterNameProviderAPI_Expecter
  • func (_e *MockClusterNameProviderAPI_Expecter) GetClusterName(ctx interface{}, cfg interface{}) *MockClusterNameProviderAPI_GetClusterName_Call
• type MockClusterNameProviderAPI_GetClusterName_Call
  • func (_c *MockClusterNameProviderAPI_GetClusterName_Call) Return(_a0 string, _a1 error) *MockClusterNameProviderAPI_GetClusterName_Call
  • func (_c *MockClusterNameProviderAPI_GetClusterName_Call) Run(run func(ctx context.Context, cfg *config.Config)) *MockClusterNameProviderAPI_GetClusterName_Call
  • func (_c *MockClusterNameProviderAPI_GetClusterName_Call) RunAndReturn(run func(context.Context, *config.Config) (string, error)) *MockClusterNameProviderAPI_GetClusterName_Call
• type MockOption
  • func NewMockOption(t interface{ ... }) *MockOption
  • func (_m *MockOption) EXPECT() *MockOption_Expecter
  • func (_m *MockOption) Execute(_a0 *DataProvider)
• type MockOption_Execute_Call
  • func (_c *MockOption_Execute_Call) Return() *MockOption_Execute_Call
  • func (_c *MockOption_Execute_Call) Run(run func(_a0 *DataProvider)) *MockOption_Execute_Call
  • func (_c *MockOption_Execute_Call) RunAndReturn(run func(*DataProvider)) *MockOption_Execute_Call
• type MockOption_Expecter
  • func (_e *MockOption_Expecter) Execute(_a0 interface{}) *MockOption_Execute_Call
• type Option
  • func WithClusterID(id string) Option
  • func WithClusterName(name string) Option
  • func WithClusterVersion(version string) Option

Functions

func NewIdProvider

func NewIdProvider(clusterID, nodeID string) dataprovider.IdProvider

Types

type ClientGetter

type ClientGetter struct{}

func (ClientGetter) GetClient

func (ClientGetter) GetClient(log *logp.Logger, kubeConfig string, options kubernetes.KubeClientOptions) (k8s.Interface, error)

type ClientGetterAPI

type ClientGetterAPI interface {
	GetClient(log *logp.Logger, kubeConfig string, options kubernetes.KubeClientOptions) (k8s.Interface, error)
}

type ClusterNameProviderAPI

type ClusterNameProviderAPI interface {
	GetClusterName(ctx context.Context, cfg *config.Config) (string, error)
}

type DataProvider

type DataProvider struct {
	// contains filtered or unexported fields
}

func New

func New(options ...Option) DataProvider

func (DataProvider) EnrichEvent

func (k DataProvider) EnrichEvent(event *beat.Event, _ fetching.ResourceMetadata) error

type EKSClusterNameProvider

type EKSClusterNameProvider struct {
	AwsCfg              aws.Config
	EKSMetadataProvider awslib.MetadataProvider
	ClusterNameProvider awslib.EKSClusterNameProviderAPI
	KubeClient          kubernetes.Interface
}

func (EKSClusterNameProvider) GetClusterName

func (provider EKSClusterNameProvider) GetClusterName(ctx context.Context, _ *config.Config) (string, error)

type KubernetesClusterNameProvider

type KubernetesClusterNameProvider struct {
	KubeClient kubernetes.Interface
}

func (KubernetesClusterNameProvider) GetClusterName

func (provider KubernetesClusterNameProvider) GetClusterName(_ context.Context, cfg *config.Config) (string, error)

type MockClientGetterAPI

type MockClientGetterAPI struct {
	mock.Mock
}

MockClientGetterAPI is an autogenerated mock type for the ClientGetterAPI type

func NewMockClientGetterAPI

func NewMockClientGetterAPI(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockClientGetterAPI

NewMockClientGetterAPI creates a new instance of MockClientGetterAPI. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockClientGetterAPI) EXPECT

func (_m *MockClientGetterAPI) EXPECT() *MockClientGetterAPI_Expecter

func (*MockClientGetterAPI) GetClient

func (_m *MockClientGetterAPI) GetClient(log *logp.Logger, kubeConfig string, options kubernetes.KubeClientOptions) (client_gokubernetes.Interface, error)

GetClient provides a mock function with given fields: log, kubeConfig, options

type MockClientGetterAPI_Expecter

type MockClientGetterAPI_Expecter struct {
	// contains filtered or unexported fields
}

func (*MockClientGetterAPI_Expecter) GetClient

func (_e *MockClientGetterAPI_Expecter) GetClient(log interface{}, kubeConfig interface{}, options interface{}) *MockClientGetterAPI_GetClient_Call

GetClient is a helper method to define mock.On call

• log *logp.Logger
• kubeConfig string
• options kubernetes.KubeClientOptions

type MockClientGetterAPI_GetClient_Call

type MockClientGetterAPI_GetClient_Call struct {
	*mock.Call
}

MockClientGetterAPI_GetClient_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetClient'

func (*MockClientGetterAPI_GetClient_Call) Return

func (_c *MockClientGetterAPI_GetClient_Call) Return(_a0 client_gokubernetes.Interface, _a1 error) *MockClientGetterAPI_GetClient_Call

func (*MockClientGetterAPI_GetClient_Call) Run

func (_c *MockClientGetterAPI_GetClient_Call) Run(run func(log *logp.Logger, kubeConfig string, options kubernetes.KubeClientOptions)) *MockClientGetterAPI_GetClient_Call

func (*MockClientGetterAPI_GetClient_Call) RunAndReturn

func (_c *MockClientGetterAPI_GetClient_Call) RunAndReturn(run func(*logp.Logger, string, kubernetes.KubeClientOptions) (client_gokubernetes.Interface, error)) *MockClientGetterAPI_GetClient_Call

type MockClusterNameProviderAPI

type MockClusterNameProviderAPI struct {
	mock.Mock
}

MockClusterNameProviderAPI is an autogenerated mock type for the ClusterNameProviderAPI type

func NewMockClusterNameProviderAPI

func NewMockClusterNameProviderAPI(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockClusterNameProviderAPI

NewMockClusterNameProviderAPI creates a new instance of MockClusterNameProviderAPI. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockClusterNameProviderAPI) EXPECT

func (_m *MockClusterNameProviderAPI) EXPECT() *MockClusterNameProviderAPI_Expecter

func (*MockClusterNameProviderAPI) GetClusterName

func (_m *MockClusterNameProviderAPI) GetClusterName(ctx context.Context, cfg *config.Config) (string, error)

GetClusterName provides a mock function with given fields: ctx, cfg

type MockClusterNameProviderAPI_Expecter

type MockClusterNameProviderAPI_Expecter struct {
	// contains filtered or unexported fields
}

func (*MockClusterNameProviderAPI_Expecter) GetClusterName

func (_e *MockClusterNameProviderAPI_Expecter) GetClusterName(ctx interface{}, cfg interface{}) *MockClusterNameProviderAPI_GetClusterName_Call

GetClusterName is a helper method to define mock.On call

• ctx context.Context
• cfg *config.Config

type MockClusterNameProviderAPI_GetClusterName_Call

type MockClusterNameProviderAPI_GetClusterName_Call struct {
	*mock.Call
}

MockClusterNameProviderAPI_GetClusterName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetClusterName'

func (*MockClusterNameProviderAPI_GetClusterName_Call) Return

func (_c *MockClusterNameProviderAPI_GetClusterName_Call) Return(_a0 string, _a1 error) *MockClusterNameProviderAPI_GetClusterName_Call

func (*MockClusterNameProviderAPI_GetClusterName_Call) Run

func (_c *MockClusterNameProviderAPI_GetClusterName_Call) Run(run func(ctx context.Context, cfg *config.Config)) *MockClusterNameProviderAPI_GetClusterName_Call

func (*MockClusterNameProviderAPI_GetClusterName_Call) RunAndReturn

func (_c *MockClusterNameProviderAPI_GetClusterName_Call) RunAndReturn(run func(context.Context, *config.Config) (string, error)) *MockClusterNameProviderAPI_GetClusterName_Call

type MockOption

type MockOption struct {
	mock.Mock
}

MockOption is an autogenerated mock type for the Option type

func NewMockOption

func NewMockOption(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockOption

NewMockOption creates a new instance of MockOption. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockOption) EXPECT

func (_m *MockOption) EXPECT() *MockOption_Expecter

func (*MockOption) Execute

func (_m *MockOption) Execute(_a0 *DataProvider)

Execute provides a mock function with given fields: _a0

type MockOption_Execute_Call

type MockOption_Execute_Call struct {
	*mock.Call
}

MockOption_Execute_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Execute'

func (*MockOption_Execute_Call) Return

func (_c *MockOption_Execute_Call) Return() *MockOption_Execute_Call

func (*MockOption_Execute_Call) Run

func (_c *MockOption_Execute_Call) Run(run func(_a0 *DataProvider)) *MockOption_Execute_Call

func (*MockOption_Execute_Call) RunAndReturn

func (_c *MockOption_Execute_Call) RunAndReturn(run func(*DataProvider)) *MockOption_Execute_Call

type MockOption_Expecter

type MockOption_Expecter struct {
	// contains filtered or unexported fields
}

func (*MockOption_Expecter) Execute

func (_e *MockOption_Expecter) Execute(_a0 interface{}) *MockOption_Execute_Call

Execute is a helper method to define mock.On call

• _a0 *DataProvider

type Option

type Option func(*DataProvider)

func WithClusterID

func WithClusterID(id string) Option

func WithClusterName

func WithClusterName(name string) Option

func WithClusterVersion

func WithClusterVersion(version string) Option