namespace

package
v0.14.2 Latest Latest
Warning

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

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

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

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.