admin

package
v0.15.0-rc.4 Latest Latest
Warning

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

 Go to latest Published: Apr 2, 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
BlockSize
Host
DatabaseCreateResponse
NamespaceGetResponse
NamespaceAddRequest
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 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"`
}

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