mockstorage

Documentation

Index

• type MockStorage
  • func NewMockStorage() *MockStorage
  • func (s *MockStorage) Close()
  • func (s *MockStorage) EstimateTableRowsCount(table abstract.TableID) (uint64, error)
  • func (s *MockStorage) ExactTableRowsCount(table abstract.TableID) (uint64, error)
  • func (s *MockStorage) LoadRandomSample(table abstract.TableDescription, pusher abstract.Pusher) error
  • func (s *MockStorage) LoadSampleBySet(table abstract.TableDescription, keySet []map[string]interface{}, ...) error
  • func (s *MockStorage) LoadTable(ctx context.Context, table abstract.TableDescription, pusher abstract.Pusher) error
  • func (s *MockStorage) LoadTopBottomSample(table abstract.TableDescription, pusher abstract.Pusher) error
  • func (s *MockStorage) Ping() error
  • func (s *MockStorage) TableAccessible(table abstract.TableDescription) bool
  • func (s *MockStorage) TableExists(table abstract.TableID) (bool, error)
  • func (s *MockStorage) TableList(in abstract.IncludeTableList) (abstract.TableMap, error)
  • func (s *MockStorage) TableSchema(ctx context.Context, table abstract.TableID) (*abstract.TableSchema, error)
  • func (s *MockStorage) TableSizeInBytes(table abstract.TableID) (uint64, error)

Types

type MockStorage

type MockStorage struct {
	TableSchemaF            func(ctx context.Context, table abstract.TableID) (*abstract.TableSchema, error)
	CloseF                  func()
	PingF                   func() error
	LoadTableF              func(ctx context.Context, table abstract.TableDescription, pusher abstract.Pusher) error
	TableListF              func(abstract.IncludeTableList) (abstract.TableMap, error)
	ExactTableRowsCountF    func(table abstract.TableID) (uint64, error)
	EstimateTableRowsCountF func(table abstract.TableID) (uint64, error)
	TableExistsF            func(table abstract.TableID) (bool, error)

	// sampleable
	TableSizeInBytesF    func(table abstract.TableID) (uint64, error)
	LoadTopBottomSampleF func(table abstract.TableDescription, pusher abstract.Pusher) error
	LoadRandomSampleF    func(table abstract.TableDescription, pusher abstract.Pusher) error
	LoadSampleBySetF     func(table abstract.TableDescription, keySet []map[string]interface{}, pusher abstract.Pusher) error
	TableAccessibleF     func(table abstract.TableDescription) bool
}

func NewMockStorage

func NewMockStorage() *MockStorage

func (*MockStorage) Close

func (s *MockStorage) Close()

func (*MockStorage) EstimateTableRowsCount

func (s *MockStorage) EstimateTableRowsCount(table abstract.TableID) (uint64, error)

func (*MockStorage) ExactTableRowsCount

func (s *MockStorage) ExactTableRowsCount(table abstract.TableID) (uint64, error)

func (*MockStorage) LoadRandomSample

func (s *MockStorage) LoadRandomSample(table abstract.TableDescription, pusher abstract.Pusher) error

func (*MockStorage) LoadSampleBySet

func (s *MockStorage) LoadSampleBySet(table abstract.TableDescription, keySet []map[string]interface{}, pusher abstract.Pusher) error

func (*MockStorage) LoadTable

func (s *MockStorage) LoadTable(ctx context.Context, table abstract.TableDescription, pusher abstract.Pusher) error

func (*MockStorage) LoadTopBottomSample

func (s *MockStorage) LoadTopBottomSample(table abstract.TableDescription, pusher abstract.Pusher) error

func (*MockStorage) Ping

func (s *MockStorage) Ping() error

func (*MockStorage) TableAccessible

func (s *MockStorage) TableAccessible(table abstract.TableDescription) bool

func (*MockStorage) TableExists

func (s *MockStorage) TableExists(table abstract.TableID) (bool, error)

func (*MockStorage) TableList

func (s *MockStorage) TableList(in abstract.IncludeTableList) (abstract.TableMap, error)

func (*MockStorage) TableSchema

func (s *MockStorage) TableSchema(ctx context.Context, table abstract.TableID) (*abstract.TableSchema, error)

func (*MockStorage) TableSizeInBytes

func (s *MockStorage) TableSizeInBytes(table abstract.TableID) (uint64, error)