admin

package
v0.8.2 Latest Latest
Warning

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

Go to latest
Published: Apr 11, 2019 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
PlacementInitRequest
PlacementGetResponse
PlacementAddRequest
PlacementReplaceRequest
TopicGetResponse
TopicInitRequest
TopicAddRequest

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL