Documentation
¶
Overview ¶
Package admin is a generated protocol buffer package.
It is generated from these files:
github.com/m3db/m3/src/query/generated/proto/admin/database.proto github.com/m3db/m3/src/query/generated/proto/admin/namespace.proto github.com/m3db/m3/src/query/generated/proto/admin/placement.proto github.com/m3db/m3/src/query/generated/proto/admin/topic.proto
It has these top-level messages:
DatabaseCreateRequest AggregatedNamespace BlockSize Host DatabaseCreateResponse NamespaceGetResponse NamespaceAddRequest NamespaceUpdateRequest NamespaceSchemaAddRequest NamespaceSchemaAddResponse NamespaceSchemaResetRequest NamespaceSchemaResetResponse NamespaceReadyRequest NamespaceReadyResponse PlacementInitRequest PlacementGetResponse PlacementAddRequest PlacementReplaceRequest PlacementSetRequest PlacementSetResponse TopicGetResponse TopicInitRequest TopicAddRequest TopicUpdateRequest
Index ¶
- Variables
- type AggregatedNamespace
- func (*AggregatedNamespace) Descriptor() ([]byte, []int)
- func (m *AggregatedNamespace) GetName() string
- func (m *AggregatedNamespace) GetResolution() string
- func (m *AggregatedNamespace) GetRetentionTime() string
- func (m *AggregatedNamespace) Marshal() (dAtA []byte, err error)
- func (m *AggregatedNamespace) MarshalTo(dAtA []byte) (int, error)
- func (*AggregatedNamespace) ProtoMessage()
- func (m *AggregatedNamespace) Reset()
- func (m *AggregatedNamespace) Size() (n int)
- func (m *AggregatedNamespace) String() string
- func (m *AggregatedNamespace) Unmarshal(dAtA []byte) error
- type BlockSize
- func (*BlockSize) Descriptor() ([]byte, []int)
- func (m *BlockSize) GetExpectedSeriesDatapointsPerHour() int64
- func (m *BlockSize) GetTime() string
- func (m *BlockSize) Marshal() (dAtA []byte, err error)
- func (m *BlockSize) MarshalTo(dAtA []byte) (int, error)
- func (*BlockSize) ProtoMessage()
- func (m *BlockSize) Reset()
- func (m *BlockSize) Size() (n int)
- func (m *BlockSize) String() string
- func (m *BlockSize) Unmarshal(dAtA []byte) error
- type DatabaseCreateRequest
- func (*DatabaseCreateRequest) Descriptor() ([]byte, []int)
- func (m *DatabaseCreateRequest) GetAggregatedNamespace() *AggregatedNamespace
- func (m *DatabaseCreateRequest) GetBlockSize() *BlockSize
- func (m *DatabaseCreateRequest) GetHosts() []*Host
- func (m *DatabaseCreateRequest) GetNamespaceName() string
- func (m *DatabaseCreateRequest) GetNumShards() int32
- func (m *DatabaseCreateRequest) GetReplicationFactor() int32
- func (m *DatabaseCreateRequest) GetRetentionTime() string
- func (m *DatabaseCreateRequest) GetType() string
- func (m *DatabaseCreateRequest) Marshal() (dAtA []byte, err error)
- func (m *DatabaseCreateRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DatabaseCreateRequest) ProtoMessage()
- func (m *DatabaseCreateRequest) Reset()
- func (m *DatabaseCreateRequest) Size() (n int)
- func (m *DatabaseCreateRequest) String() string
- func (m *DatabaseCreateRequest) Unmarshal(dAtA []byte) error
- type DatabaseCreateResponse
- func (*DatabaseCreateResponse) Descriptor() ([]byte, []int)
- func (m *DatabaseCreateResponse) GetNamespace() *NamespaceGetResponse
- func (m *DatabaseCreateResponse) GetPlacement() *PlacementGetResponse
- func (m *DatabaseCreateResponse) Marshal() (dAtA []byte, err error)
- func (m *DatabaseCreateResponse) MarshalTo(dAtA []byte) (int, error)
- func (*DatabaseCreateResponse) ProtoMessage()
- func (m *DatabaseCreateResponse) Reset()
- func (m *DatabaseCreateResponse) Size() (n int)
- func (m *DatabaseCreateResponse) String() string
- func (m *DatabaseCreateResponse) Unmarshal(dAtA []byte) error
- type Host
- func (*Host) Descriptor() ([]byte, []int)
- func (m *Host) GetAddress() string
- func (m *Host) GetId() string
- func (m *Host) GetIsolationGroup() string
- func (m *Host) GetPort() uint32
- func (m *Host) GetWeight() uint32
- func (m *Host) GetZone() string
- func (m *Host) Marshal() (dAtA []byte, err error)
- func (m *Host) MarshalTo(dAtA []byte) (int, error)
- func (*Host) ProtoMessage()
- func (m *Host) Reset()
- func (m *Host) Size() (n int)
- func (m *Host) String() string
- func (m *Host) Unmarshal(dAtA []byte) error
- type NamespaceAddRequest
- func (*NamespaceAddRequest) Descriptor() ([]byte, []int)
- func (m *NamespaceAddRequest) GetName() string
- func (m *NamespaceAddRequest) GetOptions() *namespace1.NamespaceOptions
- func (m *NamespaceAddRequest) Marshal() (dAtA []byte, err error)
- func (m *NamespaceAddRequest) MarshalTo(dAtA []byte) (int, error)
- func (*NamespaceAddRequest) ProtoMessage()
- func (m *NamespaceAddRequest) Reset()
- func (m *NamespaceAddRequest) Size() (n int)
- func (m *NamespaceAddRequest) String() string
- func (m *NamespaceAddRequest) Unmarshal(dAtA []byte) error
- type NamespaceGetResponse
- func (*NamespaceGetResponse) Descriptor() ([]byte, []int)
- func (m *NamespaceGetResponse) GetRegistry() *namespace1.Registry
- func (m *NamespaceGetResponse) Marshal() (dAtA []byte, err error)
- func (m *NamespaceGetResponse) MarshalTo(dAtA []byte) (int, error)
- func (*NamespaceGetResponse) ProtoMessage()
- func (m *NamespaceGetResponse) Reset()
- func (m *NamespaceGetResponse) Size() (n int)
- func (m *NamespaceGetResponse) String() string
- func (m *NamespaceGetResponse) Unmarshal(dAtA []byte) error
- type NamespaceReadyRequest
- func (*NamespaceReadyRequest) Descriptor() ([]byte, []int)
- func (m *NamespaceReadyRequest) GetForce() bool
- func (m *NamespaceReadyRequest) GetName() string
- func (m *NamespaceReadyRequest) Marshal() (dAtA []byte, err error)
- func (m *NamespaceReadyRequest) MarshalTo(dAtA []byte) (int, error)
- func (*NamespaceReadyRequest) ProtoMessage()
- func (m *NamespaceReadyRequest) Reset()
- func (m *NamespaceReadyRequest) Size() (n int)
- func (m *NamespaceReadyRequest) String() string
- func (m *NamespaceReadyRequest) Unmarshal(dAtA []byte) error
- type NamespaceReadyResponse
- func (*NamespaceReadyResponse) Descriptor() ([]byte, []int)
- func (m *NamespaceReadyResponse) GetReady() bool
- func (m *NamespaceReadyResponse) Marshal() (dAtA []byte, err error)
- func (m *NamespaceReadyResponse) MarshalTo(dAtA []byte) (int, error)
- func (*NamespaceReadyResponse) ProtoMessage()
- func (m *NamespaceReadyResponse) Reset()
- func (m *NamespaceReadyResponse) Size() (n int)
- func (m *NamespaceReadyResponse) String() string
- func (m *NamespaceReadyResponse) Unmarshal(dAtA []byte) error
- type NamespaceSchemaAddRequest
- func (*NamespaceSchemaAddRequest) Descriptor() ([]byte, []int)
- func (m *NamespaceSchemaAddRequest) GetMsgName() string
- func (m *NamespaceSchemaAddRequest) GetName() string
- func (m *NamespaceSchemaAddRequest) GetProtoMap() map[string]string
- func (m *NamespaceSchemaAddRequest) GetProtoName() string
- func (m *NamespaceSchemaAddRequest) Marshal() (dAtA []byte, err error)
- func (m *NamespaceSchemaAddRequest) MarshalTo(dAtA []byte) (int, error)
- func (*NamespaceSchemaAddRequest) ProtoMessage()
- func (m *NamespaceSchemaAddRequest) Reset()
- func (m *NamespaceSchemaAddRequest) Size() (n int)
- func (m *NamespaceSchemaAddRequest) String() string
- func (m *NamespaceSchemaAddRequest) Unmarshal(dAtA []byte) error
- type NamespaceSchemaAddResponse
- func (*NamespaceSchemaAddResponse) Descriptor() ([]byte, []int)
- func (m *NamespaceSchemaAddResponse) GetDeployID() string
- func (m *NamespaceSchemaAddResponse) Marshal() (dAtA []byte, err error)
- func (m *NamespaceSchemaAddResponse) MarshalTo(dAtA []byte) (int, error)
- func (*NamespaceSchemaAddResponse) ProtoMessage()
- func (m *NamespaceSchemaAddResponse) Reset()
- func (m *NamespaceSchemaAddResponse) Size() (n int)
- func (m *NamespaceSchemaAddResponse) String() string
- func (m *NamespaceSchemaAddResponse) Unmarshal(dAtA []byte) error
- type NamespaceSchemaResetRequest
- func (*NamespaceSchemaResetRequest) Descriptor() ([]byte, []int)
- func (m *NamespaceSchemaResetRequest) GetName() string
- func (m *NamespaceSchemaResetRequest) Marshal() (dAtA []byte, err error)
- func (m *NamespaceSchemaResetRequest) MarshalTo(dAtA []byte) (int, error)
- func (*NamespaceSchemaResetRequest) ProtoMessage()
- func (m *NamespaceSchemaResetRequest) Reset()
- func (m *NamespaceSchemaResetRequest) Size() (n int)
- func (m *NamespaceSchemaResetRequest) String() string
- func (m *NamespaceSchemaResetRequest) Unmarshal(dAtA []byte) error
- type NamespaceSchemaResetResponse
- func (*NamespaceSchemaResetResponse) Descriptor() ([]byte, []int)
- func (m *NamespaceSchemaResetResponse) Marshal() (dAtA []byte, err error)
- func (m *NamespaceSchemaResetResponse) MarshalTo(dAtA []byte) (int, error)
- func (*NamespaceSchemaResetResponse) ProtoMessage()
- func (m *NamespaceSchemaResetResponse) Reset()
- func (m *NamespaceSchemaResetResponse) Size() (n int)
- func (m *NamespaceSchemaResetResponse) String() string
- func (m *NamespaceSchemaResetResponse) Unmarshal(dAtA []byte) error
- type NamespaceUpdateRequest
- func (*NamespaceUpdateRequest) Descriptor() ([]byte, []int)
- func (m *NamespaceUpdateRequest) GetName() string
- func (m *NamespaceUpdateRequest) GetOptions() *namespace1.NamespaceOptions
- func (m *NamespaceUpdateRequest) Marshal() (dAtA []byte, err error)
- func (m *NamespaceUpdateRequest) MarshalTo(dAtA []byte) (int, error)
- func (*NamespaceUpdateRequest) ProtoMessage()
- func (m *NamespaceUpdateRequest) Reset()
- func (m *NamespaceUpdateRequest) Size() (n int)
- func (m *NamespaceUpdateRequest) String() string
- func (m *NamespaceUpdateRequest) Unmarshal(dAtA []byte) error
- type PlacementAddRequest
- func (*PlacementAddRequest) Descriptor() ([]byte, []int)
- func (m *PlacementAddRequest) GetForce() bool
- func (m *PlacementAddRequest) GetInstances() []*placementpb.Instance
- func (m *PlacementAddRequest) Marshal() (dAtA []byte, err error)
- func (m *PlacementAddRequest) MarshalTo(dAtA []byte) (int, error)
- func (*PlacementAddRequest) ProtoMessage()
- func (m *PlacementAddRequest) Reset()
- func (m *PlacementAddRequest) Size() (n int)
- func (m *PlacementAddRequest) String() string
- func (m *PlacementAddRequest) Unmarshal(dAtA []byte) error
- type PlacementGetResponse
- func (*PlacementGetResponse) Descriptor() ([]byte, []int)
- func (m *PlacementGetResponse) GetPlacement() *placementpb.Placement
- func (m *PlacementGetResponse) GetVersion() int32
- func (m *PlacementGetResponse) Marshal() (dAtA []byte, err error)
- func (m *PlacementGetResponse) MarshalTo(dAtA []byte) (int, error)
- func (*PlacementGetResponse) ProtoMessage()
- func (m *PlacementGetResponse) Reset()
- func (m *PlacementGetResponse) Size() (n int)
- func (m *PlacementGetResponse) String() string
- func (m *PlacementGetResponse) Unmarshal(dAtA []byte) error
- type PlacementInitRequest
- func (*PlacementInitRequest) Descriptor() ([]byte, []int)
- func (m *PlacementInitRequest) GetInstances() []*placementpb.Instance
- func (m *PlacementInitRequest) GetNumShards() int32
- func (m *PlacementInitRequest) GetReplicationFactor() int32
- func (m *PlacementInitRequest) Marshal() (dAtA []byte, err error)
- func (m *PlacementInitRequest) MarshalTo(dAtA []byte) (int, error)
- func (*PlacementInitRequest) ProtoMessage()
- func (m *PlacementInitRequest) Reset()
- func (m *PlacementInitRequest) Size() (n int)
- func (m *PlacementInitRequest) String() string
- func (m *PlacementInitRequest) Unmarshal(dAtA []byte) error
- type PlacementReplaceRequest
- func (*PlacementReplaceRequest) Descriptor() ([]byte, []int)
- func (m *PlacementReplaceRequest) GetCandidates() []*placementpb.Instance
- func (m *PlacementReplaceRequest) GetForce() bool
- func (m *PlacementReplaceRequest) GetLeavingInstanceIDs() []string
- func (m *PlacementReplaceRequest) Marshal() (dAtA []byte, err error)
- func (m *PlacementReplaceRequest) MarshalTo(dAtA []byte) (int, error)
- func (*PlacementReplaceRequest) ProtoMessage()
- func (m *PlacementReplaceRequest) Reset()
- func (m *PlacementReplaceRequest) Size() (n int)
- func (m *PlacementReplaceRequest) String() string
- func (m *PlacementReplaceRequest) Unmarshal(dAtA []byte) error
- type PlacementSetRequest
- func (*PlacementSetRequest) Descriptor() ([]byte, []int)
- func (m *PlacementSetRequest) GetConfirm() bool
- func (m *PlacementSetRequest) GetPlacement() *placementpb.Placement
- func (m *PlacementSetRequest) GetVersion() int32
- func (m *PlacementSetRequest) Marshal() (dAtA []byte, err error)
- func (m *PlacementSetRequest) MarshalTo(dAtA []byte) (int, error)
- func (*PlacementSetRequest) ProtoMessage()
- func (m *PlacementSetRequest) Reset()
- func (m *PlacementSetRequest) Size() (n int)
- func (m *PlacementSetRequest) String() string
- func (m *PlacementSetRequest) Unmarshal(dAtA []byte) error
- type PlacementSetResponse
- func (*PlacementSetResponse) Descriptor() ([]byte, []int)
- func (m *PlacementSetResponse) GetDryRun() bool
- func (m *PlacementSetResponse) GetPlacement() *placementpb.Placement
- func (m *PlacementSetResponse) GetVersion() int32
- func (m *PlacementSetResponse) Marshal() (dAtA []byte, err error)
- func (m *PlacementSetResponse) MarshalTo(dAtA []byte) (int, error)
- func (*PlacementSetResponse) ProtoMessage()
- func (m *PlacementSetResponse) Reset()
- func (m *PlacementSetResponse) Size() (n int)
- func (m *PlacementSetResponse) String() string
- func (m *PlacementSetResponse) Unmarshal(dAtA []byte) error
- type TopicAddRequest
- func (*TopicAddRequest) Descriptor() ([]byte, []int)
- func (m *TopicAddRequest) GetConsumerService() *topicpb.ConsumerService
- func (m *TopicAddRequest) Marshal() (dAtA []byte, err error)
- func (m *TopicAddRequest) MarshalTo(dAtA []byte) (int, error)
- func (*TopicAddRequest) ProtoMessage()
- func (m *TopicAddRequest) Reset()
- func (m *TopicAddRequest) Size() (n int)
- func (m *TopicAddRequest) String() string
- func (m *TopicAddRequest) Unmarshal(dAtA []byte) error
- type TopicGetResponse
- func (*TopicGetResponse) Descriptor() ([]byte, []int)
- func (m *TopicGetResponse) GetTopic() *topicpb.Topic
- func (m *TopicGetResponse) GetVersion() uint32
- func (m *TopicGetResponse) Marshal() (dAtA []byte, err error)
- func (m *TopicGetResponse) MarshalTo(dAtA []byte) (int, error)
- func (*TopicGetResponse) ProtoMessage()
- func (m *TopicGetResponse) Reset()
- func (m *TopicGetResponse) Size() (n int)
- func (m *TopicGetResponse) String() string
- func (m *TopicGetResponse) Unmarshal(dAtA []byte) error
- type TopicInitRequest
- func (*TopicInitRequest) Descriptor() ([]byte, []int)
- func (m *TopicInitRequest) GetNumberOfShards() uint32
- func (m *TopicInitRequest) Marshal() (dAtA []byte, err error)
- func (m *TopicInitRequest) MarshalTo(dAtA []byte) (int, error)
- func (*TopicInitRequest) ProtoMessage()
- func (m *TopicInitRequest) Reset()
- func (m *TopicInitRequest) Size() (n int)
- func (m *TopicInitRequest) String() string
- func (m *TopicInitRequest) Unmarshal(dAtA []byte) error
- type TopicUpdateRequest
- func (*TopicUpdateRequest) Descriptor() ([]byte, []int)
- func (m *TopicUpdateRequest) GetConsumerServices() []*topicpb.ConsumerService
- func (m *TopicUpdateRequest) GetVersion() uint32
- func (m *TopicUpdateRequest) Marshal() (dAtA []byte, err error)
- func (m *TopicUpdateRequest) MarshalTo(dAtA []byte) (int, error)
- func (*TopicUpdateRequest) ProtoMessage()
- func (m *TopicUpdateRequest) Reset()
- func (m *TopicUpdateRequest) Size() (n int)
- func (m *TopicUpdateRequest) String() string
- func (m *TopicUpdateRequest) Unmarshal(dAtA []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthDatabase = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowDatabase = fmt.Errorf("proto: integer overflow") )
View Source
var ( ErrInvalidLengthNamespace = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowNamespace = fmt.Errorf("proto: integer overflow") )
View Source
var ( ErrInvalidLengthPlacement = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPlacement = fmt.Errorf("proto: integer overflow") )
View Source
var ( ErrInvalidLengthTopic = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTopic = fmt.Errorf("proto: integer overflow") )
Functions ¶
This section is empty.
Types ¶
type AggregatedNamespace ¶ added in v0.15.16
type AggregatedNamespace struct { // Required fields. // Namespace name. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Time window to aggregate data points across. // Uses same shorthand as retention_time. Resolution string `protobuf:"bytes,2,opt,name=resolution,proto3" json:"resolution,omitempty"` // Length of time to retain data. RetentionTime string `protobuf:"bytes,3,opt,name=retention_time,json=retentionTime,proto3" json:"retention_time,omitempty"` }
func (*AggregatedNamespace) Descriptor ¶ added in v0.15.16
func (*AggregatedNamespace) Descriptor() ([]byte, []int)
func (*AggregatedNamespace) GetName ¶ added in v0.15.16
func (m *AggregatedNamespace) GetName() string
func (*AggregatedNamespace) GetResolution ¶ added in v0.15.16
func (m *AggregatedNamespace) GetResolution() string
func (*AggregatedNamespace) GetRetentionTime ¶ added in v0.15.16
func (m *AggregatedNamespace) GetRetentionTime() string
func (*AggregatedNamespace) Marshal ¶ added in v0.15.16
func (m *AggregatedNamespace) Marshal() (dAtA []byte, err error)
func (*AggregatedNamespace) MarshalTo ¶ added in v0.15.16
func (m *AggregatedNamespace) MarshalTo(dAtA []byte) (int, error)
func (*AggregatedNamespace) ProtoMessage ¶ added in v0.15.16
func (*AggregatedNamespace) ProtoMessage()
func (*AggregatedNamespace) Reset ¶ added in v0.15.16
func (m *AggregatedNamespace) Reset()
func (*AggregatedNamespace) Size ¶ added in v0.15.16
func (m *AggregatedNamespace) Size() (n int)
func (*AggregatedNamespace) String ¶ added in v0.15.16
func (m *AggregatedNamespace) String() string
func (*AggregatedNamespace) Unmarshal ¶ added in v0.15.16
func (m *AggregatedNamespace) Unmarshal(dAtA []byte) error
type BlockSize ¶
type BlockSize struct { // Explicit block size using time shorthand, e.g. "2h" Time string `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"` // With the expected series datapoints per hour, use a recommended block size ExpectedSeriesDatapointsPerHour int64 `` /* 161-byte string literal not displayed */ }
func (*BlockSize) Descriptor ¶
func (*BlockSize) GetExpectedSeriesDatapointsPerHour ¶
func (*BlockSize) ProtoMessage ¶
func (*BlockSize) ProtoMessage()
type DatabaseCreateRequest ¶
type DatabaseCreateRequest struct { // Required fields NamespaceName string `protobuf:"bytes,1,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` // Optional fields that may be inferred depending on database type NumShards int32 `protobuf:"varint,3,opt,name=num_shards,json=numShards,proto3" json:"num_shards,omitempty"` ReplicationFactor int32 `protobuf:"varint,4,opt,name=replication_factor,json=replicationFactor,proto3" json:"replication_factor,omitempty"` // Explicit retention time using time shorthand, e.g. "48h" RetentionTime string `protobuf:"bytes,5,opt,name=retention_time,json=retentionTime,proto3" json:"retention_time,omitempty"` // If no block size fields are set then the block size is // derived from the length of the retention period BlockSize *BlockSize `protobuf:"bytes,6,opt,name=block_size,json=blockSize" json:"block_size,omitempty"` // Required if not using local database type Hosts []*Host `protobuf:"bytes,7,rep,name=hosts" json:"hosts,omitempty"` // Optional field to add an additional aggregated namespace. AggregatedNamespace *AggregatedNamespace `protobuf:"bytes,8,opt,name=aggregated_namespace,json=aggregatedNamespace" json:"aggregated_namespace,omitempty"` }
func (*DatabaseCreateRequest) Descriptor ¶
func (*DatabaseCreateRequest) Descriptor() ([]byte, []int)
func (*DatabaseCreateRequest) GetAggregatedNamespace ¶ added in v0.15.16
func (m *DatabaseCreateRequest) GetAggregatedNamespace() *AggregatedNamespace
func (*DatabaseCreateRequest) GetBlockSize ¶
func (m *DatabaseCreateRequest) GetBlockSize() *BlockSize
func (*DatabaseCreateRequest) GetHosts ¶
func (m *DatabaseCreateRequest) GetHosts() []*Host
func (*DatabaseCreateRequest) GetNamespaceName ¶
func (m *DatabaseCreateRequest) GetNamespaceName() string
func (*DatabaseCreateRequest) GetNumShards ¶
func (m *DatabaseCreateRequest) GetNumShards() int32
func (*DatabaseCreateRequest) GetReplicationFactor ¶
func (m *DatabaseCreateRequest) GetReplicationFactor() int32
func (*DatabaseCreateRequest) GetRetentionTime ¶
func (m *DatabaseCreateRequest) GetRetentionTime() string
func (*DatabaseCreateRequest) GetType ¶
func (m *DatabaseCreateRequest) GetType() string
func (*DatabaseCreateRequest) Marshal ¶
func (m *DatabaseCreateRequest) Marshal() (dAtA []byte, err error)
func (*DatabaseCreateRequest) MarshalTo ¶
func (m *DatabaseCreateRequest) MarshalTo(dAtA []byte) (int, error)
func (*DatabaseCreateRequest) ProtoMessage ¶
func (*DatabaseCreateRequest) ProtoMessage()
func (*DatabaseCreateRequest) Reset ¶
func (m *DatabaseCreateRequest) Reset()
func (*DatabaseCreateRequest) Size ¶
func (m *DatabaseCreateRequest) Size() (n int)
func (*DatabaseCreateRequest) String ¶
func (m *DatabaseCreateRequest) String() string
func (*DatabaseCreateRequest) Unmarshal ¶
func (m *DatabaseCreateRequest) Unmarshal(dAtA []byte) error
type DatabaseCreateResponse ¶
type DatabaseCreateResponse struct { Namespace *NamespaceGetResponse `protobuf:"bytes,1,opt,name=namespace" json:"namespace,omitempty"` Placement *PlacementGetResponse `protobuf:"bytes,2,opt,name=placement" json:"placement,omitempty"` }
func (*DatabaseCreateResponse) Descriptor ¶
func (*DatabaseCreateResponse) Descriptor() ([]byte, []int)
func (*DatabaseCreateResponse) GetNamespace ¶
func (m *DatabaseCreateResponse) GetNamespace() *NamespaceGetResponse
func (*DatabaseCreateResponse) GetPlacement ¶
func (m *DatabaseCreateResponse) GetPlacement() *PlacementGetResponse
func (*DatabaseCreateResponse) Marshal ¶
func (m *DatabaseCreateResponse) Marshal() (dAtA []byte, err error)
func (*DatabaseCreateResponse) MarshalTo ¶
func (m *DatabaseCreateResponse) MarshalTo(dAtA []byte) (int, error)
func (*DatabaseCreateResponse) ProtoMessage ¶
func (*DatabaseCreateResponse) ProtoMessage()
func (*DatabaseCreateResponse) Reset ¶
func (m *DatabaseCreateResponse) Reset()
func (*DatabaseCreateResponse) Size ¶
func (m *DatabaseCreateResponse) Size() (n int)
func (*DatabaseCreateResponse) String ¶
func (m *DatabaseCreateResponse) String() string
func (*DatabaseCreateResponse) Unmarshal ¶
func (m *DatabaseCreateResponse) Unmarshal(dAtA []byte) error
type Host ¶
type Host struct { // Name (must be unique) of the host for logging/display purposes, can be hostname if desired, // or UUID or any other string ID as used in third party inventory system Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Address can be IP address or hostname, this is used to connect to the host Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` // Port running the Node RPC listen address (currently TChannel/Thrift Node service) Port uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"` // (Optional) Isolation group is an optional grouping, for instance to isolate replicas by // zones use zone here, or to isolate by host racks use racks here IsolationGroup string `protobuf:"bytes,4,opt,name=isolation_group,json=isolationGroup,proto3" json:"isolation_group,omitempty"` // (Optional) Zone specifies the zone the host resides in, this is optional. Zone string `protobuf:"bytes,5,opt,name=zone,proto3" json:"zone,omitempty"` // (Optional) Weight specifies when considering how many shards to take how to weight // this instance, do not specify to default to a weight of 1. Weight uint32 `protobuf:"varint,6,opt,name=weight,proto3" json:"weight,omitempty"` }
func (*Host) Descriptor ¶
func (*Host) GetAddress ¶
func (*Host) GetIsolationGroup ¶
func (*Host) ProtoMessage ¶
func (*Host) ProtoMessage()
type NamespaceAddRequest ¶
type NamespaceAddRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Options *namespace1.NamespaceOptions `protobuf:"bytes,2,opt,name=options" json:"options,omitempty"` }
func (*NamespaceAddRequest) Descriptor ¶
func (*NamespaceAddRequest) Descriptor() ([]byte, []int)
func (*NamespaceAddRequest) GetName ¶
func (m *NamespaceAddRequest) GetName() string
func (*NamespaceAddRequest) GetOptions ¶
func (m *NamespaceAddRequest) GetOptions() *namespace1.NamespaceOptions
func (*NamespaceAddRequest) Marshal ¶
func (m *NamespaceAddRequest) Marshal() (dAtA []byte, err error)
func (*NamespaceAddRequest) MarshalTo ¶
func (m *NamespaceAddRequest) MarshalTo(dAtA []byte) (int, error)
func (*NamespaceAddRequest) ProtoMessage ¶
func (*NamespaceAddRequest) ProtoMessage()
func (*NamespaceAddRequest) Reset ¶
func (m *NamespaceAddRequest) Reset()
func (*NamespaceAddRequest) Size ¶
func (m *NamespaceAddRequest) Size() (n int)
func (*NamespaceAddRequest) String ¶
func (m *NamespaceAddRequest) String() string
func (*NamespaceAddRequest) Unmarshal ¶
func (m *NamespaceAddRequest) Unmarshal(dAtA []byte) error
type NamespaceGetResponse ¶
type NamespaceGetResponse struct {
Registry *namespace1.Registry `protobuf:"bytes,1,opt,name=registry" json:"registry,omitempty"`
}
func (*NamespaceGetResponse) Descriptor ¶
func (*NamespaceGetResponse) Descriptor() ([]byte, []int)
func (*NamespaceGetResponse) GetRegistry ¶
func (m *NamespaceGetResponse) GetRegistry() *namespace1.Registry
func (*NamespaceGetResponse) Marshal ¶
func (m *NamespaceGetResponse) Marshal() (dAtA []byte, err error)
func (*NamespaceGetResponse) MarshalTo ¶
func (m *NamespaceGetResponse) MarshalTo(dAtA []byte) (int, error)
func (*NamespaceGetResponse) ProtoMessage ¶
func (*NamespaceGetResponse) ProtoMessage()
func (*NamespaceGetResponse) Reset ¶
func (m *NamespaceGetResponse) Reset()
func (*NamespaceGetResponse) Size ¶
func (m *NamespaceGetResponse) Size() (n int)
func (*NamespaceGetResponse) String ¶
func (m *NamespaceGetResponse) String() string
func (*NamespaceGetResponse) Unmarshal ¶
func (m *NamespaceGetResponse) Unmarshal(dAtA []byte) error
type NamespaceReadyRequest ¶ added in v1.0.0
type NamespaceReadyRequest struct { // Name is the namespace name. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Force forces the StagingStatus of the namespace to be moved to the ready state. // If the namespace is still not ready in DB nodes, then the coordinator will receive // errors upon attempted reads or writes until the namespaces is actually ready. Force bool `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"` }
NamespaceReadyRequest is the request for transitioning a namespace to the ready state. Calls to this endpoint are idempotent and can be safely retried on error.
func (*NamespaceReadyRequest) Descriptor ¶ added in v1.0.0
func (*NamespaceReadyRequest) Descriptor() ([]byte, []int)
func (*NamespaceReadyRequest) GetForce ¶ added in v1.0.0
func (m *NamespaceReadyRequest) GetForce() bool
func (*NamespaceReadyRequest) GetName ¶ added in v1.0.0
func (m *NamespaceReadyRequest) GetName() string
func (*NamespaceReadyRequest) Marshal ¶ added in v1.0.0
func (m *NamespaceReadyRequest) Marshal() (dAtA []byte, err error)
func (*NamespaceReadyRequest) MarshalTo ¶ added in v1.0.0
func (m *NamespaceReadyRequest) MarshalTo(dAtA []byte) (int, error)
func (*NamespaceReadyRequest) ProtoMessage ¶ added in v1.0.0
func (*NamespaceReadyRequest) ProtoMessage()
func (*NamespaceReadyRequest) Reset ¶ added in v1.0.0
func (m *NamespaceReadyRequest) Reset()
func (*NamespaceReadyRequest) Size ¶ added in v1.0.0
func (m *NamespaceReadyRequest) Size() (n int)
func (*NamespaceReadyRequest) String ¶ added in v1.0.0
func (m *NamespaceReadyRequest) String() string
func (*NamespaceReadyRequest) Unmarshal ¶ added in v1.0.0
func (m *NamespaceReadyRequest) Unmarshal(dAtA []byte) error
type NamespaceReadyResponse ¶ added in v1.0.0
type NamespaceReadyResponse struct {
Ready bool `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
}
NamespaceReadyResponse is the response from a request for transitioning a namespace to the ready state.
func (*NamespaceReadyResponse) Descriptor ¶ added in v1.0.0
func (*NamespaceReadyResponse) Descriptor() ([]byte, []int)
func (*NamespaceReadyResponse) GetReady ¶ added in v1.0.0
func (m *NamespaceReadyResponse) GetReady() bool
func (*NamespaceReadyResponse) Marshal ¶ added in v1.0.0
func (m *NamespaceReadyResponse) Marshal() (dAtA []byte, err error)
func (*NamespaceReadyResponse) MarshalTo ¶ added in v1.0.0
func (m *NamespaceReadyResponse) MarshalTo(dAtA []byte) (int, error)
func (*NamespaceReadyResponse) ProtoMessage ¶ added in v1.0.0
func (*NamespaceReadyResponse) ProtoMessage()
func (*NamespaceReadyResponse) Reset ¶ added in v1.0.0
func (m *NamespaceReadyResponse) Reset()
func (*NamespaceReadyResponse) Size ¶ added in v1.0.0
func (m *NamespaceReadyResponse) Size() (n int)
func (*NamespaceReadyResponse) String ¶ added in v1.0.0
func (m *NamespaceReadyResponse) String() string
func (*NamespaceReadyResponse) Unmarshal ¶ added in v1.0.0
func (m *NamespaceReadyResponse) Unmarshal(dAtA []byte) error
type NamespaceSchemaAddRequest ¶ added in v0.9.5
type NamespaceSchemaAddRequest struct { // Name is the namespace name. // Add schema to non-existent namespace will get 404. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // MsgName is the name of the top level proto message. MsgName string `protobuf:"bytes,2,opt,name=msgName,proto3" json:"msgName,omitempty"` // ProtoName is the name of the top level proto file. // Proto file content will be looked up from protoMap, so the name must corresponds to the map key. ProtoName string `protobuf:"bytes,3,opt,name=protoName,proto3" json:"protoName,omitempty"` // ProtoMap is a map of name to proto strings. // Except the top level proto file, other imported proto files' key must be exactly the same // as how they are imported in the import statement. // E.g. If import.proto is imported using as below // import "mainpkg/imported.proto"; // Then the map key for imported.proto must be "mainpkg/imported.proto" // See src/dbnode/namespame/kvadmin test for example. ProtoMap map[string]string `` /* 150-byte string literal not displayed */ }
func (*NamespaceSchemaAddRequest) Descriptor ¶ added in v0.9.5
func (*NamespaceSchemaAddRequest) Descriptor() ([]byte, []int)
func (*NamespaceSchemaAddRequest) GetMsgName ¶ added in v0.9.5
func (m *NamespaceSchemaAddRequest) GetMsgName() string
func (*NamespaceSchemaAddRequest) GetName ¶ added in v0.9.5
func (m *NamespaceSchemaAddRequest) GetName() string
func (*NamespaceSchemaAddRequest) GetProtoMap ¶ added in v0.9.5
func (m *NamespaceSchemaAddRequest) GetProtoMap() map[string]string
func (*NamespaceSchemaAddRequest) GetProtoName ¶ added in v0.9.5
func (m *NamespaceSchemaAddRequest) GetProtoName() string
func (*NamespaceSchemaAddRequest) Marshal ¶ added in v0.9.5
func (m *NamespaceSchemaAddRequest) Marshal() (dAtA []byte, err error)
func (*NamespaceSchemaAddRequest) MarshalTo ¶ added in v0.9.5
func (m *NamespaceSchemaAddRequest) MarshalTo(dAtA []byte) (int, error)
func (*NamespaceSchemaAddRequest) ProtoMessage ¶ added in v0.9.5
func (*NamespaceSchemaAddRequest) ProtoMessage()
func (*NamespaceSchemaAddRequest) Reset ¶ added in v0.9.5
func (m *NamespaceSchemaAddRequest) Reset()
func (*NamespaceSchemaAddRequest) Size ¶ added in v0.9.5
func (m *NamespaceSchemaAddRequest) Size() (n int)
func (*NamespaceSchemaAddRequest) String ¶ added in v0.9.5
func (m *NamespaceSchemaAddRequest) String() string
func (*NamespaceSchemaAddRequest) Unmarshal ¶ added in v0.9.5
func (m *NamespaceSchemaAddRequest) Unmarshal(dAtA []byte) error
type NamespaceSchemaAddResponse ¶ added in v0.9.5
type NamespaceSchemaAddResponse struct {
DeployID string `protobuf:"bytes,1,opt,name=deployID,proto3" json:"deployID,omitempty"`
}
func (*NamespaceSchemaAddResponse) Descriptor ¶ added in v0.9.5
func (*NamespaceSchemaAddResponse) Descriptor() ([]byte, []int)
func (*NamespaceSchemaAddResponse) GetDeployID ¶ added in v0.9.5
func (m *NamespaceSchemaAddResponse) GetDeployID() string
func (*NamespaceSchemaAddResponse) Marshal ¶ added in v0.9.5
func (m *NamespaceSchemaAddResponse) Marshal() (dAtA []byte, err error)
func (*NamespaceSchemaAddResponse) MarshalTo ¶ added in v0.9.5
func (m *NamespaceSchemaAddResponse) MarshalTo(dAtA []byte) (int, error)
func (*NamespaceSchemaAddResponse) ProtoMessage ¶ added in v0.9.5
func (*NamespaceSchemaAddResponse) ProtoMessage()
func (*NamespaceSchemaAddResponse) Reset ¶ added in v0.9.5
func (m *NamespaceSchemaAddResponse) Reset()
func (*NamespaceSchemaAddResponse) Size ¶ added in v0.9.5
func (m *NamespaceSchemaAddResponse) Size() (n int)
func (*NamespaceSchemaAddResponse) String ¶ added in v0.9.5
func (m *NamespaceSchemaAddResponse) String() string
func (*NamespaceSchemaAddResponse) Unmarshal ¶ added in v0.9.5
func (m *NamespaceSchemaAddResponse) Unmarshal(dAtA []byte) error
type NamespaceSchemaResetRequest ¶ added in v0.9.6
type NamespaceSchemaResetRequest struct { // Name is the namespace name. // Reset schema to non-existent namespace will get 404. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` }
func (*NamespaceSchemaResetRequest) Descriptor ¶ added in v0.9.6
func (*NamespaceSchemaResetRequest) Descriptor() ([]byte, []int)
func (*NamespaceSchemaResetRequest) GetName ¶ added in v0.9.6
func (m *NamespaceSchemaResetRequest) GetName() string
func (*NamespaceSchemaResetRequest) Marshal ¶ added in v0.9.6
func (m *NamespaceSchemaResetRequest) Marshal() (dAtA []byte, err error)
func (*NamespaceSchemaResetRequest) MarshalTo ¶ added in v0.9.6
func (m *NamespaceSchemaResetRequest) MarshalTo(dAtA []byte) (int, error)
func (*NamespaceSchemaResetRequest) ProtoMessage ¶ added in v0.9.6
func (*NamespaceSchemaResetRequest) ProtoMessage()
func (*NamespaceSchemaResetRequest) Reset ¶ added in v0.9.6
func (m *NamespaceSchemaResetRequest) Reset()
func (*NamespaceSchemaResetRequest) Size ¶ added in v0.9.6
func (m *NamespaceSchemaResetRequest) Size() (n int)
func (*NamespaceSchemaResetRequest) String ¶ added in v0.9.6
func (m *NamespaceSchemaResetRequest) String() string
func (*NamespaceSchemaResetRequest) Unmarshal ¶ added in v0.9.6
func (m *NamespaceSchemaResetRequest) Unmarshal(dAtA []byte) error
type NamespaceSchemaResetResponse ¶ added in v0.9.6
type NamespaceSchemaResetResponse struct { }
func (*NamespaceSchemaResetResponse) Descriptor ¶ added in v0.9.6
func (*NamespaceSchemaResetResponse) Descriptor() ([]byte, []int)
func (*NamespaceSchemaResetResponse) Marshal ¶ added in v0.9.6
func (m *NamespaceSchemaResetResponse) Marshal() (dAtA []byte, err error)
func (*NamespaceSchemaResetResponse) MarshalTo ¶ added in v0.9.6
func (m *NamespaceSchemaResetResponse) MarshalTo(dAtA []byte) (int, error)
func (*NamespaceSchemaResetResponse) ProtoMessage ¶ added in v0.9.6
func (*NamespaceSchemaResetResponse) ProtoMessage()
func (*NamespaceSchemaResetResponse) Reset ¶ added in v0.9.6
func (m *NamespaceSchemaResetResponse) Reset()
func (*NamespaceSchemaResetResponse) Size ¶ added in v0.9.6
func (m *NamespaceSchemaResetResponse) Size() (n int)
func (*NamespaceSchemaResetResponse) String ¶ added in v0.9.6
func (m *NamespaceSchemaResetResponse) String() string
func (*NamespaceSchemaResetResponse) Unmarshal ¶ added in v0.9.6
func (m *NamespaceSchemaResetResponse) Unmarshal(dAtA []byte) error
type NamespaceUpdateRequest ¶ added in v0.15.1
type NamespaceUpdateRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Options *namespace1.NamespaceOptions `protobuf:"bytes,2,opt,name=options" json:"options,omitempty"` }
func (*NamespaceUpdateRequest) Descriptor ¶ added in v0.15.1
func (*NamespaceUpdateRequest) Descriptor() ([]byte, []int)
func (*NamespaceUpdateRequest) GetName ¶ added in v0.15.1
func (m *NamespaceUpdateRequest) GetName() string
func (*NamespaceUpdateRequest) GetOptions ¶ added in v0.15.1
func (m *NamespaceUpdateRequest) GetOptions() *namespace1.NamespaceOptions
func (*NamespaceUpdateRequest) Marshal ¶ added in v0.15.1
func (m *NamespaceUpdateRequest) Marshal() (dAtA []byte, err error)
func (*NamespaceUpdateRequest) MarshalTo ¶ added in v0.15.1
func (m *NamespaceUpdateRequest) MarshalTo(dAtA []byte) (int, error)
func (*NamespaceUpdateRequest) ProtoMessage ¶ added in v0.15.1
func (*NamespaceUpdateRequest) ProtoMessage()
func (*NamespaceUpdateRequest) Reset ¶ added in v0.15.1
func (m *NamespaceUpdateRequest) Reset()
func (*NamespaceUpdateRequest) Size ¶ added in v0.15.1
func (m *NamespaceUpdateRequest) Size() (n int)
func (*NamespaceUpdateRequest) String ¶ added in v0.15.1
func (m *NamespaceUpdateRequest) String() string
func (*NamespaceUpdateRequest) Unmarshal ¶ added in v0.15.1
func (m *NamespaceUpdateRequest) Unmarshal(dAtA []byte) error
type PlacementAddRequest ¶
type PlacementAddRequest struct { Instances []*placementpb.Instance `protobuf:"bytes,1,rep,name=instances" json:"instances,omitempty"` // By default add requests will only succeed if all instances in the placement // are AVAILABLE for all their shards. force overrides that. Force bool `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"` }
func (*PlacementAddRequest) Descriptor ¶
func (*PlacementAddRequest) Descriptor() ([]byte, []int)
func (*PlacementAddRequest) GetForce ¶ added in v0.4.6
func (m *PlacementAddRequest) GetForce() bool
func (*PlacementAddRequest) GetInstances ¶
func (m *PlacementAddRequest) GetInstances() []*placementpb.Instance
func (*PlacementAddRequest) Marshal ¶
func (m *PlacementAddRequest) Marshal() (dAtA []byte, err error)
func (*PlacementAddRequest) MarshalTo ¶
func (m *PlacementAddRequest) MarshalTo(dAtA []byte) (int, error)
func (*PlacementAddRequest) ProtoMessage ¶
func (*PlacementAddRequest) ProtoMessage()
func (*PlacementAddRequest) Reset ¶
func (m *PlacementAddRequest) Reset()
func (*PlacementAddRequest) Size ¶
func (m *PlacementAddRequest) Size() (n int)
func (*PlacementAddRequest) String ¶
func (m *PlacementAddRequest) String() string
func (*PlacementAddRequest) Unmarshal ¶
func (m *PlacementAddRequest) Unmarshal(dAtA []byte) error
type PlacementGetResponse ¶
type PlacementGetResponse struct { Placement *placementpb.Placement `protobuf:"bytes,1,opt,name=placement" json:"placement,omitempty"` Version int32 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` }
func (*PlacementGetResponse) Descriptor ¶
func (*PlacementGetResponse) Descriptor() ([]byte, []int)
func (*PlacementGetResponse) GetPlacement ¶
func (m *PlacementGetResponse) GetPlacement() *placementpb.Placement
func (*PlacementGetResponse) GetVersion ¶
func (m *PlacementGetResponse) GetVersion() int32
func (*PlacementGetResponse) Marshal ¶
func (m *PlacementGetResponse) Marshal() (dAtA []byte, err error)
func (*PlacementGetResponse) MarshalTo ¶
func (m *PlacementGetResponse) MarshalTo(dAtA []byte) (int, error)
func (*PlacementGetResponse) ProtoMessage ¶
func (*PlacementGetResponse) ProtoMessage()
func (*PlacementGetResponse) Reset ¶
func (m *PlacementGetResponse) Reset()
func (*PlacementGetResponse) Size ¶
func (m *PlacementGetResponse) Size() (n int)
func (*PlacementGetResponse) String ¶
func (m *PlacementGetResponse) String() string
func (*PlacementGetResponse) Unmarshal ¶
func (m *PlacementGetResponse) Unmarshal(dAtA []byte) error
type PlacementInitRequest ¶
type PlacementInitRequest struct { Instances []*placementpb.Instance `protobuf:"bytes,1,rep,name=instances" json:"instances,omitempty"` NumShards int32 `protobuf:"varint,2,opt,name=num_shards,json=numShards,proto3" json:"num_shards,omitempty"` ReplicationFactor int32 `protobuf:"varint,3,opt,name=replication_factor,json=replicationFactor,proto3" json:"replication_factor,omitempty"` }
func (*PlacementInitRequest) Descriptor ¶
func (*PlacementInitRequest) Descriptor() ([]byte, []int)
func (*PlacementInitRequest) GetInstances ¶
func (m *PlacementInitRequest) GetInstances() []*placementpb.Instance
func (*PlacementInitRequest) GetNumShards ¶
func (m *PlacementInitRequest) GetNumShards() int32
func (*PlacementInitRequest) GetReplicationFactor ¶
func (m *PlacementInitRequest) GetReplicationFactor() int32
func (*PlacementInitRequest) Marshal ¶
func (m *PlacementInitRequest) Marshal() (dAtA []byte, err error)
func (*PlacementInitRequest) MarshalTo ¶
func (m *PlacementInitRequest) MarshalTo(dAtA []byte) (int, error)
func (*PlacementInitRequest) ProtoMessage ¶
func (*PlacementInitRequest) ProtoMessage()
func (*PlacementInitRequest) Reset ¶
func (m *PlacementInitRequest) Reset()
func (*PlacementInitRequest) Size ¶
func (m *PlacementInitRequest) Size() (n int)
func (*PlacementInitRequest) String ¶
func (m *PlacementInitRequest) String() string
func (*PlacementInitRequest) Unmarshal ¶
func (m *PlacementInitRequest) Unmarshal(dAtA []byte) error
type PlacementReplaceRequest ¶ added in v0.4.8
type PlacementReplaceRequest struct { LeavingInstanceIDs []string `protobuf:"bytes,1,rep,name=leavingInstanceIDs" json:"leavingInstanceIDs,omitempty"` Candidates []*placementpb.Instance `protobuf:"bytes,2,rep,name=candidates" json:"candidates,omitempty"` Force bool `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"` }
func (*PlacementReplaceRequest) Descriptor ¶ added in v0.4.8
func (*PlacementReplaceRequest) Descriptor() ([]byte, []int)
func (*PlacementReplaceRequest) GetCandidates ¶ added in v0.4.8
func (m *PlacementReplaceRequest) GetCandidates() []*placementpb.Instance
func (*PlacementReplaceRequest) GetForce ¶ added in v0.4.8
func (m *PlacementReplaceRequest) GetForce() bool
func (*PlacementReplaceRequest) GetLeavingInstanceIDs ¶ added in v0.4.8
func (m *PlacementReplaceRequest) GetLeavingInstanceIDs() []string
func (*PlacementReplaceRequest) Marshal ¶ added in v0.4.8
func (m *PlacementReplaceRequest) Marshal() (dAtA []byte, err error)
func (*PlacementReplaceRequest) MarshalTo ¶ added in v0.4.8
func (m *PlacementReplaceRequest) MarshalTo(dAtA []byte) (int, error)
func (*PlacementReplaceRequest) ProtoMessage ¶ added in v0.4.8
func (*PlacementReplaceRequest) ProtoMessage()
func (*PlacementReplaceRequest) Reset ¶ added in v0.4.8
func (m *PlacementReplaceRequest) Reset()
func (*PlacementReplaceRequest) Size ¶ added in v0.4.8
func (m *PlacementReplaceRequest) Size() (n int)
func (*PlacementReplaceRequest) String ¶ added in v0.4.8
func (m *PlacementReplaceRequest) String() string
func (*PlacementReplaceRequest) Unmarshal ¶ added in v0.4.8
func (m *PlacementReplaceRequest) Unmarshal(dAtA []byte) error
type PlacementSetRequest ¶ added in v0.15.0
type PlacementSetRequest struct { Placement *placementpb.Placement `protobuf:"bytes,1,opt,name=placement" json:"placement,omitempty"` Version int32 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` // Confirm must be set, otherwise just a dry run is executed. Confirm bool `protobuf:"varint,3,opt,name=confirm,proto3" json:"confirm,omitempty"` }
func (*PlacementSetRequest) Descriptor ¶ added in v0.15.0
func (*PlacementSetRequest) Descriptor() ([]byte, []int)
func (*PlacementSetRequest) GetConfirm ¶ added in v0.15.0
func (m *PlacementSetRequest) GetConfirm() bool
func (*PlacementSetRequest) GetPlacement ¶ added in v0.15.0
func (m *PlacementSetRequest) GetPlacement() *placementpb.Placement
func (*PlacementSetRequest) GetVersion ¶ added in v0.15.0
func (m *PlacementSetRequest) GetVersion() int32
func (*PlacementSetRequest) Marshal ¶ added in v0.15.0
func (m *PlacementSetRequest) Marshal() (dAtA []byte, err error)
func (*PlacementSetRequest) MarshalTo ¶ added in v0.15.0
func (m *PlacementSetRequest) MarshalTo(dAtA []byte) (int, error)
func (*PlacementSetRequest) ProtoMessage ¶ added in v0.15.0
func (*PlacementSetRequest) ProtoMessage()
func (*PlacementSetRequest) Reset ¶ added in v0.15.0
func (m *PlacementSetRequest) Reset()
func (*PlacementSetRequest) Size ¶ added in v0.15.0
func (m *PlacementSetRequest) Size() (n int)
func (*PlacementSetRequest) String ¶ added in v0.15.0
func (m *PlacementSetRequest) String() string
func (*PlacementSetRequest) Unmarshal ¶ added in v0.15.0
func (m *PlacementSetRequest) Unmarshal(dAtA []byte) error
type PlacementSetResponse ¶ added in v0.15.0
type PlacementSetResponse struct { Placement *placementpb.Placement `protobuf:"bytes,1,opt,name=placement" json:"placement,omitempty"` Version int32 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` DryRun bool `protobuf:"varint,3,opt,name=dryRun,proto3" json:"dryRun,omitempty"` }
func (*PlacementSetResponse) Descriptor ¶ added in v0.15.0
func (*PlacementSetResponse) Descriptor() ([]byte, []int)
func (*PlacementSetResponse) GetDryRun ¶ added in v0.15.0
func (m *PlacementSetResponse) GetDryRun() bool
func (*PlacementSetResponse) GetPlacement ¶ added in v0.15.0
func (m *PlacementSetResponse) GetPlacement() *placementpb.Placement
func (*PlacementSetResponse) GetVersion ¶ added in v0.15.0
func (m *PlacementSetResponse) GetVersion() int32
func (*PlacementSetResponse) Marshal ¶ added in v0.15.0
func (m *PlacementSetResponse) Marshal() (dAtA []byte, err error)
func (*PlacementSetResponse) MarshalTo ¶ added in v0.15.0
func (m *PlacementSetResponse) MarshalTo(dAtA []byte) (int, error)
func (*PlacementSetResponse) ProtoMessage ¶ added in v0.15.0
func (*PlacementSetResponse) ProtoMessage()
func (*PlacementSetResponse) Reset ¶ added in v0.15.0
func (m *PlacementSetResponse) Reset()
func (*PlacementSetResponse) Size ¶ added in v0.15.0
func (m *PlacementSetResponse) Size() (n int)
func (*PlacementSetResponse) String ¶ added in v0.15.0
func (m *PlacementSetResponse) String() string
func (*PlacementSetResponse) Unmarshal ¶ added in v0.15.0
func (m *PlacementSetResponse) Unmarshal(dAtA []byte) error
type TopicAddRequest ¶ added in v0.4.7
type TopicAddRequest struct {
ConsumerService *topicpb.ConsumerService `protobuf:"bytes,1,opt,name=consumer_service,json=consumerService" json:"consumer_service,omitempty"`
}
func (*TopicAddRequest) Descriptor ¶ added in v0.4.7
func (*TopicAddRequest) Descriptor() ([]byte, []int)
func (*TopicAddRequest) GetConsumerService ¶ added in v0.4.7
func (m *TopicAddRequest) GetConsumerService() *topicpb.ConsumerService
func (*TopicAddRequest) Marshal ¶ added in v0.4.7
func (m *TopicAddRequest) Marshal() (dAtA []byte, err error)
func (*TopicAddRequest) MarshalTo ¶ added in v0.4.7
func (m *TopicAddRequest) MarshalTo(dAtA []byte) (int, error)
func (*TopicAddRequest) ProtoMessage ¶ added in v0.4.7
func (*TopicAddRequest) ProtoMessage()
func (*TopicAddRequest) Reset ¶ added in v0.4.7
func (m *TopicAddRequest) Reset()
func (*TopicAddRequest) Size ¶ added in v0.4.7
func (m *TopicAddRequest) Size() (n int)
func (*TopicAddRequest) String ¶ added in v0.4.7
func (m *TopicAddRequest) String() string
func (*TopicAddRequest) Unmarshal ¶ added in v0.4.7
func (m *TopicAddRequest) Unmarshal(dAtA []byte) error
type TopicGetResponse ¶ added in v0.4.7
type TopicGetResponse struct { Topic *topicpb.Topic `protobuf:"bytes,1,opt,name=topic" json:"topic,omitempty"` Version uint32 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` }
func (*TopicGetResponse) Descriptor ¶ added in v0.4.7
func (*TopicGetResponse) Descriptor() ([]byte, []int)
func (*TopicGetResponse) GetTopic ¶ added in v0.4.7
func (m *TopicGetResponse) GetTopic() *topicpb.Topic
func (*TopicGetResponse) GetVersion ¶ added in v0.4.7
func (m *TopicGetResponse) GetVersion() uint32
func (*TopicGetResponse) Marshal ¶ added in v0.4.7
func (m *TopicGetResponse) Marshal() (dAtA []byte, err error)
func (*TopicGetResponse) MarshalTo ¶ added in v0.4.7
func (m *TopicGetResponse) MarshalTo(dAtA []byte) (int, error)
func (*TopicGetResponse) ProtoMessage ¶ added in v0.4.7
func (*TopicGetResponse) ProtoMessage()
func (*TopicGetResponse) Reset ¶ added in v0.4.7
func (m *TopicGetResponse) Reset()
func (*TopicGetResponse) Size ¶ added in v0.4.7
func (m *TopicGetResponse) Size() (n int)
func (*TopicGetResponse) String ¶ added in v0.4.7
func (m *TopicGetResponse) String() string
func (*TopicGetResponse) Unmarshal ¶ added in v0.4.7
func (m *TopicGetResponse) Unmarshal(dAtA []byte) error
type TopicInitRequest ¶ added in v0.4.7
type TopicInitRequest struct {
NumberOfShards uint32 `protobuf:"varint,1,opt,name=number_of_shards,json=numberOfShards,proto3" json:"number_of_shards,omitempty"`
}
func (*TopicInitRequest) Descriptor ¶ added in v0.4.7
func (*TopicInitRequest) Descriptor() ([]byte, []int)
func (*TopicInitRequest) GetNumberOfShards ¶ added in v0.4.7
func (m *TopicInitRequest) GetNumberOfShards() uint32
func (*TopicInitRequest) Marshal ¶ added in v0.4.7
func (m *TopicInitRequest) Marshal() (dAtA []byte, err error)
func (*TopicInitRequest) MarshalTo ¶ added in v0.4.7
func (m *TopicInitRequest) MarshalTo(dAtA []byte) (int, error)
func (*TopicInitRequest) ProtoMessage ¶ added in v0.4.7
func (*TopicInitRequest) ProtoMessage()
func (*TopicInitRequest) Reset ¶ added in v0.4.7
func (m *TopicInitRequest) Reset()
func (*TopicInitRequest) Size ¶ added in v0.4.7
func (m *TopicInitRequest) Size() (n int)
func (*TopicInitRequest) String ¶ added in v0.4.7
func (m *TopicInitRequest) String() string
func (*TopicInitRequest) Unmarshal ¶ added in v0.4.7
func (m *TopicInitRequest) Unmarshal(dAtA []byte) error
type TopicUpdateRequest ¶ added in v0.15.0
type TopicUpdateRequest struct { ConsumerServices []*topicpb.ConsumerService `protobuf:"bytes,1,rep,name=consumer_services,json=consumerServices" json:"consumer_services,omitempty"` Version uint32 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` }
Request to update a topic and set its consumer services to a new value. CheckAndSet is used based on the version passed.
func (*TopicUpdateRequest) Descriptor ¶ added in v0.15.0
func (*TopicUpdateRequest) Descriptor() ([]byte, []int)
func (*TopicUpdateRequest) GetConsumerServices ¶ added in v0.15.0
func (m *TopicUpdateRequest) GetConsumerServices() []*topicpb.ConsumerService
func (*TopicUpdateRequest) GetVersion ¶ added in v0.15.0
func (m *TopicUpdateRequest) GetVersion() uint32
func (*TopicUpdateRequest) Marshal ¶ added in v0.15.0
func (m *TopicUpdateRequest) Marshal() (dAtA []byte, err error)
func (*TopicUpdateRequest) MarshalTo ¶ added in v0.15.0
func (m *TopicUpdateRequest) MarshalTo(dAtA []byte) (int, error)
func (*TopicUpdateRequest) ProtoMessage ¶ added in v0.15.0
func (*TopicUpdateRequest) ProtoMessage()
func (*TopicUpdateRequest) Reset ¶ added in v0.15.0
func (m *TopicUpdateRequest) Reset()
func (*TopicUpdateRequest) Size ¶ added in v0.15.0
func (m *TopicUpdateRequest) Size() (n int)
func (*TopicUpdateRequest) String ¶ added in v0.15.0
func (m *TopicUpdateRequest) String() string
func (*TopicUpdateRequest) Unmarshal ¶ added in v0.15.0
func (m *TopicUpdateRequest) Unmarshal(dAtA []byte) error
Click to show internal directories.
Click to hide internal directories.