namespace

package
v0.10.0 Latest Latest
Warning

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

Go to latest
Published: Jun 8, 2019 License: Apache-2.0 Imports: 4 Imported by: 10

Documentation

Overview

Package namespace is a generated protocol buffer package.

It is generated from these files:

github.com/m3db/m3/src/dbnode/generated/proto/namespace/namespace.proto
github.com/m3db/m3/src/dbnode/generated/proto/namespace/schema.proto

It has these top-level messages:

RetentionOptions
IndexOptions
NamespaceOptions
Registry
SchemaOptions
SchemaHistory
FileDescriptorSet

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthNamespace = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowNamespace   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthSchema = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSchema   = fmt.Errorf("proto: integer overflow")
)

Functions

This section is empty.

Types

type FileDescriptorSet added in v0.8.2

type FileDescriptorSet struct {
	// id identifies a deployed version of FileDescriptorSet.
	DeployId string `protobuf:"bytes,1,opt,name=deployId,proto3" json:"deployId,omitempty"`
	// prevId identifies the previous deploy id of FileDescriptorSet.
	PrevId string `protobuf:"bytes,2,opt,name=prevId,proto3" json:"prevId,omitempty"`
	// descriptors is a list of proto file descriptors sorted by dependency in topological order.
	Descriptors [][]byte `protobuf:"bytes,3,rep,name=descriptors" json:"descriptors,omitempty"`
}

FileDescriptorSet is a set of proto file descriptors.

func (*FileDescriptorSet) Descriptor added in v0.8.2

func (*FileDescriptorSet) Descriptor() ([]byte, []int)

func (*FileDescriptorSet) GetDeployId added in v0.8.2

func (m *FileDescriptorSet) GetDeployId() string

func (*FileDescriptorSet) GetDescriptors added in v0.8.2

func (m *FileDescriptorSet) GetDescriptors() [][]byte

func (*FileDescriptorSet) GetPrevId added in v0.8.2

func (m *FileDescriptorSet) GetPrevId() string

func (*FileDescriptorSet) Marshal added in v0.8.2

func (m *FileDescriptorSet) Marshal() (dAtA []byte, err error)

func (*FileDescriptorSet) MarshalTo added in v0.8.2

func (m *FileDescriptorSet) MarshalTo(dAtA []byte) (int, error)

func (*FileDescriptorSet) ProtoMessage added in v0.8.2

func (*FileDescriptorSet) ProtoMessage()

func (*FileDescriptorSet) Reset added in v0.8.2

func (m *FileDescriptorSet) Reset()

func (*FileDescriptorSet) Size added in v0.8.2

func (m *FileDescriptorSet) Size() (n int)

func (*FileDescriptorSet) String added in v0.8.2

func (m *FileDescriptorSet) String() string

func (*FileDescriptorSet) Unmarshal added in v0.8.2

func (m *FileDescriptorSet) Unmarshal(dAtA []byte) error

type IndexOptions

type IndexOptions struct {
	Enabled        bool  `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	BlockSizeNanos int64 `protobuf:"varint,2,opt,name=blockSizeNanos,proto3" json:"blockSizeNanos,omitempty"`
}

func (*IndexOptions) Descriptor

func (*IndexOptions) Descriptor() ([]byte, []int)

func (*IndexOptions) GetBlockSizeNanos

func (m *IndexOptions) GetBlockSizeNanos() int64

func (*IndexOptions) GetEnabled

func (m *IndexOptions) GetEnabled() bool

func (*IndexOptions) Marshal

func (m *IndexOptions) Marshal() (dAtA []byte, err error)

func (*IndexOptions) MarshalTo

func (m *IndexOptions) MarshalTo(dAtA []byte) (int, error)

func (*IndexOptions) ProtoMessage

func (*IndexOptions) ProtoMessage()

func (*IndexOptions) Reset

func (m *IndexOptions) Reset()

func (*IndexOptions) Size

func (m *IndexOptions) Size() (n int)

func (*IndexOptions) String

func (m *IndexOptions) String() string

func (*IndexOptions) Unmarshal

func (m *IndexOptions) Unmarshal(dAtA []byte) error

type NamespaceOptions

type NamespaceOptions struct {
	BootstrapEnabled  bool              `protobuf:"varint,1,opt,name=bootstrapEnabled,proto3" json:"bootstrapEnabled,omitempty"`
	FlushEnabled      bool              `protobuf:"varint,2,opt,name=flushEnabled,proto3" json:"flushEnabled,omitempty"`
	WritesToCommitLog bool              `protobuf:"varint,3,opt,name=writesToCommitLog,proto3" json:"writesToCommitLog,omitempty"`
	CleanupEnabled    bool              `protobuf:"varint,4,opt,name=cleanupEnabled,proto3" json:"cleanupEnabled,omitempty"`
	RepairEnabled     bool              `protobuf:"varint,5,opt,name=repairEnabled,proto3" json:"repairEnabled,omitempty"`
	RetentionOptions  *RetentionOptions `protobuf:"bytes,6,opt,name=retentionOptions" json:"retentionOptions,omitempty"`
	SnapshotEnabled   bool              `protobuf:"varint,7,opt,name=snapshotEnabled,proto3" json:"snapshotEnabled,omitempty"`
	IndexOptions      *IndexOptions     `protobuf:"bytes,8,opt,name=indexOptions" json:"indexOptions,omitempty"`
	SchemaOptions     *SchemaOptions    `protobuf:"bytes,9,opt,name=schemaOptions" json:"schemaOptions,omitempty"`
	ColdWritesEnabled bool              `protobuf:"varint,10,opt,name=coldWritesEnabled,proto3" json:"coldWritesEnabled,omitempty"`
}

func (*NamespaceOptions) Descriptor

func (*NamespaceOptions) Descriptor() ([]byte, []int)

func (*NamespaceOptions) GetBootstrapEnabled

func (m *NamespaceOptions) GetBootstrapEnabled() bool

func (*NamespaceOptions) GetCleanupEnabled

func (m *NamespaceOptions) GetCleanupEnabled() bool

func (*NamespaceOptions) GetColdWritesEnabled added in v0.8.2

func (m *NamespaceOptions) GetColdWritesEnabled() bool

func (*NamespaceOptions) GetFlushEnabled

func (m *NamespaceOptions) GetFlushEnabled() bool

func (*NamespaceOptions) GetIndexOptions

func (m *NamespaceOptions) GetIndexOptions() *IndexOptions

func (*NamespaceOptions) GetRepairEnabled

func (m *NamespaceOptions) GetRepairEnabled() bool

func (*NamespaceOptions) GetRetentionOptions

func (m *NamespaceOptions) GetRetentionOptions() *RetentionOptions

func (*NamespaceOptions) GetSchemaOptions added in v0.8.2

func (m *NamespaceOptions) GetSchemaOptions() *SchemaOptions

func (*NamespaceOptions) GetSnapshotEnabled

func (m *NamespaceOptions) GetSnapshotEnabled() bool

func (*NamespaceOptions) GetWritesToCommitLog

func (m *NamespaceOptions) GetWritesToCommitLog() bool

func (*NamespaceOptions) Marshal

func (m *NamespaceOptions) Marshal() (dAtA []byte, err error)

func (*NamespaceOptions) MarshalTo

func (m *NamespaceOptions) MarshalTo(dAtA []byte) (int, error)

func (*NamespaceOptions) ProtoMessage

func (*NamespaceOptions) ProtoMessage()

func (*NamespaceOptions) Reset

func (m *NamespaceOptions) Reset()

func (*NamespaceOptions) Size

func (m *NamespaceOptions) Size() (n int)

func (*NamespaceOptions) String

func (m *NamespaceOptions) String() string

func (*NamespaceOptions) Unmarshal

func (m *NamespaceOptions) Unmarshal(dAtA []byte) error

type Registry

type Registry struct {
	Namespaces map[string]*NamespaceOptions `` /* 147-byte string literal not displayed */
}

func (*Registry) Descriptor

func (*Registry) Descriptor() ([]byte, []int)

func (*Registry) GetNamespaces

func (m *Registry) GetNamespaces() map[string]*NamespaceOptions

func (*Registry) Marshal

func (m *Registry) Marshal() (dAtA []byte, err error)

func (*Registry) MarshalTo

func (m *Registry) MarshalTo(dAtA []byte) (int, error)

func (*Registry) ProtoMessage

func (*Registry) ProtoMessage()

func (*Registry) Reset

func (m *Registry) Reset()

func (*Registry) Size

func (m *Registry) Size() (n int)

func (*Registry) String

func (m *Registry) String() string

func (*Registry) Unmarshal

func (m *Registry) Unmarshal(dAtA []byte) error

type RetentionOptions

type RetentionOptions struct {
	RetentionPeriodNanos                     int64 `protobuf:"varint,1,opt,name=retentionPeriodNanos,proto3" json:"retentionPeriodNanos,omitempty"`
	BlockSizeNanos                           int64 `protobuf:"varint,2,opt,name=blockSizeNanos,proto3" json:"blockSizeNanos,omitempty"`
	BufferFutureNanos                        int64 `protobuf:"varint,3,opt,name=bufferFutureNanos,proto3" json:"bufferFutureNanos,omitempty"`
	BufferPastNanos                          int64 `protobuf:"varint,4,opt,name=bufferPastNanos,proto3" json:"bufferPastNanos,omitempty"`
	BlockDataExpiry                          bool  `protobuf:"varint,5,opt,name=blockDataExpiry,proto3" json:"blockDataExpiry,omitempty"`
	BlockDataExpiryAfterNotAccessPeriodNanos int64 `` /* 134-byte string literal not displayed */
	FutureRetentionPeriodNanos               int64 `protobuf:"varint,7,opt,name=futureRetentionPeriodNanos,proto3" json:"futureRetentionPeriodNanos,omitempty"`
}

func (*RetentionOptions) Descriptor

func (*RetentionOptions) Descriptor() ([]byte, []int)

func (*RetentionOptions) GetBlockDataExpiry

func (m *RetentionOptions) GetBlockDataExpiry() bool

func (*RetentionOptions) GetBlockDataExpiryAfterNotAccessPeriodNanos

func (m *RetentionOptions) GetBlockDataExpiryAfterNotAccessPeriodNanos() int64

func (*RetentionOptions) GetBlockSizeNanos

func (m *RetentionOptions) GetBlockSizeNanos() int64

func (*RetentionOptions) GetBufferFutureNanos

func (m *RetentionOptions) GetBufferFutureNanos() int64

func (*RetentionOptions) GetBufferPastNanos

func (m *RetentionOptions) GetBufferPastNanos() int64

func (*RetentionOptions) GetFutureRetentionPeriodNanos added in v0.8.2

func (m *RetentionOptions) GetFutureRetentionPeriodNanos() int64

func (*RetentionOptions) GetRetentionPeriodNanos

func (m *RetentionOptions) GetRetentionPeriodNanos() int64

func (*RetentionOptions) Marshal

func (m *RetentionOptions) Marshal() (dAtA []byte, err error)

func (*RetentionOptions) MarshalTo

func (m *RetentionOptions) MarshalTo(dAtA []byte) (int, error)

func (*RetentionOptions) ProtoMessage

func (*RetentionOptions) ProtoMessage()

func (*RetentionOptions) Reset

func (m *RetentionOptions) Reset()

func (*RetentionOptions) Size

func (m *RetentionOptions) Size() (n int)

func (*RetentionOptions) String

func (m *RetentionOptions) String() string

func (*RetentionOptions) Unmarshal

func (m *RetentionOptions) Unmarshal(dAtA []byte) error

type SchemaHistory added in v0.8.2

type SchemaHistory struct {
	// versions is a list of FileDescriptorSet sorted by version in ascending order.
	// the list is a linked list and we use FileDescriptorSet.prevId to ensure the order is ascending.
	Versions []*FileDescriptorSet `protobuf:"bytes,1,rep,name=versions" json:"versions,omitempty"`
}

SchemaHistory is versioned FileDescriptorSet.

func (*SchemaHistory) Descriptor added in v0.8.2

func (*SchemaHistory) Descriptor() ([]byte, []int)

func (*SchemaHistory) GetVersions added in v0.8.2

func (m *SchemaHistory) GetVersions() []*FileDescriptorSet

func (*SchemaHistory) Marshal added in v0.8.2

func (m *SchemaHistory) Marshal() (dAtA []byte, err error)

func (*SchemaHistory) MarshalTo added in v0.8.2

func (m *SchemaHistory) MarshalTo(dAtA []byte) (int, error)

func (*SchemaHistory) ProtoMessage added in v0.8.2

func (*SchemaHistory) ProtoMessage()

func (*SchemaHistory) Reset added in v0.8.2

func (m *SchemaHistory) Reset()

func (*SchemaHistory) Size added in v0.8.2

func (m *SchemaHistory) Size() (n int)

func (*SchemaHistory) String added in v0.8.2

func (m *SchemaHistory) String() string

func (*SchemaHistory) Unmarshal added in v0.8.2

func (m *SchemaHistory) Unmarshal(dAtA []byte) error

type SchemaOptions added in v0.8.2

type SchemaOptions struct {
	// history contains a history of deployed schema definitions.
	History *SchemaHistory `protobuf:"bytes,1,opt,name=history" json:"history,omitempty"`
	// defaultMessageName identifies the proto message that contains the default schema for the namespace.
	DefaultMessageName string `protobuf:"bytes,2,opt,name=defaultMessageName,proto3" json:"defaultMessageName,omitempty"`
}

SchemaOptions contains schema information for a namespace.

func (*SchemaOptions) Descriptor added in v0.8.2

func (*SchemaOptions) Descriptor() ([]byte, []int)

func (*SchemaOptions) GetDefaultMessageName added in v0.8.2

func (m *SchemaOptions) GetDefaultMessageName() string

func (*SchemaOptions) GetHistory added in v0.8.2

func (m *SchemaOptions) GetHistory() *SchemaHistory

func (*SchemaOptions) Marshal added in v0.8.2

func (m *SchemaOptions) Marshal() (dAtA []byte, err error)

func (*SchemaOptions) MarshalTo added in v0.8.2

func (m *SchemaOptions) MarshalTo(dAtA []byte) (int, error)

func (*SchemaOptions) ProtoMessage added in v0.8.2

func (*SchemaOptions) ProtoMessage()

func (*SchemaOptions) Reset added in v0.8.2

func (m *SchemaOptions) Reset()

func (*SchemaOptions) Size added in v0.8.2

func (m *SchemaOptions) Size() (n int)

func (*SchemaOptions) String added in v0.8.2

func (m *SchemaOptions) String() string

func (*SchemaOptions) Unmarshal added in v0.8.2

func (m *SchemaOptions) Unmarshal(dAtA []byte) error

Jump to

Keyboard shortcuts

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