topicpb

Documentation

Overview

Package topicpb is a generated protocol buffer package.

It is generated from these files:

github.com/m3db/m3/src/msg/generated/proto/topicpb/topic.proto

It has these top-level messages:

Topic
ConsumerService
ServiceID

Index

• Variables
• type ConsumerService
  • func (*ConsumerService) Descriptor() ([]byte, []int)
  • func (m *ConsumerService) GetConsumptionType() ConsumptionType
  • func (m *ConsumerService) GetMessageTtlNanos() int64
  • func (m *ConsumerService) GetServiceId() *ServiceID
  • func (m *ConsumerService) Marshal() (dAtA []byte, err error)
  • func (m *ConsumerService) MarshalTo(dAtA []byte) (int, error)
  • func (*ConsumerService) ProtoMessage()
  • func (m *ConsumerService) Reset()
  • func (m *ConsumerService) Size() (n int)
  • func (m *ConsumerService) String() string
  • func (m *ConsumerService) Unmarshal(dAtA []byte) error
• type ConsumptionType
  • func (ConsumptionType) EnumDescriptor() ([]byte, []int)
  • func (x ConsumptionType) String() string
• type ServiceID
  • func (*ServiceID) Descriptor() ([]byte, []int)
  • func (m *ServiceID) GetEnvironment() string
  • func (m *ServiceID) GetName() string
  • func (m *ServiceID) GetZone() string
  • func (m *ServiceID) Marshal() (dAtA []byte, err error)
  • func (m *ServiceID) MarshalTo(dAtA []byte) (int, error)
  • func (*ServiceID) ProtoMessage()
  • func (m *ServiceID) Reset()
  • func (m *ServiceID) Size() (n int)
  • func (m *ServiceID) String() string
  • func (m *ServiceID) Unmarshal(dAtA []byte) error
• type Topic
  • func (*Topic) Descriptor() ([]byte, []int)
  • func (m *Topic) GetConsumerServices() []*ConsumerService
  • func (m *Topic) GetName() string
  • func (m *Topic) GetNumberOfShards() uint32
  • func (m *Topic) Marshal() (dAtA []byte, err error)
  • func (m *Topic) MarshalTo(dAtA []byte) (int, error)
  • func (*Topic) ProtoMessage()
  • func (m *Topic) Reset()
  • func (m *Topic) Size() (n int)
  • func (m *Topic) String() string
  • func (m *Topic) Unmarshal(dAtA []byte) error

Variables

var (
	ErrInvalidLengthTopic = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTopic   = fmt.Errorf("proto: integer overflow")
)

var ConsumptionType_name = map[int32]string{
	0: "UNKNOWN",
	1: "SHARED",
	2: "REPLICATED",
}

var ConsumptionType_value = map[string]int32{
	"UNKNOWN":    0,
	"SHARED":     1,
	"REPLICATED": 2,
}

Types

type ConsumerService

type ConsumerService struct {
	ServiceId       *ServiceID      `protobuf:"bytes,1,opt,name=service_id,json=serviceId" json:"service_id,omitempty"`
	ConsumptionType ConsumptionType `` /* 136-byte string literal not displayed */
	MessageTtlNanos int64           `protobuf:"varint,3,opt,name=message_ttl_nanos,json=messageTtlNanos,proto3" json:"message_ttl_nanos,omitempty"`
}

func (*ConsumerService) Descriptor

func (*ConsumerService) Descriptor() ([]byte, []int)

func (*ConsumerService) GetConsumptionType

func (m *ConsumerService) GetConsumptionType() ConsumptionType

func (*ConsumerService) GetMessageTtlNanos

func (m *ConsumerService) GetMessageTtlNanos() int64

func (*ConsumerService) GetServiceId

func (m *ConsumerService) GetServiceId() *ServiceID

func (*ConsumerService) Marshal

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

func (*ConsumerService) MarshalTo

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

func (*ConsumerService) ProtoMessage

func (*ConsumerService) ProtoMessage()

func (*ConsumerService) Reset

func (m *ConsumerService) Reset()

func (*ConsumerService) Size

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

func (*ConsumerService) String

func (m *ConsumerService) String() string

func (*ConsumerService) Unmarshal

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

type ConsumptionType

type ConsumptionType int32

const (
	ConsumptionType_UNKNOWN    ConsumptionType = 0
	ConsumptionType_SHARED     ConsumptionType = 1
	ConsumptionType_REPLICATED ConsumptionType = 2
)

func (ConsumptionType) EnumDescriptor

func (ConsumptionType) EnumDescriptor() ([]byte, []int)

func (ConsumptionType) String

func (x ConsumptionType) String() string

type ServiceID

type ServiceID struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Environment string `protobuf:"bytes,2,opt,name=environment,proto3" json:"environment,omitempty"`
	Zone        string `protobuf:"bytes,3,opt,name=zone,proto3" json:"zone,omitempty"`
}

func (*ServiceID) Descriptor

func (*ServiceID) Descriptor() ([]byte, []int)

func (*ServiceID) GetEnvironment

func (m *ServiceID) GetEnvironment() string

func (*ServiceID) GetName

func (m *ServiceID) GetName() string

func (*ServiceID) GetZone

func (m *ServiceID) GetZone() string

func (*ServiceID) Marshal

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

func (*ServiceID) MarshalTo

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

func (*ServiceID) ProtoMessage

func (*ServiceID) ProtoMessage()

func (*ServiceID) Reset

func (m *ServiceID) Reset()

func (*ServiceID) Size

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

func (*ServiceID) String

func (m *ServiceID) String() string

func (*ServiceID) Unmarshal

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

type Topic

type Topic struct {
	Name             string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	NumberOfShards   uint32             `protobuf:"varint,2,opt,name=number_of_shards,json=numberOfShards,proto3" json:"number_of_shards,omitempty"`
	ConsumerServices []*ConsumerService `protobuf:"bytes,3,rep,name=consumer_services,json=consumerServices" json:"consumer_services,omitempty"`
}

func (*Topic) Descriptor

func (*Topic) Descriptor() ([]byte, []int)

func (*Topic) GetConsumerServices

func (m *Topic) GetConsumerServices() []*ConsumerService

func (*Topic) GetName

func (m *Topic) GetName() string

func (*Topic) GetNumberOfShards

func (m *Topic) GetNumberOfShards() uint32

func (*Topic) Marshal

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

func (*Topic) MarshalTo

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

func (*Topic) ProtoMessage

func (*Topic) ProtoMessage()

func (*Topic) Reset

func (m *Topic) Reset()

func (*Topic) Size

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

func (*Topic) String

func (m *Topic) String() string

func (*Topic) Unmarshal

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