namespace

package
v0.9.2 Latest Latest
Warning

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

 Go to latest Published: May 18, 2019 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Overview

Package namespace is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GenTestSchemaOptions 

func GenTestSchemaOptions(protoFile string, importPathPrefix ...string) *nsproto.SchemaOptions

func LoadSchemaRegistryFromFile 

func LoadSchemaRegistryFromFile(schemaReg SchemaRegistry, nsID ident.ID, protoFile string, msgName string, importPathPrefix ...string) error

func OptionsToProto 

func OptionsToProto(opts Options) *nsproto.NamespaceOptions

OptionsToProto converts Options -> nsproto.NamespaceOptions

func ToProto 

func ToProto(m Map) *nsproto.Registry

ToProto converts Map to nsproto.Registry

func ToRetention 

func ToRetention(
	ro *nsproto.RetentionOptions,
) (retention.Options, error)

ToRetention converts nsproto.RetentionOptions to retention.Options

Types

type Context 

type Context struct {
	ID     ident.ID
	Schema SchemaDescr
}

func NewContextFor 

func NewContextFor(id ident.ID, registry SchemaRegistry) Context

func NewContextFrom 

func NewContextFrom(nsMetadata Metadata) Context

type DynamicOptions 

type DynamicOptions interface {
	// Validate validates the options
	Validate() error

	// SetInstrumentOptions sets the instrumentation options
	SetInstrumentOptions(value instrument.Options) DynamicOptions

	// InstrumentOptions returns the instrumentation options
	InstrumentOptions() instrument.Options

	// SetConfigServiceClient sets the client of ConfigService
	SetConfigServiceClient(c client.Client) DynamicOptions

	// ConfigServiceClient returns the client of ConfigService
	ConfigServiceClient() client.Client

	// SetNamespaceRegistryKey sets the kv-store key used for the
	// NamespaceRegistry
	SetNamespaceRegistryKey(k string) DynamicOptions

	// NamespaceRegistryKey returns the kv-store key used for the
	// NamespaceRegistry
	NamespaceRegistryKey() string
}

DynamicOptions is a set of options for dynamic namespace registry

func NewDynamicOptions 

func NewDynamicOptions() DynamicOptions

NewDynamicOptions creates a new DynamicOptions

type IndexConfiguration 

type IndexConfiguration struct {
	Enabled   bool          `yaml:"enabled" validate:"nonzero"`
	BlockSize time.Duration `yaml:"blockSize" validate:"nonzero"`
}

IndexConfiguration controls the knobs to tweak indexing configuration.

func (*IndexConfiguration) Options 

func (ic *IndexConfiguration) Options() IndexOptions

Options returns the IndexOptions corresponding to the receiver struct.

type IndexOptions 

type IndexOptions interface {
	// Equal returns true if the provide value is equal to this one.
	Equal(value IndexOptions) bool

	// SetEnabled sets whether indexing is enabled.
	SetEnabled(value bool) IndexOptions

	// Enabled returns whether indexing is enabled.
	Enabled() bool

	// SetBlockSize returns the block size.
	SetBlockSize(value time.Duration) IndexOptions

	// BlockSize returns the block size.
	BlockSize() time.Duration
}

IndexOptions controls the indexing options for a namespace.

func NewIndexOptions 

func NewIndexOptions() IndexOptions

NewIndexOptions returns a new IndexOptions.

func ToIndexOptions 

func ToIndexOptions(
	io *nsproto.IndexOptions,
) (IndexOptions, error)

ToIndexOptions converts nsproto.IndexOptions to IndexOptions

type Initializer 

type Initializer interface {
	// Init will return a new Registry
	Init() (Registry, error)
}

Initializer can init new instances of namespace registries

func NewDynamicInitializer 

func NewDynamicInitializer(opts DynamicOptions) Initializer

NewDynamicInitializer returns a dynamic namespace initializer

func NewStaticInitializer 

func NewStaticInitializer(metadatas []Metadata) Initializer

NewStaticInitializer returns a new static registry initializer

type Map 

type Map interface {
	// Equal returns true if the provide value is equal to this one
	Equal(value Map) bool

	// Get gets the metadata for the provided namespace
	Get(ident.ID) (Metadata, error)

	// IDs returns the ID of known namespaces
	IDs() []ident.ID

	// Metadatas returns the metadata of known namespaces
	Metadatas() []Metadata
}

Map is mapping from known namespaces' ID to their Metadata

func FromProto 

func FromProto(protoRegistry nsproto.Registry) (Map, error)

FromProto converts nsproto.Registry -> Map

func NewMap 

func NewMap(metadatas []Metadata) (Map, error)

NewMap returns a new registry containing provided metadatas, providing a consistent order.

type MapConfiguration 

type MapConfiguration struct {
	Metadatas []MetadataConfiguration `yaml:"metadatas" validate:"nonzero"`
}

MapConfiguration is the configuration for a registry of namespaces

func (*MapConfiguration) Map 

func (m *MapConfiguration) Map() (Map, error)

Map returns a Map corresponding to the receiver struct

type MessageDescriptor 

type MessageDescriptor struct {
	*desc.MessageDescriptor
}

type Metadata 

type Metadata interface {
	// Equal returns true if the provide value is equal to this one
	Equal(value Metadata) bool

	// ID is the ID of the namespace
	ID() ident.ID

	// Options is the namespace options
	Options() Options
}

Metadata represents namespace metadata information

func NewMetadata 

func NewMetadata(id ident.ID, opts Options) (Metadata, error)

NewMetadata creates a new namespace metadata

func ToMetadata 

func ToMetadata(
	id string,
	opts *nsproto.NamespaceOptions,
) (Metadata, error)

ToMetadata converts nsproto.Options to Metadata

type MetadataConfiguration 

type MetadataConfiguration struct {
	ID                string                  `yaml:"id" validate:"nonzero"`
	BootstrapEnabled  *bool                   `yaml:"bootstrapEnabled"`
	FlushEnabled      *bool                   `yaml:"flushEnabled"`
	WritesToCommitLog *bool                   `yaml:"writesToCommitLog"`
	CleanupEnabled    *bool                   `yaml:"cleanupEnabled"`
	RepairEnabled     *bool                   `yaml:"repairEnabled"`
	ColdWritesEnabled *bool                   `yaml:"coldWritesEnabled"`
	Retention         retention.Configuration `yaml:"retention" validate:"nonzero"`
	Index             IndexConfiguration      `yaml:"index"`
}

MetadataConfiguration is the configuration for a single namespace

func (*MetadataConfiguration) Metadata 

func (mc *MetadataConfiguration) Metadata() (Metadata, error)

Metadata returns a Metadata corresponding to the receiver struct

type MetadataMatcher 

type MetadataMatcher interface {
	gomock.Matcher
}

MetadataMatcher is a gomock.Matcher that matches metadata

func NewMetadataMatcher 

func NewMetadataMatcher(md Metadata) MetadataMatcher

NewMetadataMatcher returns a new MetadataMatcher

type MockDynamicOptions 

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

MockDynamicOptions is a mock of DynamicOptions interface

func NewMockDynamicOptions 

func NewMockDynamicOptions(ctrl *gomock.Controller) *MockDynamicOptions

NewMockDynamicOptions creates a new mock instance

func (*MockDynamicOptions) ConfigServiceClient 

func (m *MockDynamicOptions) ConfigServiceClient() client.Client

ConfigServiceClient mocks base method

func (*MockDynamicOptions) EXPECT 

func (m *MockDynamicOptions) EXPECT() *MockDynamicOptionsMockRecorder

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

func (*MockDynamicOptions) InstrumentOptions 

func (m *MockDynamicOptions) InstrumentOptions() instrument.Options

InstrumentOptions mocks base method

func (*MockDynamicOptions) NamespaceRegistryKey 

func (m *MockDynamicOptions) NamespaceRegistryKey() string

NamespaceRegistryKey mocks base method

func (*MockDynamicOptions) SetConfigServiceClient 

func (m *MockDynamicOptions) SetConfigServiceClient(c client.Client) DynamicOptions

SetConfigServiceClient mocks base method

func (*MockDynamicOptions) SetInstrumentOptions 

func (m *MockDynamicOptions) SetInstrumentOptions(value instrument.Options) DynamicOptions

SetInstrumentOptions mocks base method

func (*MockDynamicOptions) SetNamespaceRegistryKey 

func (m *MockDynamicOptions) SetNamespaceRegistryKey(k string) DynamicOptions

SetNamespaceRegistryKey mocks base method

func (*MockDynamicOptions) Validate 

func (m *MockDynamicOptions) Validate() error

Validate mocks base method

type MockDynamicOptionsMockRecorder 

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

MockDynamicOptionsMockRecorder is the mock recorder for MockDynamicOptions

func (*MockDynamicOptionsMockRecorder) ConfigServiceClient 

func (mr *MockDynamicOptionsMockRecorder) ConfigServiceClient() *gomock.Call

ConfigServiceClient indicates an expected call of ConfigServiceClient

func (*MockDynamicOptionsMockRecorder) InstrumentOptions 

func (mr *MockDynamicOptionsMockRecorder) InstrumentOptions() *gomock.Call

InstrumentOptions indicates an expected call of InstrumentOptions

func (*MockDynamicOptionsMockRecorder) NamespaceRegistryKey 

func (mr *MockDynamicOptionsMockRecorder) NamespaceRegistryKey() *gomock.Call

NamespaceRegistryKey indicates an expected call of NamespaceRegistryKey

func (*MockDynamicOptionsMockRecorder) SetConfigServiceClient 

func (mr *MockDynamicOptionsMockRecorder) SetConfigServiceClient(c interface{}) *gomock.Call

SetConfigServiceClient indicates an expected call of SetConfigServiceClient

func (*MockDynamicOptionsMockRecorder) SetInstrumentOptions 

func (mr *MockDynamicOptionsMockRecorder) SetInstrumentOptions(value interface{}) *gomock.Call

SetInstrumentOptions indicates an expected call of SetInstrumentOptions

func (*MockDynamicOptionsMockRecorder) SetNamespaceRegistryKey 

func (mr *MockDynamicOptionsMockRecorder) SetNamespaceRegistryKey(k interface{}) *gomock.Call

SetNamespaceRegistryKey indicates an expected call of SetNamespaceRegistryKey

func (*MockDynamicOptionsMockRecorder) Validate 

func (mr *MockDynamicOptionsMockRecorder) Validate() *gomock.Call

Validate indicates an expected call of Validate

type MockIndexOptions 

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

MockIndexOptions is a mock of IndexOptions interface

func NewMockIndexOptions 

func NewMockIndexOptions(ctrl *gomock.Controller) *MockIndexOptions

NewMockIndexOptions creates a new mock instance

func (*MockIndexOptions) BlockSize 

func (m *MockIndexOptions) BlockSize() time.Duration

BlockSize mocks base method

func (*MockIndexOptions) EXPECT 

func (m *MockIndexOptions) EXPECT() *MockIndexOptionsMockRecorder

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

func (*MockIndexOptions) Enabled 

func (m *MockIndexOptions) Enabled() bool

Enabled mocks base method

func (*MockIndexOptions) Equal 

func (m *MockIndexOptions) Equal(value IndexOptions) bool

Equal mocks base method

func (*MockIndexOptions) SetBlockSize 

func (m *MockIndexOptions) SetBlockSize(value time.Duration) IndexOptions

SetBlockSize mocks base method

func (*MockIndexOptions) SetEnabled 

func (m *MockIndexOptions) SetEnabled(value bool) IndexOptions

SetEnabled mocks base method

type MockIndexOptionsMockRecorder 

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

MockIndexOptionsMockRecorder is the mock recorder for MockIndexOptions

func (*MockIndexOptionsMockRecorder) BlockSize 

func (mr *MockIndexOptionsMockRecorder) BlockSize() *gomock.Call

BlockSize indicates an expected call of BlockSize

func (*MockIndexOptionsMockRecorder) Enabled 

func (mr *MockIndexOptionsMockRecorder) Enabled() *gomock.Call

Enabled indicates an expected call of Enabled

func (*MockIndexOptionsMockRecorder) Equal 

func (mr *MockIndexOptionsMockRecorder) Equal(value interface{}) *gomock.Call

Equal indicates an expected call of Equal

func (*MockIndexOptionsMockRecorder) SetBlockSize 

func (mr *MockIndexOptionsMockRecorder) SetBlockSize(value interface{}) *gomock.Call

SetBlockSize indicates an expected call of SetBlockSize

func (*MockIndexOptionsMockRecorder) SetEnabled 

func (mr *MockIndexOptionsMockRecorder) SetEnabled(value interface{}) *gomock.Call

SetEnabled indicates an expected call of SetEnabled

type MockInitializer 

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

MockInitializer is a mock of Initializer interface

func NewMockInitializer 

func NewMockInitializer(ctrl *gomock.Controller) *MockInitializer

NewMockInitializer creates a new mock instance

func (*MockInitializer) EXPECT 

func (m *MockInitializer) EXPECT() *MockInitializerMockRecorder

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

func (*MockInitializer) Init 

func (m *MockInitializer) Init() (Registry, error)

Init mocks base method

type MockInitializerMockRecorder 

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

MockInitializerMockRecorder is the mock recorder for MockInitializer

func (*MockInitializerMockRecorder) Init 

func (mr *MockInitializerMockRecorder) Init() *gomock.Call

Init indicates an expected call of Init

type MockMap 

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

MockMap is a mock of Map interface

func NewMockMap 

func NewMockMap(ctrl *gomock.Controller) *MockMap

NewMockMap creates a new mock instance

func (*MockMap) EXPECT 

func (m *MockMap) EXPECT() *MockMapMockRecorder

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

func (*MockMap) Equal 

func (m *MockMap) Equal(value Map) bool

Equal mocks base method

func (*MockMap) Get 

func (m *MockMap) Get(arg0 ident.ID) (Metadata, error)

Get mocks base method

func (*MockMap) IDs 

func (m *MockMap) IDs() []ident.ID

IDs mocks base method

func (*MockMap) Metadatas 

func (m *MockMap) Metadatas() []Metadata

Metadatas mocks base method

type MockMapMockRecorder 

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

MockMapMockRecorder is the mock recorder for MockMap

func (*MockMapMockRecorder) Equal 

func (mr *MockMapMockRecorder) Equal(value interface{}) *gomock.Call

Equal indicates an expected call of Equal

func (*MockMapMockRecorder) Get 

func (mr *MockMapMockRecorder) Get(arg0 interface{}) *gomock.Call

Get indicates an expected call of Get

func (*MockMapMockRecorder) IDs 

func (mr *MockMapMockRecorder) IDs() *gomock.Call

IDs indicates an expected call of IDs

func (*MockMapMockRecorder) Metadatas 

func (mr *MockMapMockRecorder) Metadatas() *gomock.Call

Metadatas indicates an expected call of Metadatas

type MockMetadata 

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

MockMetadata is a mock of Metadata interface

func NewMockMetadata 

func NewMockMetadata(ctrl *gomock.Controller) *MockMetadata

NewMockMetadata creates a new mock instance

func (*MockMetadata) EXPECT 

func (m *MockMetadata) EXPECT() *MockMetadataMockRecorder

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

func (*MockMetadata) Equal 

func (m *MockMetadata) Equal(value Metadata) bool

Equal mocks base method

func (*MockMetadata) ID 

func (m *MockMetadata) ID() ident.ID

ID mocks base method

func (*MockMetadata) Options 

func (m *MockMetadata) Options() Options

Options mocks base method

type MockMetadataMockRecorder 

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

MockMetadataMockRecorder is the mock recorder for MockMetadata

func (*MockMetadataMockRecorder) Equal 

func (mr *MockMetadataMockRecorder) Equal(value interface{}) *gomock.Call

Equal indicates an expected call of Equal

func (*MockMetadataMockRecorder) ID 

func (mr *MockMetadataMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID

func (*MockMetadataMockRecorder) Options 

func (mr *MockMetadataMockRecorder) Options() *gomock.Call

Options indicates an expected call of Options

type MockOptions 

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

MockOptions is a mock of Options interface

func NewMockOptions 

func NewMockOptions(ctrl *gomock.Controller) *MockOptions

NewMockOptions creates a new mock instance

func (*MockOptions) BootstrapEnabled 

func (m *MockOptions) BootstrapEnabled() bool

BootstrapEnabled mocks base method

func (*MockOptions) CleanupEnabled 

func (m *MockOptions) CleanupEnabled() bool

CleanupEnabled mocks base method

func (*MockOptions) ColdWritesEnabled 

func (m *MockOptions) ColdWritesEnabled() bool

ColdWritesEnabled mocks base method

func (*MockOptions) EXPECT 

func (m *MockOptions) EXPECT() *MockOptionsMockRecorder

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

func (*MockOptions) Equal 

func (m *MockOptions) Equal(value Options) bool

Equal mocks base method

func (*MockOptions) FlushEnabled 

func (m *MockOptions) FlushEnabled() bool

FlushEnabled mocks base method

func (*MockOptions) IndexOptions 

func (m *MockOptions) IndexOptions() IndexOptions

IndexOptions mocks base method

func (*MockOptions) RepairEnabled 

func (m *MockOptions) RepairEnabled() bool

RepairEnabled mocks base method

func (*MockOptions) RetentionOptions 

func (m *MockOptions) RetentionOptions() retention.Options

RetentionOptions mocks base method

func (*MockOptions) SchemaHistory 

func (m *MockOptions) SchemaHistory() SchemaHistory

SchemaHistory mocks base method

func (*MockOptions) SetBootstrapEnabled 

func (m *MockOptions) SetBootstrapEnabled(value bool) Options

SetBootstrapEnabled mocks base method

func (*MockOptions) SetCleanupEnabled 

func (m *MockOptions) SetCleanupEnabled(value bool) Options

SetCleanupEnabled mocks base method

func (*MockOptions) SetColdWritesEnabled 

func (m *MockOptions) SetColdWritesEnabled(value bool) Options

SetColdWritesEnabled mocks base method

func (*MockOptions) SetFlushEnabled 

func (m *MockOptions) SetFlushEnabled(value bool) Options

SetFlushEnabled mocks base method

func (*MockOptions) SetIndexOptions 

func (m *MockOptions) SetIndexOptions(value IndexOptions) Options

SetIndexOptions mocks base method

func (*MockOptions) SetRepairEnabled 

func (m *MockOptions) SetRepairEnabled(value bool) Options

SetRepairEnabled mocks base method

func (*MockOptions) SetRetentionOptions 

func (m *MockOptions) SetRetentionOptions(value retention.Options) Options

SetRetentionOptions mocks base method

func (*MockOptions) SetSchemaHistory 

func (m *MockOptions) SetSchemaHistory(value SchemaHistory) Options

SetSchemaHistory mocks base method

func (*MockOptions) SetSnapshotEnabled 

func (m *MockOptions) SetSnapshotEnabled(value bool) Options

SetSnapshotEnabled mocks base method

func (*MockOptions) SetWritesToCommitLog 

func (m *MockOptions) SetWritesToCommitLog(value bool) Options

SetWritesToCommitLog mocks base method

func (*MockOptions) SnapshotEnabled 

func (m *MockOptions) SnapshotEnabled() bool

SnapshotEnabled mocks base method

func (*MockOptions) Validate 

func (m *MockOptions) Validate() error

Validate mocks base method

func (*MockOptions) WritesToCommitLog 

func (m *MockOptions) WritesToCommitLog() bool

WritesToCommitLog mocks base method

type MockOptionsMockRecorder 

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

MockOptionsMockRecorder is the mock recorder for MockOptions

func (*MockOptionsMockRecorder) BootstrapEnabled 

func (mr *MockOptionsMockRecorder) BootstrapEnabled() *gomock.Call

BootstrapEnabled indicates an expected call of BootstrapEnabled

func (*MockOptionsMockRecorder) CleanupEnabled 

func (mr *MockOptionsMockRecorder) CleanupEnabled() *gomock.Call

CleanupEnabled indicates an expected call of CleanupEnabled

func (*MockOptionsMockRecorder) ColdWritesEnabled 

func (mr *MockOptionsMockRecorder) ColdWritesEnabled() *gomock.Call

ColdWritesEnabled indicates an expected call of ColdWritesEnabled

func (*MockOptionsMockRecorder) Equal 

func (mr *MockOptionsMockRecorder) Equal(value interface{}) *gomock.Call

Equal indicates an expected call of Equal

func (*MockOptionsMockRecorder) FlushEnabled 

func (mr *MockOptionsMockRecorder) FlushEnabled() *gomock.Call

FlushEnabled indicates an expected call of FlushEnabled

func (*MockOptionsMockRecorder) IndexOptions 

func (mr *MockOptionsMockRecorder) IndexOptions() *gomock.Call

IndexOptions indicates an expected call of IndexOptions

func (*MockOptionsMockRecorder) RepairEnabled 

func (mr *MockOptionsMockRecorder) RepairEnabled() *gomock.Call

RepairEnabled indicates an expected call of RepairEnabled

func (*MockOptionsMockRecorder) RetentionOptions 

func (mr *MockOptionsMockRecorder) RetentionOptions() *gomock.Call

RetentionOptions indicates an expected call of RetentionOptions

func (*MockOptionsMockRecorder) SchemaHistory 

func (mr *MockOptionsMockRecorder) SchemaHistory() *gomock.Call

SchemaHistory indicates an expected call of SchemaHistory

func (*MockOptionsMockRecorder) SetBootstrapEnabled 

func (mr *MockOptionsMockRecorder) SetBootstrapEnabled(value interface{}) *gomock.Call

SetBootstrapEnabled indicates an expected call of SetBootstrapEnabled

func (*MockOptionsMockRecorder) SetCleanupEnabled 

func (mr *MockOptionsMockRecorder) SetCleanupEnabled(value interface{}) *gomock.Call

SetCleanupEnabled indicates an expected call of SetCleanupEnabled

func (*MockOptionsMockRecorder) SetColdWritesEnabled 

func (mr *MockOptionsMockRecorder) SetColdWritesEnabled(value interface{}) *gomock.Call

SetColdWritesEnabled indicates an expected call of SetColdWritesEnabled

func (*MockOptionsMockRecorder) SetFlushEnabled 

func (mr *MockOptionsMockRecorder) SetFlushEnabled(value interface{}) *gomock.Call

SetFlushEnabled indicates an expected call of SetFlushEnabled

func (*MockOptionsMockRecorder) SetIndexOptions 

func (mr *MockOptionsMockRecorder) SetIndexOptions(value interface{}) *gomock.Call

SetIndexOptions indicates an expected call of SetIndexOptions

func (*MockOptionsMockRecorder) SetRepairEnabled 

func (mr *MockOptionsMockRecorder) SetRepairEnabled(value interface{}) *gomock.Call

SetRepairEnabled indicates an expected call of SetRepairEnabled

func (*MockOptionsMockRecorder) SetRetentionOptions 

func (mr *MockOptionsMockRecorder) SetRetentionOptions(value interface{}) *gomock.Call

SetRetentionOptions indicates an expected call of SetRetentionOptions

func (*MockOptionsMockRecorder) SetSchemaHistory 

func (mr *MockOptionsMockRecorder) SetSchemaHistory(value interface{}) *gomock.Call

SetSchemaHistory indicates an expected call of SetSchemaHistory

func (*MockOptionsMockRecorder) SetSnapshotEnabled 

func (mr *MockOptionsMockRecorder) SetSnapshotEnabled(value interface{}) *gomock.Call

SetSnapshotEnabled indicates an expected call of SetSnapshotEnabled

func (*MockOptionsMockRecorder) SetWritesToCommitLog 

func (mr *MockOptionsMockRecorder) SetWritesToCommitLog(value interface{}) *gomock.Call

SetWritesToCommitLog indicates an expected call of SetWritesToCommitLog

func (*MockOptionsMockRecorder) SnapshotEnabled 

func (mr *MockOptionsMockRecorder) SnapshotEnabled() *gomock.Call

SnapshotEnabled indicates an expected call of SnapshotEnabled

func (*MockOptionsMockRecorder) Validate 

func (mr *MockOptionsMockRecorder) Validate() *gomock.Call

Validate indicates an expected call of Validate

func (*MockOptionsMockRecorder) WritesToCommitLog 

func (mr *MockOptionsMockRecorder) WritesToCommitLog() *gomock.Call

WritesToCommitLog indicates an expected call of WritesToCommitLog

type MockRegistry 

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

MockRegistry is a mock of Registry interface

func NewMockRegistry 

func NewMockRegistry(ctrl *gomock.Controller) *MockRegistry

NewMockRegistry creates a new mock instance

func (*MockRegistry) Close 

func (m *MockRegistry) Close() error

Close mocks base method

func (*MockRegistry) EXPECT 

func (m *MockRegistry) EXPECT() *MockRegistryMockRecorder

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

func (*MockRegistry) Watch 

func (m *MockRegistry) Watch() (Watch, error)

Watch mocks base method

type MockRegistryMockRecorder 

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

MockRegistryMockRecorder is the mock recorder for MockRegistry

func (*MockRegistryMockRecorder) Close 

func (mr *MockRegistryMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockRegistryMockRecorder) Watch 

func (mr *MockRegistryMockRecorder) Watch() *gomock.Call

Watch indicates an expected call of Watch

type MockSchemaDescr 

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

MockSchemaDescr is a mock of SchemaDescr interface

func NewMockSchemaDescr 

func NewMockSchemaDescr(ctrl *gomock.Controller) *MockSchemaDescr

NewMockSchemaDescr creates a new mock instance

func (*MockSchemaDescr) DeployId 

func (m *MockSchemaDescr) DeployId() string

DeployId mocks base method

func (*MockSchemaDescr) EXPECT 

func (m *MockSchemaDescr) EXPECT() *MockSchemaDescrMockRecorder

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

func (*MockSchemaDescr) Equal 

func (m *MockSchemaDescr) Equal(arg0 SchemaDescr) bool

Equal mocks base method

func (*MockSchemaDescr) Get 

func (m *MockSchemaDescr) Get() MessageDescriptor

Get mocks base method

func (*MockSchemaDescr) PrevDeployId 

func (m *MockSchemaDescr) PrevDeployId() string

PrevDeployId mocks base method

func (*MockSchemaDescr) String 

func (m *MockSchemaDescr) String() string

String mocks base method

type MockSchemaDescrMockRecorder 

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

MockSchemaDescrMockRecorder is the mock recorder for MockSchemaDescr

func (*MockSchemaDescrMockRecorder) DeployId 

func (mr *MockSchemaDescrMockRecorder) DeployId() *gomock.Call

DeployId indicates an expected call of DeployId

func (*MockSchemaDescrMockRecorder) Equal 

func (mr *MockSchemaDescrMockRecorder) Equal(arg0 interface{}) *gomock.Call

Equal indicates an expected call of Equal

func (*MockSchemaDescrMockRecorder) Get 

func (mr *MockSchemaDescrMockRecorder) Get() *gomock.Call

Get indicates an expected call of Get

func (*MockSchemaDescrMockRecorder) PrevDeployId 

func (mr *MockSchemaDescrMockRecorder) PrevDeployId() *gomock.Call

PrevDeployId indicates an expected call of PrevDeployId

func (*MockSchemaDescrMockRecorder) String 

func (mr *MockSchemaDescrMockRecorder) String() *gomock.Call

String indicates an expected call of String

type MockSchemaHistory 

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

MockSchemaHistory is a mock of SchemaHistory interface

func NewMockSchemaHistory 

func NewMockSchemaHistory(ctrl *gomock.Controller) *MockSchemaHistory

NewMockSchemaHistory creates a new mock instance

func (*MockSchemaHistory) EXPECT 

func (m *MockSchemaHistory) EXPECT() *MockSchemaHistoryMockRecorder

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

func (*MockSchemaHistory) Equal 

func (m *MockSchemaHistory) Equal(arg0 SchemaHistory) bool

Equal mocks base method

func (*MockSchemaHistory) Extends 

func (m *MockSchemaHistory) Extends(arg0 SchemaHistory) bool

Extends mocks base method

func (*MockSchemaHistory) Get 

func (m *MockSchemaHistory) Get(id string) (SchemaDescr, bool)

Get mocks base method

func (*MockSchemaHistory) GetLatest 

func (m *MockSchemaHistory) GetLatest() (SchemaDescr, bool)

GetLatest mocks base method

type MockSchemaHistoryMockRecorder 

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

MockSchemaHistoryMockRecorder is the mock recorder for MockSchemaHistory

func (*MockSchemaHistoryMockRecorder) Equal 

func (mr *MockSchemaHistoryMockRecorder) Equal(arg0 interface{}) *gomock.Call

Equal indicates an expected call of Equal

func (*MockSchemaHistoryMockRecorder) Extends 

func (mr *MockSchemaHistoryMockRecorder) Extends(arg0 interface{}) *gomock.Call

Extends indicates an expected call of Extends

func (*MockSchemaHistoryMockRecorder) Get 

func (mr *MockSchemaHistoryMockRecorder) Get(id interface{}) *gomock.Call

Get indicates an expected call of Get

func (*MockSchemaHistoryMockRecorder) GetLatest 

func (mr *MockSchemaHistoryMockRecorder) GetLatest() *gomock.Call

GetLatest indicates an expected call of GetLatest

type MockSchemaListener 

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

MockSchemaListener is a mock of SchemaListener interface

func NewMockSchemaListener 

func NewMockSchemaListener(ctrl *gomock.Controller) *MockSchemaListener

NewMockSchemaListener creates a new mock instance

func (*MockSchemaListener) EXPECT 

func (m *MockSchemaListener) EXPECT() *MockSchemaListenerMockRecorder

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

func (*MockSchemaListener) SetSchema 

func (m *MockSchemaListener) SetSchema(value SchemaDescr)

SetSchema mocks base method

type MockSchemaListenerMockRecorder 

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

MockSchemaListenerMockRecorder is the mock recorder for MockSchemaListener

func (*MockSchemaListenerMockRecorder) SetSchema 

func (mr *MockSchemaListenerMockRecorder) SetSchema(value interface{}) *gomock.Call

SetSchema indicates an expected call of SetSchema

type MockSchemaRegistry 

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

MockSchemaRegistry is a mock of SchemaRegistry interface

func NewMockSchemaRegistry 

func NewMockSchemaRegistry(ctrl *gomock.Controller) *MockSchemaRegistry

NewMockSchemaRegistry creates a new mock instance

func (*MockSchemaRegistry) Close 

func (m *MockSchemaRegistry) Close()

Close mocks base method

func (*MockSchemaRegistry) EXPECT 

func (m *MockSchemaRegistry) EXPECT() *MockSchemaRegistryMockRecorder

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

func (*MockSchemaRegistry) GetLatestSchema 

func (m *MockSchemaRegistry) GetLatestSchema(id ident.ID) (SchemaDescr, error)

GetLatestSchema mocks base method

func (*MockSchemaRegistry) GetSchema 

func (m *MockSchemaRegistry) GetSchema(id ident.ID, schemaId string) (SchemaDescr, error)

GetSchema mocks base method

func (*MockSchemaRegistry) RegisterListener 

func (m *MockSchemaRegistry) RegisterListener(id ident.ID, listener SchemaListener) (close.SimpleCloser, error)

RegisterListener mocks base method

func (*MockSchemaRegistry) SetSchemaHistory 

func (m *MockSchemaRegistry) SetSchemaHistory(id ident.ID, history SchemaHistory) error

SetSchemaHistory mocks base method

type MockSchemaRegistryMockRecorder 

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

MockSchemaRegistryMockRecorder is the mock recorder for MockSchemaRegistry

func (*MockSchemaRegistryMockRecorder) Close 

func (mr *MockSchemaRegistryMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockSchemaRegistryMockRecorder) GetLatestSchema 

func (mr *MockSchemaRegistryMockRecorder) GetLatestSchema(id interface{}) *gomock.Call

GetLatestSchema indicates an expected call of GetLatestSchema

func (*MockSchemaRegistryMockRecorder) GetSchema 

func (mr *MockSchemaRegistryMockRecorder) GetSchema(id, schemaId interface{}) *gomock.Call

GetSchema indicates an expected call of GetSchema

func (*MockSchemaRegistryMockRecorder) RegisterListener 

func (mr *MockSchemaRegistryMockRecorder) RegisterListener(id, listener interface{}) *gomock.Call

RegisterListener indicates an expected call of RegisterListener

func (*MockSchemaRegistryMockRecorder) SetSchemaHistory 

func (mr *MockSchemaRegistryMockRecorder) SetSchemaHistory(id, history interface{}) *gomock.Call

SetSchemaHistory indicates an expected call of SetSchemaHistory

type MockWatch 

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

MockWatch is a mock of Watch interface

func NewMockWatch 

func NewMockWatch(ctrl *gomock.Controller) *MockWatch

NewMockWatch creates a new mock instance

func (*MockWatch) C 

func (m *MockWatch) C() <-chan struct{}

C mocks base method

func (*MockWatch) Close 

func (m *MockWatch) Close() error

Close mocks base method

func (*MockWatch) EXPECT 

func (m *MockWatch) EXPECT() *MockWatchMockRecorder

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

func (*MockWatch) Get 

func (m *MockWatch) Get() Map

Get mocks base method

type MockWatchMockRecorder 

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

MockWatchMockRecorder is the mock recorder for MockWatch

func (*MockWatchMockRecorder) C 

func (mr *MockWatchMockRecorder) C() *gomock.Call

C indicates an expected call of C

func (*MockWatchMockRecorder) Close 

func (mr *MockWatchMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockWatchMockRecorder) Get 

func (mr *MockWatchMockRecorder) Get() *gomock.Call

Get indicates an expected call of Get

type Options 

type Options interface {
	// Validate validates the options
	Validate() error

	// Equal returns true if the provide value is equal to this one
	Equal(value Options) bool

	// SetBootstrapEnabled sets whether this namespace requires bootstrapping
	SetBootstrapEnabled(value bool) Options

	// BootstrapEnabled returns whether this namespace requires bootstrapping
	BootstrapEnabled() bool

	// SetFlushEnabled sets whether the in-memory data for this namespace needs to be flushed
	SetFlushEnabled(value bool) Options

	// FlushEnabled returns whether the in-memory data for this namespace needs to be flushed
	FlushEnabled() bool

	// SetSnapshotEnabled sets whether the in-memory data for this namespace should be snapshotted regularly
	SetSnapshotEnabled(value bool) Options

	// SnapshotEnabled returns whether the in-memory data for this namespace should be snapshotted regularly
	SnapshotEnabled() bool

	// SetWritesToCommitLog sets whether writes for series in this namespace need to go to commit log
	SetWritesToCommitLog(value bool) Options

	// WritesToCommitLog returns whether writes for series in this namespace need to go to commit log
	WritesToCommitLog() bool

	// SetCleanupEnabled sets whether this namespace requires cleaning up fileset/snapshot files
	SetCleanupEnabled(value bool) Options

	// CleanupEnabled returns whether this namespace requires cleaning up fileset/snapshot files
	CleanupEnabled() bool

	// SetRepairEnabled sets whether the data for this namespace needs to be repaired
	SetRepairEnabled(value bool) Options

	// RepairEnabled returns whether the data for this namespace needs to be repaired
	RepairEnabled() bool

	// SetColdWritesEnabled sets whether cold writes are enabled for this namespace.
	SetColdWritesEnabled(value bool) Options

	// ColdWritesEnabled returns whether cold writes are enabled for this namespace.
	ColdWritesEnabled() bool

	// SetRetentionOptions sets the retention options for this namespace
	SetRetentionOptions(value retention.Options) Options

	// RetentionOptions returns the retention options for this namespace
	RetentionOptions() retention.Options

	// SetIndexOptions sets the IndexOptions.
	SetIndexOptions(value IndexOptions) Options

	// IndexOptions returns the IndexOptions.
	IndexOptions() IndexOptions

	// SetSchemaHistory sets the schema registry for this namespace.
	SetSchemaHistory(value SchemaHistory) Options

	// SchemaHistory returns the schema registry for this namespace.
	SchemaHistory() SchemaHistory
}

Options controls namespace behavior

func NewOptions 

func NewOptions() Options

NewOptions creates a new namespace options

type Registry 

type Registry interface {
	// Watch for the Registry changes
	Watch() (Watch, error)

	// Close closes the registry
	Close() error
}

Registry is an un-changing container for a Map

type SchemaDescr 

type SchemaDescr interface {
	// DeployId returns the deploy id of the schema.
	DeployId() string
	// PrevDeployId returns the previous deploy id of the schema.
	PrevDeployId() string
	// Get returns the message descriptor for the schema.
	Get() MessageDescriptor
	// String returns the compact text of the message descriptor.
	String() string
	// Equal returns true if the provided value is equal to this one.
	Equal(SchemaDescr) bool
}

SchemaDescr describes the schema for a complex type value.

func GetTestSchemaDescr 

func GetTestSchemaDescr(md *desc.MessageDescriptor) SchemaDescr

type SchemaHistory 

type SchemaHistory interface {
	// Equal returns true if the provided value is equal to this one.
	Equal(SchemaHistory) bool

	// Extends returns true iif the provided value has a lineage to this one.
	Extends(SchemaHistory) bool

	// Get gets the schema descriptor for the specified deploy id.
	Get(id string) (SchemaDescr, bool)

	// GetLatest gets the latest version of schema descriptor.
	GetLatest() (SchemaDescr, bool)
}

SchemaHistory represents schema history for a namespace.

func LoadSchemaHistory 

func LoadSchemaHistory(options *nsproto.SchemaOptions) (SchemaHistory, error)

LoadSchemaHistory loads schema registry from SchemaOptions proto.

func NewSchemaHistory 

func NewSchemaHistory() SchemaHistory

NewSchemaHistory returns an empty schema history.

type SchemaListener 

type SchemaListener interface {
	// SetSchema is called when the listener is registered
	// and when any updates occurred passing the new schema history.
	SetSchema(value SchemaDescr)
}

SchemaListener listens for updates to schema registry for a namespace.

type SchemaRegistry 

type SchemaRegistry interface {
	// GetLatestSchema gets the latest schema for the namespace.
	// If proto is not enabled, nil, nil is returned
	GetLatestSchema(id ident.ID) (SchemaDescr, error)

	// GetSchema gets the latest schema for the namespace.
	// If proto is not enabled, nil, nil is returned
	GetSchema(id ident.ID, schemaId string) (SchemaDescr, error)

	// SetSchemaHistory sets the schema history for the namespace.
	// If proto is not enabled, nil is returned
	SetSchemaHistory(id ident.ID, history SchemaHistory) error

	// RegisterListener registers a schema listener for the namespace.
	// If proto is not enabled, nil, nil is returned
	RegisterListener(id ident.ID, listener SchemaListener) (xclose.SimpleCloser, error)

	// Close closes all the listeners.
	Close()
}

SchemaRegistry represents the schema registry for a database. It is where dynamic schema updates are delivered into, and where schema is retrieved from at series read and write path.

func NewSchemaRegistry 

func NewSchemaRegistry(protoEnabled bool, logger *zap.Logger) SchemaRegistry

type Watch 

type Watch interface {
	// C is the notification channel for when a value becomes available
	C() <-chan struct{}

	// Get the current namespace map
	Get() Map

	// Close closes the watch
	Close() error
}

Watch is a watch on a namespace Map

func NewWatch 

func NewWatch(w xwatch.Watch) Watch

NewWatch creates a new watch on a topology map from a generic watch that watches a Map

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.