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 BlockSize Host DatabaseCreateResponse NamespaceGetResponse NamespaceAddRequest NamespaceSchemaAddRequest NamespaceSchemaAddResponse NamespaceSchemaResetRequest NamespaceSchemaResetResponse PlacementInitRequest PlacementGetResponse PlacementAddRequest PlacementReplaceRequest TopicGetResponse TopicInitRequest TopicAddRequest
Index ¶
- Variables
- 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) 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 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 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 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
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 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"` }
func (*DatabaseCreateRequest) Descriptor ¶
func (*DatabaseCreateRequest) Descriptor() ([]byte, []int)
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 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 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 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
Click to show internal directories.
Click to hide internal directories.