namespace

Apr 11, 2019

Changes in this version

+ func GenTestSchemaOptions(importPathPrefix string) *nsproto.SchemaOptions

+ type MessageDescriptor struct

type MetadataConfiguration

+ ColdWritesEnabled *bool

type MockOptions

+ func (m *MockOptions) ColdWritesEnabled() bool

+ func (m *MockOptions) SchemaRegistry() SchemaRegistry

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

+ func (m *MockOptions) SetSchemaRegistry(value SchemaRegistry) Options

type MockOptionsMockRecorder

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

+ func (mr *MockOptionsMockRecorder) SchemaRegistry() *gomock.Call

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

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

+ type MockSchemaDescr struct

+ func NewMockSchemaDescr(ctrl *gomock.Controller) *MockSchemaDescr

+ func (m *MockSchemaDescr) DeployId() string

+ func (m *MockSchemaDescr) EXPECT() *MockSchemaDescrMockRecorder

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

+ func (m *MockSchemaDescr) Get() MessageDescriptor

+ func (m *MockSchemaDescr) PrevDeployId() string

+ func (m *MockSchemaDescr) String() string

+ type MockSchemaDescrMockRecorder struct

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

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

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

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

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

+ type MockSchemaRegistry struct

+ func NewMockSchemaRegistry(ctrl *gomock.Controller) *MockSchemaRegistry

+ func (m *MockSchemaRegistry) EXPECT() *MockSchemaRegistryMockRecorder

+ func (m *MockSchemaRegistry) Equal(arg0 SchemaRegistry) bool

+ func (m *MockSchemaRegistry) Extends(arg0 SchemaRegistry) bool

+ func (m *MockSchemaRegistry) Get(id string) (SchemaDescr, bool)

+ func (m *MockSchemaRegistry) GetLatest() (SchemaDescr, bool)

+ type MockSchemaRegistryMockRecorder struct

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

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

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

+ func (mr *MockSchemaRegistryMockRecorder) GetLatest() *gomock.Call

type Options

+ ColdWritesEnabled func() bool

+ SchemaRegistry func() SchemaRegistry

+ SetColdWritesEnabled func(value bool) Options

+ SetSchemaRegistry func(value SchemaRegistry) Options

+ type SchemaDescr interface

+ DeployId func() string

+ Equal func(SchemaDescr) bool

+ Get func() MessageDescriptor

+ PrevDeployId func() string

+ String func() string

+ type SchemaRegistry interface

+ Equal func(SchemaRegistry) bool

+ Extends func(SchemaRegistry) bool

+ Get func(id string) (SchemaDescr, bool)

+ GetLatest func() (SchemaDescr, bool)

+ func LoadSchemaRegistry(options *nsproto.SchemaOptions) (SchemaRegistry, error)

Jul 16, 2018

Changes in this version

+ func OptionsToProto(opts Options) *nsproto.NamespaceOptions

May 24, 2018

Changes in this version

+ func ToProto(m Map) *nsproto.Registry

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

+ type DynamicOptions interface

+ ConfigServiceClient func() client.Client

+ InitTimeout func() time.Duration

+ InstrumentOptions func() instrument.Options

+ NamespaceRegistryKey func() string

+ SetConfigServiceClient func(c client.Client) DynamicOptions

+ SetInitTimeout func(value time.Duration) DynamicOptions

+ SetInstrumentOptions func(value instrument.Options) DynamicOptions

+ SetNamespaceRegistryKey func(k string) DynamicOptions

+ Validate func() error

+ func NewDynamicOptions() DynamicOptions

+ type IndexConfiguration struct

+ BlockSize time.Duration

+ Enabled bool

+ func (ic *IndexConfiguration) Options() IndexOptions

+ type IndexOptions interface

+ BlockSize func() time.Duration

+ Enabled func() bool

+ Equal func(value IndexOptions) bool

+ SetBlockSize func(value time.Duration) IndexOptions

+ SetEnabled func(value bool) IndexOptions

+ func NewIndexOptions() IndexOptions

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

+ type Initializer interface

+ Init func() (Registry, error)

+ func NewDynamicInitializer(opts DynamicOptions) Initializer

+ func NewStaticInitializer(metadatas []Metadata) Initializer

+ type Map interface

+ Equal func(value Map) bool

+ Get func(ident.ID) (Metadata, error)

+ IDs func() []ident.ID

+ Metadatas func() []Metadata

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

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

+ type MapConfiguration struct

+ Metadatas []MetadataConfiguration

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

+ type Metadata interface

+ Equal func(value Metadata) bool

+ ID func() ident.ID

+ Options func() Options

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

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

+ type MetadataConfiguration struct

+ BootstrapEnabled *bool

+ CleanupEnabled *bool

+ FlushEnabled *bool

+ ID string

+ Index IndexConfiguration

+ RepairEnabled *bool

+ Retention retention.Configuration

+ WritesToCommitLog *bool

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

+ type MetadataMatcher interface

+ func NewMetadataMatcher(md Metadata) MetadataMatcher

+ type MockDynamicOptions struct

+ func NewMockDynamicOptions(ctrl *gomock.Controller) *MockDynamicOptions

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

+ func (m *MockDynamicOptions) EXPECT() *MockDynamicOptionsMockRecorder

+ func (m *MockDynamicOptions) InitTimeout() time.Duration

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

+ func (m *MockDynamicOptions) NamespaceRegistryKey() string

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

+ func (m *MockDynamicOptions) SetInitTimeout(value time.Duration) DynamicOptions

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

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

+ func (m *MockDynamicOptions) Validate() error

+ type MockDynamicOptionsMockRecorder struct

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

+ func (mr *MockDynamicOptionsMockRecorder) InitTimeout() *gomock.Call

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

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

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

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

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

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

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

+ type MockIndexOptions struct

+ func NewMockIndexOptions(ctrl *gomock.Controller) *MockIndexOptions

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

+ func (m *MockIndexOptions) EXPECT() *MockIndexOptionsMockRecorder

+ func (m *MockIndexOptions) Enabled() bool

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

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

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

+ type MockIndexOptionsMockRecorder struct

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

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

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

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

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

+ type MockInitializer struct

+ func NewMockInitializer(ctrl *gomock.Controller) *MockInitializer

+ func (m *MockInitializer) EXPECT() *MockInitializerMockRecorder

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

+ type MockInitializerMockRecorder struct

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

+ type MockMap struct

+ func NewMockMap(ctrl *gomock.Controller) *MockMap

+ func (m *MockMap) EXPECT() *MockMapMockRecorder

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

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

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

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

+ type MockMapMockRecorder struct

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

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

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

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

+ type MockMetadata struct

+ func NewMockMetadata(ctrl *gomock.Controller) *MockMetadata

+ func (m *MockMetadata) EXPECT() *MockMetadataMockRecorder

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

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

+ func (m *MockMetadata) Options() Options

+ type MockMetadataMockRecorder struct

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

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

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

+ type MockOptions struct

+ func NewMockOptions(ctrl *gomock.Controller) *MockOptions

+ func (m *MockOptions) BootstrapEnabled() bool

+ func (m *MockOptions) CleanupEnabled() bool

+ func (m *MockOptions) EXPECT() *MockOptionsMockRecorder

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

+ func (m *MockOptions) FlushEnabled() bool

+ func (m *MockOptions) IndexOptions() IndexOptions

+ func (m *MockOptions) RepairEnabled() bool

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

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

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

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

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

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

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

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

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

+ func (m *MockOptions) SnapshotEnabled() bool

+ func (m *MockOptions) Validate() error

+ func (m *MockOptions) WritesToCommitLog() bool

+ type MockOptionsMockRecorder struct

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type MockRegistry struct

+ func NewMockRegistry(ctrl *gomock.Controller) *MockRegistry

+ func (m *MockRegistry) Close() error

+ func (m *MockRegistry) EXPECT() *MockRegistryMockRecorder

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

+ type MockRegistryMockRecorder struct

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

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

+ type MockWatch struct

+ func NewMockWatch(ctrl *gomock.Controller) *MockWatch

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

+ func (m *MockWatch) Close() error

+ func (m *MockWatch) EXPECT() *MockWatchMockRecorder

+ func (m *MockWatch) Get() Map

+ type MockWatchMockRecorder struct

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

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

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

+ type Options interface

+ BootstrapEnabled func() bool

+ CleanupEnabled func() bool

+ Equal func(value Options) bool

+ FlushEnabled func() bool

+ IndexOptions func() IndexOptions

+ RepairEnabled func() bool

+ RetentionOptions func() retention.Options

+ SetBootstrapEnabled func(value bool) Options

+ SetCleanupEnabled func(value bool) Options

+ SetFlushEnabled func(value bool) Options

+ SetIndexOptions func(value IndexOptions) Options

+ SetRepairEnabled func(value bool) Options

+ SetRetentionOptions func(value retention.Options) Options

+ SetSnapshotEnabled func(value bool) Options

+ SetWritesToCommitLog func(value bool) Options

+ SnapshotEnabled func() bool

+ Validate func() error

+ WritesToCommitLog func() bool

+ func NewOptions() Options

+ type Registry interface

+ Close func() error

+ Watch func() (Watch, error)

+ type Watch interface

+ C func() <-chan struct{}

+ Close func() error

+ Get func() Map

+ func NewWatch(w xwatch.Watch) Watch