admin

package
v0.15.17-hotfix.2 Latest Latest
Warning

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

 Go to latest Published: Oct 28, 2020 License: Apache-2.0 Imports: 7 Imported by: 14

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
PlacementInitRequest
PlacementGetResponse
PlacementAddRequest
PlacementReplaceRequest
PlacementSetRequest
PlacementSetResponse
TopicGetResponse
TopicInitRequest
TopicAddRequest
TopicUpdateRequest

Index

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) Descriptor() ([]byte, []int)

func (*BlockSize) GetExpectedSeriesDatapointsPerHour 

func (m *BlockSize) GetExpectedSeriesDatapointsPerHour() int64

func (*BlockSize) GetTime 

func (m *BlockSize) GetTime() string

func (*BlockSize) Marshal 

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

func (*BlockSize) MarshalTo 

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

func (*BlockSize) ProtoMessage 

func (*BlockSize) ProtoMessage()

func (*BlockSize) Reset 

func (m *BlockSize) Reset()

func (*BlockSize) Size 

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

func (*BlockSize) String 

func (m *BlockSize) String() string

func (*BlockSize) Unmarshal 

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

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) Descriptor() ([]byte, []int)

func (*Host) GetAddress 

func (m *Host) GetAddress() string

func (*Host) GetId 

func (m *Host) GetId() string

func (*Host) GetIsolationGroup 

func (m *Host) GetIsolationGroup() string

func (*Host) GetPort 

func (m *Host) GetPort() uint32

func (*Host) GetWeight 

func (m *Host) GetWeight() uint32

func (*Host) GetZone 

func (m *Host) GetZone() string

func (*Host) Marshal 

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

func (*Host) MarshalTo 

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

func (*Host) ProtoMessage 

func (*Host) ProtoMessage()

func (*Host) Reset 

func (m *Host) Reset()

func (*Host) Size 

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

func (*Host) String 

func (m *Host) String() string

func (*Host) Unmarshal 

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

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

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.