test

Documentation

Index

• type MockBpKinesisConfigBackend
  • func NewMockBpKinesisConfigBackend() *MockBpKinesisConfigBackend
  • func (m *MockBpKinesisConfigBackend) AllKinesisConfigs() ([]scoop_protocol.AnnotatedKinesisConfig, error)
  • func (m *MockBpKinesisConfigBackend) CreateKinesisConfig(config *scoop_protocol.AnnotatedKinesisConfig, user string) *core.WebError
  • func (m *MockBpKinesisConfigBackend) DropKinesisConfig(config *scoop_protocol.AnnotatedKinesisConfig, reason string, user string) error
  • func (m *MockBpKinesisConfigBackend) KinesisConfig(account int64, streamType string, name string) (*scoop_protocol.AnnotatedKinesisConfig, error)
  • func (m *MockBpKinesisConfigBackend) UpdateKinesisConfig(update *scoop_protocol.AnnotatedKinesisConfig, user string) *core.WebError
• type MockBpSchemaBackend
  • func NewMockBpSchemaBackend(initMetadata map[string]map[string]bpdb.EventMetadataRow) *MockBpSchemaBackend
  • func (m *MockBpSchemaBackend) AllEventMetadata() (*bpdb.AllEventMetadata, error)
  • func (m *MockBpSchemaBackend) AllSchemas() ([]bpdb.AnnotatedSchema, error)
  • func (m *MockBpSchemaBackend) CreateSchema(schema *scoop_protocol.Config, user string) *core.WebError
  • func (m *MockBpSchemaBackend) DropSchema(schema *bpdb.AnnotatedSchema, reason string, exists bool, user string) error
  • func (m *MockBpSchemaBackend) GetAllEventMetadataCalls() int32
  • func (m *MockBpSchemaBackend) GetAllSchemasCalls() int32
  • func (m *MockBpSchemaBackend) Migration(table string, from int, to int) ([]*scoop_protocol.Operation, error)
  • func (m *MockBpSchemaBackend) Schema(name string, version *int) (*bpdb.AnnotatedSchema, error)
  • func (m *MockBpSchemaBackend) UpdateEventMetadata(update *core.ClientUpdateEventMetadataRequest, user string) *core.WebError
  • func (m *MockBpSchemaBackend) UpdateSchema(update *core.ClientUpdateSchemaRequest, user string) *core.WebError
• type MockBpdb
  • func NewMockBpdb(mm map[string]bpdb.MaintenanceMode, activeUsers []*bpdb.ActiveUser, ...) *MockBpdb
  • func (m *MockBpdb) ActiveUsersLast30Days() ([]*bpdb.ActiveUser, error)
  • func (m *MockBpdb) DailyChangesLast30Days() ([]*bpdb.DailyChange, error)
  • func (m *MockBpdb) GetMaintenanceMode() bpdb.MaintenanceMode
  • func (m *MockBpdb) GetSchemaMaintenanceMode(schema string) (bpdb.MaintenanceMode, error)
  • func (m *MockBpdb) SetMaintenanceMode(switchingOn bool, user, reason string) error
  • func (m *MockBpdb) SetSchemaMaintenanceMode(schema string, switchingOn bool, user, reason string) error

Types

type MockBpKinesisConfigBackend

type MockBpKinesisConfigBackend struct {
}

MockBpKinesisConfigBackend is a mock for the bpdb/BpKinesisConfigBackend interface

func NewMockBpKinesisConfigBackend

func NewMockBpKinesisConfigBackend() *MockBpKinesisConfigBackend

NewMockBpKinesisConfigBackend creates a new mock kinesis config backend.

func (*MockBpKinesisConfigBackend) AllKinesisConfigs

func (m *MockBpKinesisConfigBackend) AllKinesisConfigs() ([]scoop_protocol.AnnotatedKinesisConfig, error)

AllKinesisConfigs returns nil

func (*MockBpKinesisConfigBackend) CreateKinesisConfig

func (m *MockBpKinesisConfigBackend) CreateKinesisConfig(config *scoop_protocol.AnnotatedKinesisConfig, user string) *core.WebError

CreateKinesisConfig returns nil

func (*MockBpKinesisConfigBackend) DropKinesisConfig

func (m *MockBpKinesisConfigBackend) DropKinesisConfig(config *scoop_protocol.AnnotatedKinesisConfig, reason string, user string) error

DropKinesisConfig returns nil

func (*MockBpKinesisConfigBackend) KinesisConfig

func (m *MockBpKinesisConfigBackend) KinesisConfig(account int64, streamType string, name string) (*scoop_protocol.AnnotatedKinesisConfig, error)

KinesisConfig returns nil

func (*MockBpKinesisConfigBackend) UpdateKinesisConfig

func (m *MockBpKinesisConfigBackend) UpdateKinesisConfig(update *scoop_protocol.AnnotatedKinesisConfig, user string) *core.WebError

UpdateKinesisConfig returns nil

type MockBpSchemaBackend

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

MockBpSchemaBackend is a mock for the bpdb/BpSchemaBackend interface which tracks how many times AllSchemas has been called

func NewMockBpSchemaBackend

func NewMockBpSchemaBackend(initMetadata map[string]map[string]bpdb.EventMetadataRow) *MockBpSchemaBackend

NewMockBpSchemaBackend creates a new mock schema backend.

func (*MockBpSchemaBackend) AllEventMetadata

func (m *MockBpSchemaBackend) AllEventMetadata() (*bpdb.AllEventMetadata, error)

AllEventMetadata increments the number of AllEventMetadata calls

func (*MockBpSchemaBackend) AllSchemas

func (m *MockBpSchemaBackend) AllSchemas() ([]bpdb.AnnotatedSchema, error)

AllSchemas increments the number of AllSchemas calls and return nils.

func (*MockBpSchemaBackend) CreateSchema

func (m *MockBpSchemaBackend) CreateSchema(schema *scoop_protocol.Config, user string) *core.WebError

CreateSchema returns nil.

func (*MockBpSchemaBackend) DropSchema

func (m *MockBpSchemaBackend) DropSchema(schema *bpdb.AnnotatedSchema, reason string, exists bool, user string) error

DropSchema return nil.

func (*MockBpSchemaBackend) GetAllEventMetadataCalls

func (m *MockBpSchemaBackend) GetAllEventMetadataCalls() int32

GetAllEventMetadataCalls returns the number of times EventMetadata() has been called.

func (*MockBpSchemaBackend) GetAllSchemasCalls

func (m *MockBpSchemaBackend) GetAllSchemasCalls() int32

GetAllSchemasCalls returns the number of times AllSchemas() has been called.

func (*MockBpSchemaBackend) Migration

func (m *MockBpSchemaBackend) Migration(table string, from int, to int) ([]*scoop_protocol.Operation, error)

Migration returns nils.

func (*MockBpSchemaBackend) Schema

func (m *MockBpSchemaBackend) Schema(name string, version *int) (*bpdb.AnnotatedSchema, error)

Schema returns nils except when the event name is "this-table-exists" or "this-event-exists"

func (*MockBpSchemaBackend) UpdateEventMetadata

func (m *MockBpSchemaBackend) UpdateEventMetadata(update *core.ClientUpdateEventMetadataRequest, user string) *core.WebError

UpdateEventMetadata returns nil if update.EventName is in the returnMap

func (*MockBpSchemaBackend) UpdateSchema

func (m *MockBpSchemaBackend) UpdateSchema(update *core.ClientUpdateSchemaRequest, user string) *core.WebError

UpdateSchema returns nil.

type MockBpdb

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

MockBpdb is a mock for the bpdb/Bpdb interface which tracks whether the DB is in maintenance mode.

func NewMockBpdb

func NewMockBpdb(mm map[string]bpdb.MaintenanceMode, activeUsers []*bpdb.ActiveUser, dailyChanges []*bpdb.DailyChange) *MockBpdb

NewMockBpdb creates a new mock backend.

func (*MockBpdb) ActiveUsersLast30Days

func (m *MockBpdb) ActiveUsersLast30Days() ([]*bpdb.ActiveUser, error)

ActiveUsersLast30Days returns nils.

func (*MockBpdb) DailyChangesLast30Days

func (m *MockBpdb) DailyChangesLast30Days() ([]*bpdb.DailyChange, error)

DailyChangesLast30Days returns nils.

func (*MockBpdb) GetMaintenanceMode

func (m *MockBpdb) GetMaintenanceMode() bpdb.MaintenanceMode

GetMaintenanceMode returns current value (starts as false, can be set by SetMaintenanceMode).

func (*MockBpdb) GetSchemaMaintenanceMode

func (m *MockBpdb) GetSchemaMaintenanceMode(schema string) (bpdb.MaintenanceMode, error)

GetSchemaMaintenanceMode returns false, ""

func (*MockBpdb) SetMaintenanceMode

func (m *MockBpdb) SetMaintenanceMode(switchingOn bool, user, reason string) error

SetMaintenanceMode sets the maintenance mode in memory and returns nil.

func (*MockBpdb) SetSchemaMaintenanceMode

func (m *MockBpdb) SetSchemaMaintenanceMode(schema string, switchingOn bool, user, reason string) error

SetSchemaMaintenanceMode returns nil