namespace

package
v1.5.0 Latest Latest
Warning

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

 Go to latest Published: Apr 7, 2022 License: Apache-2.0 Imports: 5 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
AggregationOptions
Aggregation
AggregatedAttributes
DownsampleOptions
StagingState
Registry
NamespaceRuntimeOptions
ExtendedOptions
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")
)
View Source 
var StagingStatus_name = map[int32]string{
	0: "UNKNOWN",
	1: "INITIALIZING",
	2: "READY",
}
View Source 
var StagingStatus_value = map[string]int32{
	"UNKNOWN":      0,
	"INITIALIZING": 1,
	"READY":        2,
}

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 ExtendedOptions added in v1.2.0 

type ExtendedOptions struct {
	Type    string                  `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Options *google_protobuf.Struct `protobuf:"bytes,2,opt,name=options" json:"options,omitempty"`
}

func (*ExtendedOptions) Descriptor added in v1.2.0 

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

func (*ExtendedOptions) GetOptions added in v1.2.0 

func (m *ExtendedOptions) GetOptions() *google_protobuf.Struct

func (*ExtendedOptions) GetType added in v1.2.0 

func (m *ExtendedOptions) GetType() string

func (*ExtendedOptions) Marshal added in v1.2.0 

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

func (*ExtendedOptions) MarshalTo added in v1.2.0 

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

func (*ExtendedOptions) ProtoMessage added in v1.2.0 

func (*ExtendedOptions) ProtoMessage()

func (*ExtendedOptions) Reset added in v1.2.0 

func (m *ExtendedOptions) Reset()

func (*ExtendedOptions) Size added in v1.2.0 

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

func (*ExtendedOptions) String added in v1.2.0 

func (m *ExtendedOptions) String() string

func (*ExtendedOptions) Unmarshal added in v1.2.0 

func (m *ExtendedOptions) 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) 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"`
	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"`
	StagingState          *StagingState               `protobuf:"bytes,14,opt,name=stagingState" json:"stagingState,omitempty"`
	// Use larger field ID to ensure new fields are always added before extended options.
	ExtendedOptions *ExtendedOptions `protobuf:"bytes,1000,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() *ExtendedOptions

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) GetStagingState added in v1.0.0 

func (m *NamespaceOptions) GetStagingState() *StagingState

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 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) 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

type StagingState added in v1.0.0 

type StagingState struct {
	Status StagingStatus `protobuf:"varint,1,opt,name=status,proto3,enum=namespace.StagingStatus" json:"status,omitempty"`
}

StagingState is state related to the namespace's availability for reads and writes.

func (*StagingState) Descriptor added in v1.0.0 

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

func (*StagingState) GetStatus added in v1.0.0 

func (m *StagingState) GetStatus() StagingStatus

func (*StagingState) Marshal added in v1.0.0 

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

func (*StagingState) MarshalTo added in v1.0.0 

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

func (*StagingState) ProtoMessage added in v1.0.0 

func (*StagingState) ProtoMessage()

func (*StagingState) Reset added in v1.0.0 

func (m *StagingState) Reset()

func (*StagingState) Size added in v1.0.0 

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

func (*StagingState) String added in v1.0.0 

func (m *StagingState) String() string

func (*StagingState) Unmarshal added in v1.0.0 

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

type StagingStatus added in v1.0.0 

type StagingStatus int32

StagingStatus represents the current status of the namespace. 

const (
	// Namespace has an unknown staging status.
	StagingStatus_UNKNOWN StagingStatus = 0
	// Namespace is being initialized and is not ready to receive traffic.
	StagingStatus_INITIALIZING StagingStatus = 1
	// Namespace is ready to receive traffic.
	StagingStatus_READY StagingStatus = 2
)

func (StagingStatus) EnumDescriptor added in v1.0.0 

func (StagingStatus) EnumDescriptor() ([]byte, []int)

func (StagingStatus) String added in v1.0.0 

func (x StagingStatus) String() string

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.