topicpb

package
v1.6.0 Latest Latest
Warning

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

 Go to latest Published: Sep 25, 2026 License: Apache-2.0 Imports: 5 Imported by: 10

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
Filters
StoragePolicyFilter
PercentageFilter
ShardSetFilter
RoutingPolicyFilter
ServiceID

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthTopic = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTopic   = fmt.Errorf("proto: integer overflow")
)
View Source 
var ConsumptionType_name = map[int32]string{
	0: "UNKNOWN",
	1: "SHARED",
	2: "REPLICATED",
}
View Source 
var ConsumptionType_value = map[string]int32{
	"UNKNOWN":    0,
	"SHARED":     1,
	"REPLICATED": 2,
}

Functions

This section is empty.

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"`
	Filters         *Filters        `protobuf:"bytes,4,opt,name=filters" json:"filters,omitempty"`
}

func (*ConsumerService) Descriptor 

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

func (*ConsumerService) GetConsumptionType 

func (m *ConsumerService) GetConsumptionType() ConsumptionType

func (*ConsumerService) GetFilters added in v1.6.0 

func (m *ConsumerService) GetFilters() *Filters

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 Filters added in v1.6.0 

type Filters struct {
	StoragePolicyFilter *StoragePolicyFilter `protobuf:"bytes,1,opt,name=storage_policy_filter,json=storagePolicyFilter" json:"storage_policy_filter,omitempty"`
	PercentageFilter    *PercentageFilter    `protobuf:"bytes,2,opt,name=percentage_filter,json=percentageFilter" json:"percentage_filter,omitempty"`
	ShardSetFilter      *ShardSetFilter      `protobuf:"bytes,3,opt,name=shard_set_filter,json=shardSetFilter" json:"shard_set_filter,omitempty"`
	RoutingPolicyFilter *RoutingPolicyFilter `protobuf:"bytes,4,opt,name=routing_policy_filter,json=routingPolicyFilter" json:"routing_policy_filter,omitempty"`
}

func (*Filters) Descriptor added in v1.6.0 

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

func (*Filters) GetPercentageFilter added in v1.6.0 

func (m *Filters) GetPercentageFilter() *PercentageFilter

func (*Filters) GetRoutingPolicyFilter added in v1.6.0 

func (m *Filters) GetRoutingPolicyFilter() *RoutingPolicyFilter

func (*Filters) GetShardSetFilter added in v1.6.0 

func (m *Filters) GetShardSetFilter() *ShardSetFilter

func (*Filters) GetStoragePolicyFilter added in v1.6.0 

func (m *Filters) GetStoragePolicyFilter() *StoragePolicyFilter

func (*Filters) Marshal added in v1.6.0 

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

func (*Filters) MarshalTo added in v1.6.0 

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

func (*Filters) ProtoMessage added in v1.6.0 

func (*Filters) ProtoMessage()

func (*Filters) Reset added in v1.6.0 

func (m *Filters) Reset()

func (*Filters) Size added in v1.6.0 

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

func (*Filters) String added in v1.6.0 

func (m *Filters) String() string

func (*Filters) Unmarshal added in v1.6.0 

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

type PercentageFilter added in v1.6.0 

type PercentageFilter struct {
	Percentage float64 `protobuf:"fixed64,1,opt,name=percentage,proto3" json:"percentage,omitempty"`
}

func (*PercentageFilter) Descriptor added in v1.6.0 

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

func (*PercentageFilter) GetPercentage added in v1.6.0 

func (m *PercentageFilter) GetPercentage() float64

func (*PercentageFilter) Marshal added in v1.6.0 

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

func (*PercentageFilter) MarshalTo added in v1.6.0 

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

func (*PercentageFilter) ProtoMessage added in v1.6.0 

func (*PercentageFilter) ProtoMessage()

func (*PercentageFilter) Reset added in v1.6.0 

func (m *PercentageFilter) Reset()

func (*PercentageFilter) Size added in v1.6.0 

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

func (*PercentageFilter) String added in v1.6.0 

func (m *PercentageFilter) String() string

func (*PercentageFilter) Unmarshal added in v1.6.0 

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

type RoutingPolicyFilter added in v1.6.0 

type RoutingPolicyFilter struct {
	AllowedTrafficTypes []string `protobuf:"bytes,1,rep,name=allowed_traffic_types,json=allowedTrafficTypes" json:"allowed_traffic_types,omitempty"`
	IsDefault           bool     `protobuf:"varint,2,opt,name=is_default,json=isDefault,proto3" json:"is_default,omitempty"`
}

func (*RoutingPolicyFilter) Descriptor added in v1.6.0 

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

func (*RoutingPolicyFilter) GetAllowedTrafficTypes added in v1.6.0 

func (m *RoutingPolicyFilter) GetAllowedTrafficTypes() []string

func (*RoutingPolicyFilter) GetIsDefault added in v1.6.0 

func (m *RoutingPolicyFilter) GetIsDefault() bool

func (*RoutingPolicyFilter) Marshal added in v1.6.0 

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

func (*RoutingPolicyFilter) MarshalTo added in v1.6.0 

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

func (*RoutingPolicyFilter) ProtoMessage added in v1.6.0 

func (*RoutingPolicyFilter) ProtoMessage()

func (*RoutingPolicyFilter) Reset added in v1.6.0 

func (m *RoutingPolicyFilter) Reset()

func (*RoutingPolicyFilter) Size added in v1.6.0 

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

func (*RoutingPolicyFilter) String added in v1.6.0 

func (m *RoutingPolicyFilter) String() string

func (*RoutingPolicyFilter) Unmarshal added in v1.6.0 

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

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 ShardSetFilter added in v1.6.0 

type ShardSetFilter struct {
	ShardSet string `protobuf:"bytes,1,opt,name=shard_set,json=shardSet,proto3" json:"shard_set,omitempty"`
}

func (*ShardSetFilter) Descriptor added in v1.6.0 

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

func (*ShardSetFilter) GetShardSet added in v1.6.0 

func (m *ShardSetFilter) GetShardSet() string

func (*ShardSetFilter) Marshal added in v1.6.0 

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

func (*ShardSetFilter) MarshalTo added in v1.6.0 

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

func (*ShardSetFilter) ProtoMessage added in v1.6.0 

func (*ShardSetFilter) ProtoMessage()

func (*ShardSetFilter) Reset added in v1.6.0 

func (m *ShardSetFilter) Reset()

func (*ShardSetFilter) Size added in v1.6.0 

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

func (*ShardSetFilter) String added in v1.6.0 

func (m *ShardSetFilter) String() string

func (*ShardSetFilter) Unmarshal added in v1.6.0 

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

type StoragePolicyFilter added in v1.6.0 

type StoragePolicyFilter struct {
	StoragePolicies []string `protobuf:"bytes,1,rep,name=storage_policies,json=storagePolicies" json:"storage_policies,omitempty"`
}

func (*StoragePolicyFilter) Descriptor added in v1.6.0 

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

func (*StoragePolicyFilter) GetStoragePolicies added in v1.6.0 

func (m *StoragePolicyFilter) GetStoragePolicies() []string

func (*StoragePolicyFilter) Marshal added in v1.6.0 

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

func (*StoragePolicyFilter) MarshalTo added in v1.6.0 

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

func (*StoragePolicyFilter) ProtoMessage added in v1.6.0 

func (*StoragePolicyFilter) ProtoMessage()

func (*StoragePolicyFilter) Reset added in v1.6.0 

func (m *StoragePolicyFilter) Reset()

func (*StoragePolicyFilter) Size added in v1.6.0 

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

func (*StoragePolicyFilter) String added in v1.6.0 

func (m *StoragePolicyFilter) String() string

func (*StoragePolicyFilter) Unmarshal added in v1.6.0 

func (m *StoragePolicyFilter) 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

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.