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 AggregationOptions Aggregation AggregatedAttributes DownsampleOptions Registry NamespaceRuntimeOptions SchemaOptions SchemaHistory FileDescriptorSet
Index ¶
- Variables
- type AggregatedAttributes
- func (*AggregatedAttributes) Descriptor() ([]byte, []int)
- func (m *AggregatedAttributes) GetDownsampleOptions() *DownsampleOptions
- func (m *AggregatedAttributes) GetResolutionNanos() int64
- func (m *AggregatedAttributes) Marshal() (dAtA []byte, err error)
- func (m *AggregatedAttributes) MarshalTo(dAtA []byte) (int, error)
- func (*AggregatedAttributes) ProtoMessage()
- func (m *AggregatedAttributes) Reset()
- func (m *AggregatedAttributes) Size() (n int)
- func (m *AggregatedAttributes) String() string
- func (m *AggregatedAttributes) Unmarshal(dAtA []byte) error
- type Aggregation
- func (*Aggregation) Descriptor() ([]byte, []int)
- func (m *Aggregation) GetAggregated() bool
- func (m *Aggregation) GetAttributes() *AggregatedAttributes
- func (m *Aggregation) Marshal() (dAtA []byte, err error)
- func (m *Aggregation) MarshalTo(dAtA []byte) (int, error)
- func (*Aggregation) ProtoMessage()
- func (m *Aggregation) Reset()
- func (m *Aggregation) Size() (n int)
- func (m *Aggregation) String() string
- func (m *Aggregation) Unmarshal(dAtA []byte) error
- type AggregationOptions
- func (*AggregationOptions) Descriptor() ([]byte, []int)
- func (m *AggregationOptions) GetAggregations() []*Aggregation
- func (m *AggregationOptions) Marshal() (dAtA []byte, err error)
- func (m *AggregationOptions) MarshalTo(dAtA []byte) (int, error)
- func (*AggregationOptions) ProtoMessage()
- func (m *AggregationOptions) Reset()
- func (m *AggregationOptions) Size() (n int)
- func (m *AggregationOptions) String() string
- func (m *AggregationOptions) Unmarshal(dAtA []byte) error
- type DownsampleOptions
- func (*DownsampleOptions) Descriptor() ([]byte, []int)
- func (m *DownsampleOptions) GetAll() bool
- func (m *DownsampleOptions) Marshal() (dAtA []byte, err error)
- func (m *DownsampleOptions) MarshalTo(dAtA []byte) (int, error)
- func (*DownsampleOptions) ProtoMessage()
- func (m *DownsampleOptions) Reset()
- func (m *DownsampleOptions) Size() (n int)
- func (m *DownsampleOptions) String() string
- func (m *DownsampleOptions) Unmarshal(dAtA []byte) error
- type FileDescriptorSet
- func (*FileDescriptorSet) Descriptor() ([]byte, []int)
- func (m *FileDescriptorSet) GetDeployId() string
- func (m *FileDescriptorSet) GetDescriptors() [][]byte
- func (m *FileDescriptorSet) GetPrevId() string
- func (m *FileDescriptorSet) Marshal() (dAtA []byte, err error)
- func (m *FileDescriptorSet) MarshalTo(dAtA []byte) (int, error)
- func (*FileDescriptorSet) ProtoMessage()
- func (m *FileDescriptorSet) Reset()
- func (m *FileDescriptorSet) Size() (n int)
- func (m *FileDescriptorSet) String() string
- func (m *FileDescriptorSet) Unmarshal(dAtA []byte) error
- type IndexOptions
- func (*IndexOptions) Descriptor() ([]byte, []int)
- func (m *IndexOptions) GetBlockSizeNanos() int64
- func (m *IndexOptions) GetEnabled() bool
- func (m *IndexOptions) Marshal() (dAtA []byte, err error)
- func (m *IndexOptions) MarshalTo(dAtA []byte) (int, error)
- func (*IndexOptions) ProtoMessage()
- func (m *IndexOptions) Reset()
- func (m *IndexOptions) Size() (n int)
- func (m *IndexOptions) String() string
- func (m *IndexOptions) Unmarshal(dAtA []byte) error
- type NamespaceOptions
- func (*NamespaceOptions) Descriptor() ([]byte, []int)
- func (m *NamespaceOptions) GetAggregationOptions() *AggregationOptions
- func (m *NamespaceOptions) GetBootstrapEnabled() bool
- func (m *NamespaceOptions) GetCacheBlocksOnRetrieve() *google_protobuf1.BoolValue
- func (m *NamespaceOptions) GetCleanupEnabled() bool
- func (m *NamespaceOptions) GetColdWritesEnabled() bool
- func (m *NamespaceOptions) GetExtendedOptions() *google_protobuf.Any
- func (m *NamespaceOptions) GetFlushEnabled() bool
- func (m *NamespaceOptions) GetIndexOptions() *IndexOptions
- func (m *NamespaceOptions) GetRepairEnabled() bool
- func (m *NamespaceOptions) GetRetentionOptions() *RetentionOptions
- func (m *NamespaceOptions) GetRuntimeOptions() *NamespaceRuntimeOptions
- func (m *NamespaceOptions) GetSchemaOptions() *SchemaOptions
- func (m *NamespaceOptions) GetSnapshotEnabled() bool
- func (m *NamespaceOptions) GetWritesToCommitLog() bool
- func (m *NamespaceOptions) Marshal() (dAtA []byte, err error)
- func (m *NamespaceOptions) MarshalTo(dAtA []byte) (int, error)
- func (*NamespaceOptions) ProtoMessage()
- func (m *NamespaceOptions) Reset()
- func (m *NamespaceOptions) Size() (n int)
- func (m *NamespaceOptions) String() string
- func (m *NamespaceOptions) Unmarshal(dAtA []byte) error
- type NamespaceRuntimeOptions
- func (*NamespaceRuntimeOptions) Descriptor() ([]byte, []int)
- func (m *NamespaceRuntimeOptions) GetFlushIndexingPerCPUConcurrency() *google_protobuf1.DoubleValue
- func (m *NamespaceRuntimeOptions) GetWriteIndexingPerCPUConcurrency() *google_protobuf1.DoubleValue
- func (m *NamespaceRuntimeOptions) Marshal() (dAtA []byte, err error)
- func (m *NamespaceRuntimeOptions) MarshalTo(dAtA []byte) (int, error)
- func (*NamespaceRuntimeOptions) ProtoMessage()
- func (m *NamespaceRuntimeOptions) Reset()
- func (m *NamespaceRuntimeOptions) Size() (n int)
- func (m *NamespaceRuntimeOptions) String() string
- func (m *NamespaceRuntimeOptions) Unmarshal(dAtA []byte) error
- type Registry
- func (*Registry) Descriptor() ([]byte, []int)
- func (m *Registry) GetNamespaces() map[string]*NamespaceOptions
- func (m *Registry) Marshal() (dAtA []byte, err error)
- func (m *Registry) MarshalTo(dAtA []byte) (int, error)
- func (*Registry) ProtoMessage()
- func (m *Registry) Reset()
- func (m *Registry) Size() (n int)
- func (m *Registry) String() string
- func (m *Registry) Unmarshal(dAtA []byte) error
- type RetentionOptions
- func (*RetentionOptions) Descriptor() ([]byte, []int)
- func (m *RetentionOptions) GetBlockDataExpiry() bool
- func (m *RetentionOptions) GetBlockDataExpiryAfterNotAccessPeriodNanos() int64
- func (m *RetentionOptions) GetBlockSizeNanos() int64
- func (m *RetentionOptions) GetBufferFutureNanos() int64
- func (m *RetentionOptions) GetBufferPastNanos() int64
- func (m *RetentionOptions) GetFutureRetentionPeriodNanos() int64
- func (m *RetentionOptions) GetRetentionPeriodNanos() int64
- func (m *RetentionOptions) Marshal() (dAtA []byte, err error)
- func (m *RetentionOptions) MarshalTo(dAtA []byte) (int, error)
- func (*RetentionOptions) ProtoMessage()
- func (m *RetentionOptions) Reset()
- func (m *RetentionOptions) Size() (n int)
- func (m *RetentionOptions) String() string
- func (m *RetentionOptions) Unmarshal(dAtA []byte) error
- type SchemaHistory
- func (*SchemaHistory) Descriptor() ([]byte, []int)
- func (m *SchemaHistory) GetVersions() []*FileDescriptorSet
- func (m *SchemaHistory) Marshal() (dAtA []byte, err error)
- func (m *SchemaHistory) MarshalTo(dAtA []byte) (int, error)
- func (*SchemaHistory) ProtoMessage()
- func (m *SchemaHistory) Reset()
- func (m *SchemaHistory) Size() (n int)
- func (m *SchemaHistory) String() string
- func (m *SchemaHistory) Unmarshal(dAtA []byte) error
- type SchemaOptions
- func (*SchemaOptions) Descriptor() ([]byte, []int)
- func (m *SchemaOptions) GetDefaultMessageName() string
- func (m *SchemaOptions) GetHistory() *SchemaHistory
- func (m *SchemaOptions) Marshal() (dAtA []byte, err error)
- func (m *SchemaOptions) MarshalTo(dAtA []byte) (int, error)
- func (*SchemaOptions) ProtoMessage()
- func (m *SchemaOptions) Reset()
- func (m *SchemaOptions) Size() (n int)
- func (m *SchemaOptions) String() string
- func (m *SchemaOptions) Unmarshal(dAtA []byte) error
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 AggregatedAttributes ¶ added in v0.15.16
type AggregatedAttributes struct { // resolutionNanos is the time range to aggregate data across. ResolutionNanos int64 `protobuf:"varint,1,opt,name=resolutionNanos,proto3" json:"resolutionNanos,omitempty"` DownsampleOptions *DownsampleOptions `protobuf:"bytes,2,opt,name=downsampleOptions" json:"downsampleOptions,omitempty"` }
AggregatedAttributes describe how to aggregate data.
func (*AggregatedAttributes) Descriptor ¶ added in v0.15.16
func (*AggregatedAttributes) Descriptor() ([]byte, []int)
func (*AggregatedAttributes) GetDownsampleOptions ¶ added in v0.15.16
func (m *AggregatedAttributes) GetDownsampleOptions() *DownsampleOptions
func (*AggregatedAttributes) GetResolutionNanos ¶ added in v0.15.16
func (m *AggregatedAttributes) GetResolutionNanos() int64
func (*AggregatedAttributes) Marshal ¶ added in v0.15.16
func (m *AggregatedAttributes) Marshal() (dAtA []byte, err error)
func (*AggregatedAttributes) MarshalTo ¶ added in v0.15.16
func (m *AggregatedAttributes) MarshalTo(dAtA []byte) (int, error)
func (*AggregatedAttributes) ProtoMessage ¶ added in v0.15.16
func (*AggregatedAttributes) ProtoMessage()
func (*AggregatedAttributes) Reset ¶ added in v0.15.16
func (m *AggregatedAttributes) Reset()
func (*AggregatedAttributes) Size ¶ added in v0.15.16
func (m *AggregatedAttributes) Size() (n int)
func (*AggregatedAttributes) String ¶ added in v0.15.16
func (m *AggregatedAttributes) String() string
func (*AggregatedAttributes) Unmarshal ¶ added in v0.15.16
func (m *AggregatedAttributes) Unmarshal(dAtA []byte) error
type Aggregation ¶ added in v0.15.16
type Aggregation struct { // aggregated is true if data points are aggregated, false otherwise. Aggregated bool `protobuf:"varint,1,opt,name=aggregated,proto3" json:"aggregated,omitempty"` // attributes specifies how to aggregate data when aggregated is set to true. // This field is ignored when aggregated is false and required when aggregated // is true. Attributes *AggregatedAttributes `protobuf:"bytes,2,opt,name=attributes" json:"attributes,omitempty"` }
Aggregation describes data points within the namespace.
func (*Aggregation) Descriptor ¶ added in v0.15.16
func (*Aggregation) Descriptor() ([]byte, []int)
func (*Aggregation) GetAggregated ¶ added in v0.15.16
func (m *Aggregation) GetAggregated() bool
func (*Aggregation) GetAttributes ¶ added in v0.15.16
func (m *Aggregation) GetAttributes() *AggregatedAttributes
func (*Aggregation) Marshal ¶ added in v0.15.16
func (m *Aggregation) Marshal() (dAtA []byte, err error)
func (*Aggregation) MarshalTo ¶ added in v0.15.16
func (m *Aggregation) MarshalTo(dAtA []byte) (int, error)
func (*Aggregation) ProtoMessage ¶ added in v0.15.16
func (*Aggregation) ProtoMessage()
func (*Aggregation) Reset ¶ added in v0.15.16
func (m *Aggregation) Reset()
func (*Aggregation) Size ¶ added in v0.15.16
func (m *Aggregation) Size() (n int)
func (*Aggregation) String ¶ added in v0.15.16
func (m *Aggregation) String() string
func (*Aggregation) Unmarshal ¶ added in v0.15.16
func (m *Aggregation) Unmarshal(dAtA []byte) error
type AggregationOptions ¶ added in v0.15.16
type AggregationOptions struct { // aggregations is a repeated field to support the ability to send aggregated data // to a namespace also receiving unaggregated data. In this case, the namespace will // have one Aggregation with aggregated set to false and another with aggregated set to true. Aggregations []*Aggregation `protobuf:"bytes,1,rep,name=aggregations" json:"aggregations,omitempty"` }
AggregationOptions is a set of options for aggregating data within the namespace.
func (*AggregationOptions) Descriptor ¶ added in v0.15.16
func (*AggregationOptions) Descriptor() ([]byte, []int)
func (*AggregationOptions) GetAggregations ¶ added in v0.15.16
func (m *AggregationOptions) GetAggregations() []*Aggregation
func (*AggregationOptions) Marshal ¶ added in v0.15.16
func (m *AggregationOptions) Marshal() (dAtA []byte, err error)
func (*AggregationOptions) MarshalTo ¶ added in v0.15.16
func (m *AggregationOptions) MarshalTo(dAtA []byte) (int, error)
func (*AggregationOptions) ProtoMessage ¶ added in v0.15.16
func (*AggregationOptions) ProtoMessage()
func (*AggregationOptions) Reset ¶ added in v0.15.16
func (m *AggregationOptions) Reset()
func (*AggregationOptions) Size ¶ added in v0.15.16
func (m *AggregationOptions) Size() (n int)
func (*AggregationOptions) String ¶ added in v0.15.16
func (m *AggregationOptions) String() string
func (*AggregationOptions) Unmarshal ¶ added in v0.15.16
func (m *AggregationOptions) Unmarshal(dAtA []byte) error
type DownsampleOptions ¶ added in v0.15.16
type DownsampleOptions struct { // all indicates whether to send data points to this namespace. If false, // data points must be sent via rollup/recording rules. Defaults to true. All bool `protobuf:"varint,1,opt,name=all,proto3" json:"all,omitempty"` }
DownsampleOptions is a set of options related to downsampling data.
func (*DownsampleOptions) Descriptor ¶ added in v0.15.16
func (*DownsampleOptions) Descriptor() ([]byte, []int)
func (*DownsampleOptions) GetAll ¶ added in v0.15.16
func (m *DownsampleOptions) GetAll() bool
func (*DownsampleOptions) Marshal ¶ added in v0.15.16
func (m *DownsampleOptions) Marshal() (dAtA []byte, err error)
func (*DownsampleOptions) MarshalTo ¶ added in v0.15.16
func (m *DownsampleOptions) MarshalTo(dAtA []byte) (int, error)
func (*DownsampleOptions) ProtoMessage ¶ added in v0.15.16
func (*DownsampleOptions) ProtoMessage()
func (*DownsampleOptions) Reset ¶ added in v0.15.16
func (m *DownsampleOptions) Reset()
func (*DownsampleOptions) Size ¶ added in v0.15.16
func (m *DownsampleOptions) Size() (n int)
func (*DownsampleOptions) String ¶ added in v0.15.16
func (m *DownsampleOptions) String() string
func (*DownsampleOptions) Unmarshal ¶ added in v0.15.16
func (m *DownsampleOptions) Unmarshal(dAtA []byte) error
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) 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"` RuntimeOptions *NamespaceRuntimeOptions `protobuf:"bytes,11,opt,name=runtimeOptions" json:"runtimeOptions,omitempty"` CacheBlocksOnRetrieve *google_protobuf1.BoolValue `protobuf:"bytes,12,opt,name=cacheBlocksOnRetrieve" json:"cacheBlocksOnRetrieve,omitempty"` AggregationOptions *AggregationOptions `protobuf:"bytes,13,opt,name=aggregationOptions" json:"aggregationOptions,omitempty"` ExtendedOptions *google_protobuf.Any `protobuf:"bytes,14,opt,name=extendedOptions" json:"extendedOptions,omitempty"` }
func (*NamespaceOptions) Descriptor ¶
func (*NamespaceOptions) Descriptor() ([]byte, []int)
func (*NamespaceOptions) GetAggregationOptions ¶ added in v0.15.16
func (m *NamespaceOptions) GetAggregationOptions() *AggregationOptions
func (*NamespaceOptions) GetBootstrapEnabled ¶
func (m *NamespaceOptions) GetBootstrapEnabled() bool
func (*NamespaceOptions) GetCacheBlocksOnRetrieve ¶ added in v0.15.15
func (m *NamespaceOptions) GetCacheBlocksOnRetrieve() *google_protobuf1.BoolValue
func (*NamespaceOptions) GetCleanupEnabled ¶
func (m *NamespaceOptions) GetCleanupEnabled() bool
func (*NamespaceOptions) GetColdWritesEnabled ¶ added in v0.8.2
func (m *NamespaceOptions) GetColdWritesEnabled() bool
func (*NamespaceOptions) GetExtendedOptions ¶ added in v0.15.17
func (m *NamespaceOptions) GetExtendedOptions() *google_protobuf.Any
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) GetRuntimeOptions ¶ added in v0.15.6
func (m *NamespaceOptions) GetRuntimeOptions() *NamespaceRuntimeOptions
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) 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 NamespaceRuntimeOptions ¶ added in v0.15.6
type NamespaceRuntimeOptions struct { WriteIndexingPerCPUConcurrency *google_protobuf1.DoubleValue `protobuf:"bytes,1,opt,name=writeIndexingPerCPUConcurrency" json:"writeIndexingPerCPUConcurrency,omitempty"` FlushIndexingPerCPUConcurrency *google_protobuf1.DoubleValue `protobuf:"bytes,2,opt,name=flushIndexingPerCPUConcurrency" json:"flushIndexingPerCPUConcurrency,omitempty"` }
func (*NamespaceRuntimeOptions) Descriptor ¶ added in v0.15.6
func (*NamespaceRuntimeOptions) Descriptor() ([]byte, []int)
func (*NamespaceRuntimeOptions) GetFlushIndexingPerCPUConcurrency ¶ added in v0.15.6
func (m *NamespaceRuntimeOptions) GetFlushIndexingPerCPUConcurrency() *google_protobuf1.DoubleValue
func (*NamespaceRuntimeOptions) GetWriteIndexingPerCPUConcurrency ¶ added in v0.15.6
func (m *NamespaceRuntimeOptions) GetWriteIndexingPerCPUConcurrency() *google_protobuf1.DoubleValue
func (*NamespaceRuntimeOptions) Marshal ¶ added in v0.15.6
func (m *NamespaceRuntimeOptions) Marshal() (dAtA []byte, err error)
func (*NamespaceRuntimeOptions) MarshalTo ¶ added in v0.15.6
func (m *NamespaceRuntimeOptions) MarshalTo(dAtA []byte) (int, error)
func (*NamespaceRuntimeOptions) ProtoMessage ¶ added in v0.15.6
func (*NamespaceRuntimeOptions) ProtoMessage()
func (*NamespaceRuntimeOptions) Reset ¶ added in v0.15.6
func (m *NamespaceRuntimeOptions) Reset()
func (*NamespaceRuntimeOptions) Size ¶ added in v0.15.6
func (m *NamespaceRuntimeOptions) Size() (n int)
func (*NamespaceRuntimeOptions) String ¶ added in v0.15.6
func (m *NamespaceRuntimeOptions) String() string
func (*NamespaceRuntimeOptions) Unmarshal ¶ added in v0.15.6
func (m *NamespaceRuntimeOptions) Unmarshal(dAtA []byte) error
type Registry ¶
type Registry struct {
Namespaces map[string]*NamespaceOptions `` /* 147-byte string literal not displayed */
}
func (*Registry) Descriptor ¶
func (*Registry) GetNamespaces ¶
func (m *Registry) GetNamespaces() map[string]*NamespaceOptions
func (*Registry) ProtoMessage ¶
func (*Registry) ProtoMessage()
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) 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
Click to show internal directories.
Click to hide internal directories.