usage

package
v0.0.7-dev0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 6, 2024 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DataUsageSyncer 

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

func NewDataUsageSyncer 

func NewDataUsageSyncer() *DataUsageSyncer

func (*DataUsageSyncer) SyncDataUsage 

func (s *DataUsageSyncer) SyncDataUsage(ctx context.Context, dataUsageFileHandler wrappers.DataUsageStatementHandler, configMap *config.ConfigMap) error

type FileUsageObjectMapper 

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

func NewFileUsageObjectMapper 

func NewFileUsageObjectMapper(pathDepth int, dataObjectsWithType *trie.Trie[string]) FileUsageObjectMapper

func (FileUsageObjectMapper) MapObject 

func (m FileUsageObjectMapper) MapObject(object string) *data_usage.UsageDataObjectReference

type GlueUsageObjectMapper 

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

func NewGlueUsageObjectMapper 

func NewGlueUsageObjectMapper(dataObjectsWithType *trie.Trie[string]) GlueUsageObjectMapper

func (GlueUsageObjectMapper) MapObject 

func (m GlueUsageObjectMapper) MapObject(object string) *data_usage.UsageDataObjectReference

type MockdataObjectRepository 

type MockdataObjectRepository struct {
	mock.Mock
}

MockdataObjectRepository is an autogenerated mock type for the dataObjectRepository type

func NewMockdataObjectRepository 

func NewMockdataObjectRepository(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockdataObjectRepository

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

func (_m *MockdataObjectRepository) EXPECT() *MockdataObjectRepository_Expecter

func (*MockdataObjectRepository) GetAvailableObjectTypes 

func (_m *MockdataObjectRepository) GetAvailableObjectTypes(ctx context.Context, cfg *config.ConfigMap) (*trie.Trie[string], error)

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

type MockdataObjectRepository_Expecter 

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

func (*MockdataObjectRepository_Expecter) GetAvailableObjectTypes 

func (_e *MockdataObjectRepository_Expecter) GetAvailableObjectTypes(ctx interface{}, cfg interface{}) *MockdataObjectRepository_GetAvailableObjectTypes_Call

GetAvailableObjectTypes is a helper method to define mock.On call

  • ctx context.Context
  • cfg *config.ConfigMap

type MockdataObjectRepository_GetAvailableObjectTypes_Call 

type MockdataObjectRepository_GetAvailableObjectTypes_Call struct {
	*mock.Call
}

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

func (*MockdataObjectRepository_GetAvailableObjectTypes_Call) Return 

func (_c *MockdataObjectRepository_GetAvailableObjectTypes_Call) Return(_a0 *trie.Trie[string], _a1 error) *MockdataObjectRepository_GetAvailableObjectTypes_Call

func (*MockdataObjectRepository_GetAvailableObjectTypes_Call) Run 

func (_c *MockdataObjectRepository_GetAvailableObjectTypes_Call) Run(run func(ctx context.Context, cfg *config.ConfigMap)) *MockdataObjectRepository_GetAvailableObjectTypes_Call

func (*MockdataObjectRepository_GetAvailableObjectTypes_Call) RunAndReturn 

func (_c *MockdataObjectRepository_GetAvailableObjectTypes_Call) RunAndReturn(run func(context.Context, *config.ConfigMap) (*trie.Trie[string], error)) *MockdataObjectRepository_GetAvailableObjectTypes_Call

type MockdataUsageRepository 

type MockdataUsageRepository struct {
	mock.Mock
}

MockdataUsageRepository is an autogenerated mock type for the dataUsageRepository type

func NewMockdataUsageRepository 

func NewMockdataUsageRepository(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockdataUsageRepository

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

func (_m *MockdataUsageRepository) EXPECT() *MockdataUsageRepository_Expecter

func (*MockdataUsageRepository) GetFile 

func (_m *MockdataUsageRepository) GetFile(ctx context.Context, bucket string, key string, region *string) (io.ReadCloser, error)

GetFile provides a mock function with given fields: ctx, bucket, key, region

func (*MockdataUsageRepository) ListFiles 

func (_m *MockdataUsageRepository) ListFiles(ctx context.Context, bucket string, prefix *string) ([]model.AwsS3Entity, string, error)

ListFiles provides a mock function with given fields: ctx, bucket, prefix

type MockdataUsageRepository_Expecter 

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

func (*MockdataUsageRepository_Expecter) GetFile 

func (_e *MockdataUsageRepository_Expecter) GetFile(ctx interface{}, bucket interface{}, key interface{}, region interface{}) *MockdataUsageRepository_GetFile_Call

GetFile is a helper method to define mock.On call

  • ctx context.Context
  • bucket string
  • key string
  • region *string

func (*MockdataUsageRepository_Expecter) ListFiles 

func (_e *MockdataUsageRepository_Expecter) ListFiles(ctx interface{}, bucket interface{}, prefix interface{}) *MockdataUsageRepository_ListFiles_Call

ListFiles is a helper method to define mock.On call

  • ctx context.Context
  • bucket string
  • prefix *string

type MockdataUsageRepository_GetFile_Call 

type MockdataUsageRepository_GetFile_Call struct {
	*mock.Call
}

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

func (*MockdataUsageRepository_GetFile_Call) Return 

func (_c *MockdataUsageRepository_GetFile_Call) Return(_a0 io.ReadCloser, _a1 error) *MockdataUsageRepository_GetFile_Call

func (*MockdataUsageRepository_GetFile_Call) Run 

func (_c *MockdataUsageRepository_GetFile_Call) Run(run func(ctx context.Context, bucket string, key string, region *string)) *MockdataUsageRepository_GetFile_Call

func (*MockdataUsageRepository_GetFile_Call) RunAndReturn 

func (_c *MockdataUsageRepository_GetFile_Call) RunAndReturn(run func(context.Context, string, string, *string) (io.ReadCloser, error)) *MockdataUsageRepository_GetFile_Call

type MockdataUsageRepository_ListFiles_Call 

type MockdataUsageRepository_ListFiles_Call struct {
	*mock.Call
}

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

func (*MockdataUsageRepository_ListFiles_Call) Return 

func (_c *MockdataUsageRepository_ListFiles_Call) Return(_a0 []model.AwsS3Entity, _a1 string, _a2 error) *MockdataUsageRepository_ListFiles_Call

func (*MockdataUsageRepository_ListFiles_Call) Run 

func (_c *MockdataUsageRepository_ListFiles_Call) Run(run func(ctx context.Context, bucket string, prefix *string)) *MockdataUsageRepository_ListFiles_Call

func (*MockdataUsageRepository_ListFiles_Call) RunAndReturn 

func (_c *MockdataUsageRepository_ListFiles_Call) RunAndReturn(run func(context.Context, string, *string) ([]model.AwsS3Entity, string, error)) *MockdataUsageRepository_ListFiles_Call

type ObjectMapper 

type ObjectMapper interface {
	MapObject(object string) *data_usage.UsageDataObjectReference
}

func ObjectMapperFactory 

func ObjectMapperFactory(ctx context.Context, repo dataObjectRepository, configMap *config.ConfigMap) (ObjectMapper, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.