Documentation
¶
Index ¶
- type MockDataExportClient
- type MockDatabase
- func (m *MockDatabase) ApplyExportSchema(newSchema warehouse.Schema) error
- func (m *MockDatabase) GetExportTableColumns() []string
- func (m *MockDatabase) InitExportTable(schema warehouse.Schema) (bool, error)
- func (m *MockDatabase) LastSyncPoint(_ context.Context) (time.Time, error)
- func (m *MockDatabase) LoadToWarehouse(filename string, _ time.Time) error
- func (m *MockDatabase) SaveSyncPoint(_ context.Context, endTime time.Time) error
- func (m *MockDatabase) ValueToString(val interface{}, isTime bool) string
- type MockStorage
- func (m *MockStorage) DeleteFile(_ context.Context, path string) error
- func (m *MockStorage) GetFilePrefix() string
- func (m *MockStorage) GetFileReference(name string) string
- func (m *MockStorage) LastSyncPoint(_ context.Context) (time.Time, error)
- func (m *MockStorage) ReadFile(_ context.Context, name string) (io.Reader, error)
- func (m *MockStorage) SaveFile(_ context.Context, name string, reader io.Reader) (string, error)
- func (m *MockStorage) SaveSyncPoint(ctx context.Context, endTime time.Time) error
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 (*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 (*MockDatabase) LoadToWarehouse ¶
func (m *MockDatabase) LoadToWarehouse(filename string, _ time.Time) error
func (*MockDatabase) SaveSyncPoint ¶
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 (*MockStorage) SaveSyncPoint ¶
Click to show internal directories.
Click to hide internal directories.