kvadmin

Documentation

Overview

Package kvadmin is a generated GoMock package.

Index

• Constants
• Variables
• func LoadSchemaRegistryFromKVStore(schemaReg namespace.SchemaRegistry, kvStore kv.Store) error
• type MockNamespaceMetadataAdminService
  • func NewMockNamespaceMetadataAdminService(ctrl *gomock.Controller) *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
  • func NewAdminService(store kv.Store, key string, idGen func() string) NamespaceMetadataAdminService

Constants

const (
	// M3DBNodeNamespacesKey is the KV key that holds namespaces.
	M3DBNodeNamespacesKey = "m3db.node.namespaces"
)

Variables

var (
	ErrNotImplemented        = errors.New("api not implemented")
	ErrNamespaceNotFound     = errors.New("namespace is not found")
	ErrNamespaceAlreadyExist = errors.New("namespace already exists")
)

Functions

func LoadSchemaRegistryFromKVStore

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

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

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