kvadmin

package
v1.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 7, 2022 License: Apache-2.0 Imports: 9 Imported by: 2

Documentation

Overview

Package kvadmin is a generated GoMock package.

Index

Constants

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

Variables

View Source
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

Add mocks base method.

func (*MockNamespaceMetadataAdminService) Delete

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

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockNamespaceMetadataAdminService) Get

Get mocks base method.

func (*MockNamespaceMetadataAdminService) GetAll

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

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL