testing

package
v1.4.0 Latest Latest
Warning

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

Go to latest
Published: Oct 23, 2023 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockDataExportClient

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

func NewMockDataExportClient

func NewMockDataExportClient(datafile string) *MockDataExportClient

func (*MockDataExportClient) CreateExport

func (m *MockDataExportClient) CreateExport(start, end time.Time, fields []string) (string, error)

func (*MockDataExportClient) GetExport

func (m *MockDataExportClient) GetExport(exportId string) (io.ReadCloser, error)

func (*MockDataExportClient) GetExportProgress

func (m *MockDataExportClient) GetExportProgress(operationId string) (int, string, error)

type MockDatabase

type MockDatabase struct {
	Initialized bool
	Syncs       []time.Time
	LoadedFiles []string
	// contains filtered or unexported fields
}

func NewMockDatabase

func NewMockDatabase(existingColumns []string) *MockDatabase

func (*MockDatabase) ApplyExportSchema

func (m *MockDatabase) ApplyExportSchema(newSchema warehouse.Schema) error

func (*MockDatabase) GetExportTableColumns

func (m *MockDatabase) GetExportTableColumns() []string

func (*MockDatabase) InitExportTable

func (m *MockDatabase) InitExportTable(schema warehouse.Schema) (bool, error)

func (*MockDatabase) LastSyncPoint

func (m *MockDatabase) LastSyncPoint(_ context.Context) (time.Time, error)

func (*MockDatabase) LoadToWarehouse

func (m *MockDatabase) LoadToWarehouse(filename string, _ time.Time) error

func (*MockDatabase) SaveSyncPoint

func (m *MockDatabase) SaveSyncPoint(_ context.Context, endTime time.Time) error

func (*MockDatabase) ValueToString

func (m *MockDatabase) ValueToString(val interface{}, isTime bool) string

type MockStorage

type MockStorage struct {
	Syncs         []time.Time
	UploadedFiles map[string][]byte
	DeletedFiles  []string
	FilePrefix    string
}

func NewMockStorage

func NewMockStorage() *MockStorage

func (*MockStorage) DeleteFile

func (m *MockStorage) DeleteFile(_ context.Context, path string) error

func (*MockStorage) GetFilePrefix added in v1.1.0

func (m *MockStorage) GetFilePrefix() string

func (*MockStorage) GetFileReference

func (m *MockStorage) GetFileReference(name string) string

func (*MockStorage) LastSyncPoint

func (m *MockStorage) LastSyncPoint(_ context.Context) (time.Time, error)

func (*MockStorage) ReadFile

func (m *MockStorage) ReadFile(_ context.Context, name string) (io.Reader, error)

func (*MockStorage) SaveFile

func (m *MockStorage) SaveFile(_ context.Context, name string, reader io.Reader) (string, error)

func (*MockStorage) SaveSyncPoint

func (m *MockStorage) SaveSyncPoint(ctx context.Context, endTime time.Time) error

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL