Documentation
¶
Overview ¶
Package kvadmin is a generated GoMock package.
Index ¶
- Constants
- Variables
- func LoadSchemaRegistryFromKVStore(schemaReg namespace.SchemaRegistry, kvStore kv.Store) error
- type MockNamespaceMetadataAdminService
- func (m *MockNamespaceMetadataAdminService) Add(name string, options *namespace.NamespaceOptions) error
- func (m *MockNamespaceMetadataAdminService) Delete(name string) error
- func (m *MockNamespaceMetadataAdminService) DeploySchema(name, protoFileName, msgName string, protos map[string]string) (string, error)
- func (m *MockNamespaceMetadataAdminService) EXPECT() *MockNamespaceMetadataAdminServiceMockRecorder
- func (m *MockNamespaceMetadataAdminService) Get(name string) (*namespace.NamespaceOptions, error)
- func (m *MockNamespaceMetadataAdminService) GetAll() (*namespace.Registry, error)
- func (m *MockNamespaceMetadataAdminService) ResetSchema(name string) error
- func (m *MockNamespaceMetadataAdminService) Set(name string, options *namespace.NamespaceOptions) error
- type MockNamespaceMetadataAdminServiceMockRecorder
- func (mr *MockNamespaceMetadataAdminServiceMockRecorder) Add(name, options interface{}) *gomock.Call
- func (mr *MockNamespaceMetadataAdminServiceMockRecorder) Delete(name interface{}) *gomock.Call
- func (mr *MockNamespaceMetadataAdminServiceMockRecorder) DeploySchema(name, protoFileName, msgName, protos interface{}) *gomock.Call
- func (mr *MockNamespaceMetadataAdminServiceMockRecorder) Get(name interface{}) *gomock.Call
- func (mr *MockNamespaceMetadataAdminServiceMockRecorder) GetAll() *gomock.Call
- func (mr *MockNamespaceMetadataAdminServiceMockRecorder) ResetSchema(name interface{}) *gomock.Call
- func (mr *MockNamespaceMetadataAdminServiceMockRecorder) Set(name, options interface{}) *gomock.Call
- type NamespaceMetadataAdminService
Constants ¶
const (
// M3DBNodeNamespacesKey is the KV key that holds namespaces.
M3DBNodeNamespacesKey = "m3db.node.namespaces"
)
Variables ¶
var ( // ErrNamespaceNotFound is returned when namespace is not found in registry. ErrNamespaceNotFound = errors.New("namespace is not found") // ErrNamespaceAlreadyExist is returned for addition of a namespace which already exists. ErrNamespaceAlreadyExist = errors.New("namespace already exists") )
Functions ¶
func LoadSchemaRegistryFromKVStore ¶ added in v0.12.0
func LoadSchemaRegistryFromKVStore(schemaReg namespace.SchemaRegistry, kvStore kv.Store) error
Types ¶
type MockNamespaceMetadataAdminService ¶
type MockNamespaceMetadataAdminService struct {
// contains filtered or unexported fields
}
MockNamespaceMetadataAdminService is a mock of NamespaceMetadataAdminService interface
func NewMockNamespaceMetadataAdminService ¶
func NewMockNamespaceMetadataAdminService(ctrl *gomock.Controller) *MockNamespaceMetadataAdminService
NewMockNamespaceMetadataAdminService creates a new mock instance
func (*MockNamespaceMetadataAdminService) Add ¶
func (m *MockNamespaceMetadataAdminService) Add(name string, options *namespace.NamespaceOptions) error
Add mocks base method
func (*MockNamespaceMetadataAdminService) Delete ¶
func (m *MockNamespaceMetadataAdminService) Delete(name string) error
Delete mocks base method
func (*MockNamespaceMetadataAdminService) DeploySchema ¶
func (m *MockNamespaceMetadataAdminService) DeploySchema(name, protoFileName, msgName string, protos map[string]string) (string, error)
DeploySchema mocks base method
func (*MockNamespaceMetadataAdminService) EXPECT ¶
func (m *MockNamespaceMetadataAdminService) EXPECT() *MockNamespaceMetadataAdminServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockNamespaceMetadataAdminService) Get ¶
func (m *MockNamespaceMetadataAdminService) Get(name string) (*namespace.NamespaceOptions, error)
Get mocks base method
func (*MockNamespaceMetadataAdminService) GetAll ¶
func (m *MockNamespaceMetadataAdminService) GetAll() (*namespace.Registry, error)
GetAll mocks base method
func (*MockNamespaceMetadataAdminService) ResetSchema ¶ added in v0.9.6
func (m *MockNamespaceMetadataAdminService) ResetSchema(name string) error
ResetSchema mocks base method
func (*MockNamespaceMetadataAdminService) Set ¶
func (m *MockNamespaceMetadataAdminService) Set(name string, options *namespace.NamespaceOptions) error
Set mocks base method
type MockNamespaceMetadataAdminServiceMockRecorder ¶
type MockNamespaceMetadataAdminServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockNamespaceMetadataAdminServiceMockRecorder is the mock recorder for MockNamespaceMetadataAdminService
func (*MockNamespaceMetadataAdminServiceMockRecorder) Add ¶
func (mr *MockNamespaceMetadataAdminServiceMockRecorder) Add(name, options interface{}) *gomock.Call
Add indicates an expected call of Add
func (*MockNamespaceMetadataAdminServiceMockRecorder) Delete ¶
func (mr *MockNamespaceMetadataAdminServiceMockRecorder) Delete(name interface{}) *gomock.Call
Delete indicates an expected call of Delete
func (*MockNamespaceMetadataAdminServiceMockRecorder) DeploySchema ¶
func (mr *MockNamespaceMetadataAdminServiceMockRecorder) DeploySchema(name, protoFileName, msgName, protos interface{}) *gomock.Call
DeploySchema indicates an expected call of DeploySchema
func (*MockNamespaceMetadataAdminServiceMockRecorder) Get ¶
func (mr *MockNamespaceMetadataAdminServiceMockRecorder) Get(name interface{}) *gomock.Call
Get indicates an expected call of Get
func (*MockNamespaceMetadataAdminServiceMockRecorder) GetAll ¶
func (mr *MockNamespaceMetadataAdminServiceMockRecorder) GetAll() *gomock.Call
GetAll indicates an expected call of GetAll
func (*MockNamespaceMetadataAdminServiceMockRecorder) ResetSchema ¶ added in v0.9.6
func (mr *MockNamespaceMetadataAdminServiceMockRecorder) ResetSchema(name interface{}) *gomock.Call
ResetSchema indicates an expected call of ResetSchema
func (*MockNamespaceMetadataAdminServiceMockRecorder) Set ¶
func (mr *MockNamespaceMetadataAdminServiceMockRecorder) Set(name, options interface{}) *gomock.Call
Set indicates an expected call of Set
type NamespaceMetadataAdminService ¶
type NamespaceMetadataAdminService interface { // GetAll gets namespace options for all namespaces. GetAll() (*nsproto.Registry, error) // Get gets option for the specified namespace. Get(name string) (*nsproto.NamespaceOptions, error) // Add adds a new namespace and set its options. Add(name string, options *nsproto.NamespaceOptions) error // Set sets the options for the specified namespace. Set(name string, options *nsproto.NamespaceOptions) error // Delete deletes the specified namespace. Delete(name string) error // DeploySchema deploys a new version schema to the specified namespace. // An opaque string (deployID) is returned if successful. // Application developer is to include the deployID in their m3db client configuration // when they upgrade their application to use the new schema version. DeploySchema(name, protoFileName, msgName string, protos map[string]string) (string, error) // ResetSchema reset schema for the specified namespace. ResetSchema(name string) error }
func NewAdminService ¶
func NewAdminService(store kv.Store, key string, idGen func() string) NamespaceMetadataAdminService