Documentation ¶
Overview ¶
Package mocks is the Mocks generated by mockgen..
These are the commands used to generate the mocks found here. Currently generated using github.com/rkuris/mock to reduce the number of warnings from golint.
mocks/client.go:
mockgen -package mocks github.com/uber-go/dosa Client,AdminClient > mocks/client.go
mocks/connector.go:
mockgen -package mocks github.com/uber-go/dosa Connector > mocks/connector.go
OR just run make mocks
Index ¶
- type MockAdminClient
- func (_m *MockAdminClient) CheckSchema(_param0 context.Context, _param1 string) (*dosa.SchemaStatus, error)
- func (_m *MockAdminClient) CheckSchemaStatus(_param0 context.Context, _param1 string, _param2 int32) (*dosa.SchemaStatus, error)
- func (_m *MockAdminClient) CreateScope(_param0 context.Context, _param1 string) error
- func (_m *MockAdminClient) Directories(_param0 []string) dosa.AdminClient
- func (_m *MockAdminClient) DropScope(_param0 context.Context, _param1 string) error
- func (_m *MockAdminClient) EXPECT() *_MockAdminClientRecorder
- func (_m *MockAdminClient) Excludes(_param0 []string) dosa.AdminClient
- func (_m *MockAdminClient) GetSchema() ([]*dosa.EntityDefinition, error)
- func (_m *MockAdminClient) Scope(_param0 string) dosa.AdminClient
- func (_m *MockAdminClient) TruncateScope(_param0 context.Context, _param1 string) error
- func (_m *MockAdminClient) UpsertSchema(_param0 context.Context, _param1 string) (*dosa.SchemaStatus, error)
- type MockClient
- func (_m *MockClient) CreateIfNotExists(_param0 context.Context, _param1 dosa.DomainObject) error
- func (_m *MockClient) EXPECT() *_MockClientRecorder
- func (_m *MockClient) Initialize(_param0 context.Context) error
- func (_m *MockClient) Range(_param0 context.Context, _param1 *dosa.RangeOp) ([]dosa.DomainObject, string, error)
- func (_m *MockClient) Read(_param0 context.Context, _param1 []string, _param2 dosa.DomainObject) error
- func (_m *MockClient) Remove(_param0 context.Context, _param1 dosa.DomainObject) error
- func (_m *MockClient) RemoveRange(_param0 context.Context, _param1 *dosa.RemoveRangeOp) error
- func (_m *MockClient) ScanEverything(_param0 context.Context, _param1 *dosa.ScanOp) ([]dosa.DomainObject, string, error)
- func (_m *MockClient) Upsert(_param0 context.Context, _param1 []string, _param2 dosa.DomainObject) error
- func (_m *MockClient) WalkRange(_param0 context.Context, _param1 *dosa.RangeOp, ...) error
- type MockConnector
- func (_m *MockConnector) CheckSchema(_param0 context.Context, _param1 string, _param2 string, ...) (int32, error)
- func (_m *MockConnector) CheckSchemaStatus(_param0 context.Context, _param1 string, _param2 string, _param3 int32) (*dosa.SchemaStatus, error)
- func (_m *MockConnector) CreateIfNotExists(_param0 context.Context, _param1 *dosa.EntityInfo, ...) error
- func (_m *MockConnector) CreateScope(_param0 context.Context, _param1 string) error
- func (_m *MockConnector) DropScope(_param0 context.Context, _param1 string) error
- func (_m *MockConnector) EXPECT() *_MockConnectorRecorder
- func (_m *MockConnector) MultiRead(_param0 context.Context, _param1 *dosa.EntityInfo, ...) ([]*dosa.FieldValuesOrError, error)
- func (_m *MockConnector) MultiRemove(_param0 context.Context, _param1 *dosa.EntityInfo, ...) ([]error, error)
- func (_m *MockConnector) MultiUpsert(_param0 context.Context, _param1 *dosa.EntityInfo, ...) ([]error, error)
- func (_m *MockConnector) Range(_param0 context.Context, _param1 *dosa.EntityInfo, ...) ([]map[string]dosa.FieldValue, string, error)
- func (_m *MockConnector) Read(_param0 context.Context, _param1 *dosa.EntityInfo, ...) (map[string]dosa.FieldValue, error)
- func (_m *MockConnector) Remove(_param0 context.Context, _param1 *dosa.EntityInfo, ...) error
- func (_m *MockConnector) RemoveRange(_param0 context.Context, _param1 *dosa.EntityInfo, ...) error
- func (_m *MockConnector) Scan(_param0 context.Context, _param1 *dosa.EntityInfo, _param2 []string, ...) ([]map[string]dosa.FieldValue, string, error)
- func (_m *MockConnector) ScopeExists(_param0 context.Context, _param1 string) (bool, error)
- func (_m *MockConnector) Search(_param0 context.Context, _param1 *dosa.EntityInfo, ...) ([]map[string]dosa.FieldValue, string, error)
- func (_m *MockConnector) Shutdown() error
- func (_m *MockConnector) TruncateScope(_param0 context.Context, _param1 string) error
- func (_m *MockConnector) Upsert(_param0 context.Context, _param1 *dosa.EntityInfo, ...) error
- func (_m *MockConnector) UpsertSchema(_param0 context.Context, _param1 string, _param2 string, ...) (*dosa.SchemaStatus, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockAdminClient ¶
type MockAdminClient struct {
// contains filtered or unexported fields
}
MockAdminClient is a mock of AdminClient interface
func NewMockAdminClient ¶
func NewMockAdminClient(ctrl *gomock.Controller) *MockAdminClient
NewMockAdminClient creates a new mock
func (*MockAdminClient) CheckSchema ¶
func (_m *MockAdminClient) CheckSchema(_param0 context.Context, _param1 string) (*dosa.SchemaStatus, error)
CheckSchema is a mock implementation of MockAdminClient.CheckSchema
func (*MockAdminClient) CheckSchemaStatus ¶
func (_m *MockAdminClient) CheckSchemaStatus(_param0 context.Context, _param1 string, _param2 int32) (*dosa.SchemaStatus, error)
CheckSchemaStatus is a mock implementation of MockAdminClient.CheckSchemaStatus
func (*MockAdminClient) CreateScope ¶
func (_m *MockAdminClient) CreateScope(_param0 context.Context, _param1 string) error
CreateScope is a mock implementation of MockAdminClient.CreateScope
func (*MockAdminClient) Directories ¶
func (_m *MockAdminClient) Directories(_param0 []string) dosa.AdminClient
Directories is a mock implementation of MockAdminClient.Directories
func (*MockAdminClient) DropScope ¶
func (_m *MockAdminClient) DropScope(_param0 context.Context, _param1 string) error
DropScope is a mock implementation of MockAdminClient.DropScope
func (*MockAdminClient) EXPECT ¶
func (_m *MockAdminClient) EXPECT() *_MockAdminClientRecorder
EXPECT adds an expectation
func (*MockAdminClient) Excludes ¶
func (_m *MockAdminClient) Excludes(_param0 []string) dosa.AdminClient
Excludes is a mock implementation of MockAdminClient.Excludes
func (*MockAdminClient) GetSchema ¶
func (_m *MockAdminClient) GetSchema() ([]*dosa.EntityDefinition, error)
GetSchema is a mock implementation of MockAdminClient.GetSchema
func (*MockAdminClient) Scope ¶
func (_m *MockAdminClient) Scope(_param0 string) dosa.AdminClient
Scope is a mock implementation of MockAdminClient.Scope
func (*MockAdminClient) TruncateScope ¶
func (_m *MockAdminClient) TruncateScope(_param0 context.Context, _param1 string) error
TruncateScope is a mock implementation of MockAdminClient.TruncateScope
func (*MockAdminClient) UpsertSchema ¶
func (_m *MockAdminClient) UpsertSchema(_param0 context.Context, _param1 string) (*dosa.SchemaStatus, error)
UpsertSchema is a mock implementation of MockAdminClient.UpsertSchema
type MockClient ¶
type MockClient struct {
// contains filtered or unexported fields
}
MockClient is a mock of Client interface
func NewMockClient ¶
func NewMockClient(ctrl *gomock.Controller) *MockClient
NewMockClient creates a new mock
func (*MockClient) CreateIfNotExists ¶
func (_m *MockClient) CreateIfNotExists(_param0 context.Context, _param1 dosa.DomainObject) error
CreateIfNotExists is a mock implementation of MockClient.CreateIfNotExists
func (*MockClient) EXPECT ¶
func (_m *MockClient) EXPECT() *_MockClientRecorder
EXPECT adds an expectation
func (*MockClient) Initialize ¶
func (_m *MockClient) Initialize(_param0 context.Context) error
Initialize is a mock implementation of MockClient.Initialize
func (*MockClient) Range ¶
func (_m *MockClient) Range(_param0 context.Context, _param1 *dosa.RangeOp) ([]dosa.DomainObject, string, error)
Range is a mock implementation of MockClient.Range
func (*MockClient) Read ¶
func (_m *MockClient) Read(_param0 context.Context, _param1 []string, _param2 dosa.DomainObject) error
Read is a mock implementation of MockClient.Read
func (*MockClient) Remove ¶
func (_m *MockClient) Remove(_param0 context.Context, _param1 dosa.DomainObject) error
Remove is a mock implementation of MockClient.Remove
func (*MockClient) RemoveRange ¶
func (_m *MockClient) RemoveRange(_param0 context.Context, _param1 *dosa.RemoveRangeOp) error
RemoveRange is a mock implementation of MockClient.RemoveRange
func (*MockClient) ScanEverything ¶
func (_m *MockClient) ScanEverything(_param0 context.Context, _param1 *dosa.ScanOp) ([]dosa.DomainObject, string, error)
ScanEverything is a mock implementation of MockClient.ScanEverything
func (*MockClient) Upsert ¶
func (_m *MockClient) Upsert(_param0 context.Context, _param1 []string, _param2 dosa.DomainObject) error
Upsert is a mock implementation of MockClient.Upsert
type MockConnector ¶
type MockConnector struct {
// contains filtered or unexported fields
}
MockConnector is a mock of Connector interface
func NewMockConnector ¶
func NewMockConnector(ctrl *gomock.Controller) *MockConnector
NewMockConnector creates a new mock
func (*MockConnector) CheckSchema ¶
func (_m *MockConnector) CheckSchema(_param0 context.Context, _param1 string, _param2 string, _param3 []*dosa.EntityDefinition) (int32, error)
CheckSchema is a mock implementation of MockConnector.CheckSchema
func (*MockConnector) CheckSchemaStatus ¶
func (_m *MockConnector) CheckSchemaStatus(_param0 context.Context, _param1 string, _param2 string, _param3 int32) (*dosa.SchemaStatus, error)
CheckSchemaStatus is a mock implementation of MockConnector.CheckSchemaStatus
func (*MockConnector) CreateIfNotExists ¶
func (_m *MockConnector) CreateIfNotExists(_param0 context.Context, _param1 *dosa.EntityInfo, _param2 map[string]dosa.FieldValue) error
CreateIfNotExists is a mock implementation of MockConnector.CreateIfNotExists
func (*MockConnector) CreateScope ¶
func (_m *MockConnector) CreateScope(_param0 context.Context, _param1 string) error
CreateScope is a mock implementation of MockConnector.CreateScope
func (*MockConnector) DropScope ¶
func (_m *MockConnector) DropScope(_param0 context.Context, _param1 string) error
DropScope is a mock implementation of MockConnector.DropScope
func (*MockConnector) EXPECT ¶
func (_m *MockConnector) EXPECT() *_MockConnectorRecorder
EXPECT adds an expectation
func (*MockConnector) MultiRead ¶
func (_m *MockConnector) MultiRead(_param0 context.Context, _param1 *dosa.EntityInfo, _param2 []map[string]dosa.FieldValue, _param3 []string) ([]*dosa.FieldValuesOrError, error)
MultiRead is a mock implementation of MockConnector.MultiRead
func (*MockConnector) MultiRemove ¶
func (_m *MockConnector) MultiRemove(_param0 context.Context, _param1 *dosa.EntityInfo, _param2 []map[string]dosa.FieldValue) ([]error, error)
MultiRemove is a mock implementation of MockConnector.MultiRemove
func (*MockConnector) MultiUpsert ¶
func (_m *MockConnector) MultiUpsert(_param0 context.Context, _param1 *dosa.EntityInfo, _param2 []map[string]dosa.FieldValue) ([]error, error)
MultiUpsert is a mock implementation of MockConnector.MultiUpsert
func (*MockConnector) Range ¶
func (_m *MockConnector) Range(_param0 context.Context, _param1 *dosa.EntityInfo, _param2 map[string][]*dosa.Condition, _param3 []string, _param4 string, _param5 int) ([]map[string]dosa.FieldValue, string, error)
Range is a mock implementation of MockConnector.Range
func (*MockConnector) Read ¶
func (_m *MockConnector) Read(_param0 context.Context, _param1 *dosa.EntityInfo, _param2 map[string]dosa.FieldValue, _param3 []string) (map[string]dosa.FieldValue, error)
Read is a mock implementation of MockConnector.Read
func (*MockConnector) Remove ¶
func (_m *MockConnector) Remove(_param0 context.Context, _param1 *dosa.EntityInfo, _param2 map[string]dosa.FieldValue) error
Remove is a mock implementation of MockConnector.Remove
func (*MockConnector) RemoveRange ¶
func (_m *MockConnector) RemoveRange(_param0 context.Context, _param1 *dosa.EntityInfo, _param2 map[string][]*dosa.Condition) error
RemoveRange is a mock implementation of MockConnector.RemoveRange
func (*MockConnector) Scan ¶
func (_m *MockConnector) Scan(_param0 context.Context, _param1 *dosa.EntityInfo, _param2 []string, _param3 string, _param4 int) ([]map[string]dosa.FieldValue, string, error)
Scan is a mock implementation of MockConnector.Scan
func (*MockConnector) ScopeExists ¶
ScopeExists is a mock implementation of MockConnector.ScopeExists
func (*MockConnector) Search ¶
func (_m *MockConnector) Search(_param0 context.Context, _param1 *dosa.EntityInfo, _param2 dosa.FieldNameValuePair, _param3 []string, _param4 string, _param5 int) ([]map[string]dosa.FieldValue, string, error)
Search is a mock implementation of MockConnector.Search
func (*MockConnector) Shutdown ¶
func (_m *MockConnector) Shutdown() error
Shutdown is a mock implementation of MockConnector.Shutdown
func (*MockConnector) TruncateScope ¶
func (_m *MockConnector) TruncateScope(_param0 context.Context, _param1 string) error
TruncateScope is a mock implementation of MockConnector.TruncateScope
func (*MockConnector) Upsert ¶
func (_m *MockConnector) Upsert(_param0 context.Context, _param1 *dosa.EntityInfo, _param2 map[string]dosa.FieldValue) error
Upsert is a mock implementation of MockConnector.Upsert
func (*MockConnector) UpsertSchema ¶
func (_m *MockConnector) UpsertSchema(_param0 context.Context, _param1 string, _param2 string, _param3 []*dosa.EntityDefinition) (*dosa.SchemaStatus, error)
UpsertSchema is a mock implementation of MockConnector.UpsertSchema