dataprovider

Documentation

Index

• type CommonDataProvider
• type ElasticCommonDataProvider
• type Enricher
  • func NewEnricher(dataprovider ElasticCommonDataProvider) *Enricher
  • func (e *Enricher) EnrichEvent(event *beat.Event) error
• type IdProvider
• type MockCommonDataProvider
  • func NewMockCommonDataProvider(t interface{ ... }) *MockCommonDataProvider
  • func (_m *MockCommonDataProvider) EXPECT() *MockCommonDataProvider_Expecter
  • func (_m *MockCommonDataProvider) EnrichEvent(event *beat.Event, resource fetching.ResourceMetadata) error
• type MockCommonDataProvider_EnrichEvent_Call
  • func (_c *MockCommonDataProvider_EnrichEvent_Call) Return(_a0 error) *MockCommonDataProvider_EnrichEvent_Call
  • func (_c *MockCommonDataProvider_EnrichEvent_Call) Run(run func(event *beat.Event, resource fetching.ResourceMetadata)) *MockCommonDataProvider_EnrichEvent_Call
  • func (_c *MockCommonDataProvider_EnrichEvent_Call) RunAndReturn(run func(*beat.Event, fetching.ResourceMetadata) error) *MockCommonDataProvider_EnrichEvent_Call
• type MockCommonDataProvider_Expecter
  • func (_e *MockCommonDataProvider_Expecter) EnrichEvent(event interface{}, resource interface{}) *MockCommonDataProvider_EnrichEvent_Call
• type MockElasticCommonDataProvider
  • func NewMockElasticCommonDataProvider(t interface{ ... }) *MockElasticCommonDataProvider
  • func (_m *MockElasticCommonDataProvider) EXPECT() *MockElasticCommonDataProvider_Expecter
  • func (_m *MockElasticCommonDataProvider) GetElasticCommonData() (map[string]interface{}, error)
• type MockElasticCommonDataProvider_Expecter
  • func (_e *MockElasticCommonDataProvider_Expecter) GetElasticCommonData() *MockElasticCommonDataProvider_GetElasticCommonData_Call
• type MockElasticCommonDataProvider_GetElasticCommonData_Call
  • func (_c *MockElasticCommonDataProvider_GetElasticCommonData_Call) Return(_a0 map[string]interface{}, _a1 error) *MockElasticCommonDataProvider_GetElasticCommonData_Call
  • func (_c *MockElasticCommonDataProvider_GetElasticCommonData_Call) Run(run func()) *MockElasticCommonDataProvider_GetElasticCommonData_Call
  • func (_c *MockElasticCommonDataProvider_GetElasticCommonData_Call) RunAndReturn(run func() (map[string]interface{}, error)) *MockElasticCommonDataProvider_GetElasticCommonData_Call
• type MockIdProvider
  • func NewMockIdProvider(t interface{ ... }) *MockIdProvider
  • func (_m *MockIdProvider) EXPECT() *MockIdProvider_Expecter
  • func (_m *MockIdProvider) GetId(resourceType string, resourceId string) string
• type MockIdProvider_Expecter
  • func (_e *MockIdProvider_Expecter) GetId(resourceType interface{}, resourceId interface{}) *MockIdProvider_GetId_Call
• type MockIdProvider_GetId_Call
  • func (_c *MockIdProvider_GetId_Call) Return(_a0 string) *MockIdProvider_GetId_Call
  • func (_c *MockIdProvider_GetId_Call) Run(run func(resourceType string, resourceId string)) *MockIdProvider_GetId_Call
  • func (_c *MockIdProvider_GetId_Call) RunAndReturn(run func(string, string) string) *MockIdProvider_GetId_Call

Types

type CommonDataProvider

type CommonDataProvider interface {
	EnrichEvent(event *beat.Event, resource fetching.ResourceMetadata) error
}

type ElasticCommonDataProvider

type ElasticCommonDataProvider interface {
	GetElasticCommonData() (map[string]any, error)
}

type Enricher

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

func NewEnricher

func NewEnricher(dataprovider ElasticCommonDataProvider) *Enricher

func (*Enricher) EnrichEvent

func (e *Enricher) EnrichEvent(event *beat.Event) error

type IdProvider

type IdProvider interface {
	GetId(resourceType string, resourceId string) string
}

type MockCommonDataProvider

type MockCommonDataProvider struct {
	mock.Mock
}

MockCommonDataProvider is an autogenerated mock type for the CommonDataProvider type

func NewMockCommonDataProvider

func NewMockCommonDataProvider(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockCommonDataProvider

NewMockCommonDataProvider creates a new instance of MockCommonDataProvider. 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 (*MockCommonDataProvider) EXPECT

func (_m *MockCommonDataProvider) EXPECT() *MockCommonDataProvider_Expecter

func (*MockCommonDataProvider) EnrichEvent

func (_m *MockCommonDataProvider) EnrichEvent(event *beat.Event, resource fetching.ResourceMetadata) error

EnrichEvent provides a mock function with given fields: event, resource

type MockCommonDataProvider_EnrichEvent_Call

type MockCommonDataProvider_EnrichEvent_Call struct {
	*mock.Call
}

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

func (*MockCommonDataProvider_EnrichEvent_Call) Return

func (_c *MockCommonDataProvider_EnrichEvent_Call) Return(_a0 error) *MockCommonDataProvider_EnrichEvent_Call

func (*MockCommonDataProvider_EnrichEvent_Call) Run

func (_c *MockCommonDataProvider_EnrichEvent_Call) Run(run func(event *beat.Event, resource fetching.ResourceMetadata)) *MockCommonDataProvider_EnrichEvent_Call

func (*MockCommonDataProvider_EnrichEvent_Call) RunAndReturn

func (_c *MockCommonDataProvider_EnrichEvent_Call) RunAndReturn(run func(*beat.Event, fetching.ResourceMetadata) error) *MockCommonDataProvider_EnrichEvent_Call

type MockCommonDataProvider_Expecter

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

func (*MockCommonDataProvider_Expecter) EnrichEvent

func (_e *MockCommonDataProvider_Expecter) EnrichEvent(event interface{}, resource interface{}) *MockCommonDataProvider_EnrichEvent_Call

EnrichEvent is a helper method to define mock.On call

• event *beat.Event
• resource fetching.ResourceMetadata

type MockElasticCommonDataProvider

type MockElasticCommonDataProvider struct {
	mock.Mock
}

MockElasticCommonDataProvider is an autogenerated mock type for the ElasticCommonDataProvider type

func NewMockElasticCommonDataProvider

func NewMockElasticCommonDataProvider(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockElasticCommonDataProvider

NewMockElasticCommonDataProvider creates a new instance of MockElasticCommonDataProvider. 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 (*MockElasticCommonDataProvider) EXPECT

func (_m *MockElasticCommonDataProvider) EXPECT() *MockElasticCommonDataProvider_Expecter

func (*MockElasticCommonDataProvider) GetElasticCommonData

func (_m *MockElasticCommonDataProvider) GetElasticCommonData() (map[string]interface{}, error)

GetElasticCommonData provides a mock function with given fields:

type MockElasticCommonDataProvider_Expecter

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

func (*MockElasticCommonDataProvider_Expecter) GetElasticCommonData

func (_e *MockElasticCommonDataProvider_Expecter) GetElasticCommonData() *MockElasticCommonDataProvider_GetElasticCommonData_Call

GetElasticCommonData is a helper method to define mock.On call

type MockElasticCommonDataProvider_GetElasticCommonData_Call

type MockElasticCommonDataProvider_GetElasticCommonData_Call struct {
	*mock.Call
}

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

func (*MockElasticCommonDataProvider_GetElasticCommonData_Call) Return

func (_c *MockElasticCommonDataProvider_GetElasticCommonData_Call) Return(_a0 map[string]interface{}, _a1 error) *MockElasticCommonDataProvider_GetElasticCommonData_Call

func (*MockElasticCommonDataProvider_GetElasticCommonData_Call) Run

func (_c *MockElasticCommonDataProvider_GetElasticCommonData_Call) Run(run func()) *MockElasticCommonDataProvider_GetElasticCommonData_Call

func (*MockElasticCommonDataProvider_GetElasticCommonData_Call) RunAndReturn

func (_c *MockElasticCommonDataProvider_GetElasticCommonData_Call) RunAndReturn(run func() (map[string]interface{}, error)) *MockElasticCommonDataProvider_GetElasticCommonData_Call

type MockIdProvider

type MockIdProvider struct {
	mock.Mock
}

MockIdProvider is an autogenerated mock type for the IdProvider type

func NewMockIdProvider

func NewMockIdProvider(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockIdProvider

NewMockIdProvider creates a new instance of MockIdProvider. 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 (*MockIdProvider) EXPECT

func (_m *MockIdProvider) EXPECT() *MockIdProvider_Expecter

func (*MockIdProvider) GetId

func (_m *MockIdProvider) GetId(resourceType string, resourceId string) string

GetId provides a mock function with given fields: resourceType, resourceId

type MockIdProvider_Expecter

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

func (*MockIdProvider_Expecter) GetId

func (_e *MockIdProvider_Expecter) GetId(resourceType interface{}, resourceId interface{}) *MockIdProvider_GetId_Call

GetId is a helper method to define mock.On call

• resourceType string
• resourceId string

type MockIdProvider_GetId_Call

type MockIdProvider_GetId_Call struct {
	*mock.Call
}

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

func (*MockIdProvider_GetId_Call) Return

func (_c *MockIdProvider_GetId_Call) Return(_a0 string) *MockIdProvider_GetId_Call

func (*MockIdProvider_GetId_Call) Run

func (_c *MockIdProvider_GetId_Call) Run(run func(resourceType string, resourceId string)) *MockIdProvider_GetId_Call

func (*MockIdProvider_GetId_Call) RunAndReturn

func (_c *MockIdProvider_GetId_Call) RunAndReturn(run func(string, string) string) *MockIdProvider_GetId_Call