pubsub_pb

package
v0.2.1 Latest Latest
Warning

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

 Go to latest Published: Nov 4, 2019 License: MIT Imports: 4 Imported by: 159

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRpc   = fmt.Errorf("proto: integer overflow")
)
View Source 
var TopicDescriptor_AuthOpts_AuthMode_name = map[int32]string{
	0: "NONE",
	1: "KEY",
	2: "WOT",
}
View Source 
var TopicDescriptor_AuthOpts_AuthMode_value = map[string]int32{
	"NONE": 0,
	"KEY":  1,
	"WOT":  2,
}
View Source 
var TopicDescriptor_EncOpts_EncMode_name = map[int32]string{
	0: "NONE",
	1: "SHAREDKEY",
	2: "WOT",
}
View Source 
var TopicDescriptor_EncOpts_EncMode_value = map[string]int32{
	"NONE":      0,
	"SHAREDKEY": 1,
	"WOT":       2,
}

Functions

This section is empty.

Types

type ControlGraft 

type ControlGraft struct {
	TopicID              *string  `protobuf:"bytes,1,opt,name=topicID" json:"topicID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ControlGraft) Descriptor 

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

func (*ControlGraft) GetTopicID 

func (m *ControlGraft) GetTopicID() string

func (*ControlGraft) Marshal 

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

func (*ControlGraft) MarshalTo 

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

func (*ControlGraft) ProtoMessage 

func (*ControlGraft) ProtoMessage()

func (*ControlGraft) Reset 

func (m *ControlGraft) Reset()

func (*ControlGraft) Size 

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

func (*ControlGraft) String 

func (m *ControlGraft) String() string

func (*ControlGraft) Unmarshal 

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

func (*ControlGraft) XXX_DiscardUnknown 

func (m *ControlGraft) XXX_DiscardUnknown()

func (*ControlGraft) XXX_Marshal 

func (m *ControlGraft) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControlGraft) XXX_Merge 

func (m *ControlGraft) XXX_Merge(src proto.Message)

func (*ControlGraft) XXX_Size 

func (m *ControlGraft) XXX_Size() int

func (*ControlGraft) XXX_Unmarshal 

func (m *ControlGraft) XXX_Unmarshal(b []byte) error

type ControlIHave 

type ControlIHave struct {
	TopicID              *string  `protobuf:"bytes,1,opt,name=topicID" json:"topicID,omitempty"`
	MessageIDs           []string `protobuf:"bytes,2,rep,name=messageIDs" json:"messageIDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ControlIHave) Descriptor 

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

func (*ControlIHave) GetMessageIDs 

func (m *ControlIHave) GetMessageIDs() []string

func (*ControlIHave) GetTopicID 

func (m *ControlIHave) GetTopicID() string

func (*ControlIHave) Marshal 

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

func (*ControlIHave) MarshalTo 

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

func (*ControlIHave) ProtoMessage 

func (*ControlIHave) ProtoMessage()

func (*ControlIHave) Reset 

func (m *ControlIHave) Reset()

func (*ControlIHave) Size 

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

func (*ControlIHave) String 

func (m *ControlIHave) String() string

func (*ControlIHave) Unmarshal 

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

func (*ControlIHave) XXX_DiscardUnknown 

func (m *ControlIHave) XXX_DiscardUnknown()

func (*ControlIHave) XXX_Marshal 

func (m *ControlIHave) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControlIHave) XXX_Merge 

func (m *ControlIHave) XXX_Merge(src proto.Message)

func (*ControlIHave) XXX_Size 

func (m *ControlIHave) XXX_Size() int

func (*ControlIHave) XXX_Unmarshal 

func (m *ControlIHave) XXX_Unmarshal(b []byte) error

type ControlIWant 

type ControlIWant struct {
	MessageIDs           []string `protobuf:"bytes,1,rep,name=messageIDs" json:"messageIDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ControlIWant) Descriptor 

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

func (*ControlIWant) GetMessageIDs 

func (m *ControlIWant) GetMessageIDs() []string

func (*ControlIWant) Marshal 

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

func (*ControlIWant) MarshalTo 

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

func (*ControlIWant) ProtoMessage 

func (*ControlIWant) ProtoMessage()

func (*ControlIWant) Reset 

func (m *ControlIWant) Reset()

func (*ControlIWant) Size 

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

func (*ControlIWant) String 

func (m *ControlIWant) String() string

func (*ControlIWant) Unmarshal 

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

func (*ControlIWant) XXX_DiscardUnknown 

func (m *ControlIWant) XXX_DiscardUnknown()

func (*ControlIWant) XXX_Marshal 

func (m *ControlIWant) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControlIWant) XXX_Merge 

func (m *ControlIWant) XXX_Merge(src proto.Message)

func (*ControlIWant) XXX_Size 

func (m *ControlIWant) XXX_Size() int

func (*ControlIWant) XXX_Unmarshal 

func (m *ControlIWant) XXX_Unmarshal(b []byte) error

type ControlMessage 

type ControlMessage struct {
	Ihave                []*ControlIHave `protobuf:"bytes,1,rep,name=ihave" json:"ihave,omitempty"`
	Iwant                []*ControlIWant `protobuf:"bytes,2,rep,name=iwant" json:"iwant,omitempty"`
	Graft                []*ControlGraft `protobuf:"bytes,3,rep,name=graft" json:"graft,omitempty"`
	Prune                []*ControlPrune `protobuf:"bytes,4,rep,name=prune" json:"prune,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ControlMessage) Descriptor 

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

func (*ControlMessage) GetGraft 

func (m *ControlMessage) GetGraft() []*ControlGraft

func (*ControlMessage) GetIhave 

func (m *ControlMessage) GetIhave() []*ControlIHave

func (*ControlMessage) GetIwant 

func (m *ControlMessage) GetIwant() []*ControlIWant

func (*ControlMessage) GetPrune 

func (m *ControlMessage) GetPrune() []*ControlPrune

func (*ControlMessage) Marshal 

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

func (*ControlMessage) MarshalTo 

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

func (*ControlMessage) ProtoMessage 

func (*ControlMessage) ProtoMessage()

func (*ControlMessage) Reset 

func (m *ControlMessage) Reset()

func (*ControlMessage) Size 

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

func (*ControlMessage) String 

func (m *ControlMessage) String() string

func (*ControlMessage) Unmarshal 

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

func (*ControlMessage) XXX_DiscardUnknown 

func (m *ControlMessage) XXX_DiscardUnknown()

func (*ControlMessage) XXX_Marshal 

func (m *ControlMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControlMessage) XXX_Merge 

func (m *ControlMessage) XXX_Merge(src proto.Message)

func (*ControlMessage) XXX_Size 

func (m *ControlMessage) XXX_Size() int

func (*ControlMessage) XXX_Unmarshal 

func (m *ControlMessage) XXX_Unmarshal(b []byte) error

type ControlPrune 

type ControlPrune struct {
	TopicID              *string  `protobuf:"bytes,1,opt,name=topicID" json:"topicID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ControlPrune) Descriptor 

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

func (*ControlPrune) GetTopicID 

func (m *ControlPrune) GetTopicID() string

func (*ControlPrune) Marshal 

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

func (*ControlPrune) MarshalTo 

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

func (*ControlPrune) ProtoMessage 

func (*ControlPrune) ProtoMessage()

func (*ControlPrune) Reset 

func (m *ControlPrune) Reset()

func (*ControlPrune) Size 

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

func (*ControlPrune) String 

func (m *ControlPrune) String() string

func (*ControlPrune) Unmarshal 

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

func (*ControlPrune) XXX_DiscardUnknown 

func (m *ControlPrune) XXX_DiscardUnknown()

func (*ControlPrune) XXX_Marshal 

func (m *ControlPrune) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControlPrune) XXX_Merge 

func (m *ControlPrune) XXX_Merge(src proto.Message)

func (*ControlPrune) XXX_Size 

func (m *ControlPrune) XXX_Size() int

func (*ControlPrune) XXX_Unmarshal 

func (m *ControlPrune) XXX_Unmarshal(b []byte) error

type Message 

type Message struct {
	From                 []byte   `protobuf:"bytes,1,opt,name=from" json:"from,omitempty"`
	Data                 []byte   `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
	Seqno                []byte   `protobuf:"bytes,3,opt,name=seqno" json:"seqno,omitempty"`
	TopicIDs             []string `protobuf:"bytes,4,rep,name=topicIDs" json:"topicIDs,omitempty"`
	Signature            []byte   `protobuf:"bytes,5,opt,name=signature" json:"signature,omitempty"`
	Key                  []byte   `protobuf:"bytes,6,opt,name=key" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Message) Descriptor 

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

func (*Message) GetData 

func (m *Message) GetData() []byte

func (*Message) GetFrom 

func (m *Message) GetFrom() []byte

func (*Message) GetKey 

func (m *Message) GetKey() []byte

func (*Message) GetSeqno 

func (m *Message) GetSeqno() []byte

func (*Message) GetSignature 

func (m *Message) GetSignature() []byte

func (*Message) GetTopicIDs 

func (m *Message) GetTopicIDs() []string

func (*Message) Marshal 

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

func (*Message) MarshalTo 

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

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) Size 

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

func (*Message) String 

func (m *Message) String() string

func (*Message) Unmarshal 

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

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Message) XXX_Merge 

func (m *Message) XXX_Merge(src proto.Message)

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

func (m *Message) XXX_Unmarshal(b []byte) error

type RPC 

type RPC struct {
	Subscriptions        []*RPC_SubOpts  `protobuf:"bytes,1,rep,name=subscriptions" json:"subscriptions,omitempty"`
	Publish              []*Message      `protobuf:"bytes,2,rep,name=publish" json:"publish,omitempty"`
	Control              *ControlMessage `protobuf:"bytes,3,opt,name=control" json:"control,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*RPC) Descriptor 

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

func (*RPC) GetControl 

func (m *RPC) GetControl() *ControlMessage

func (*RPC) GetPublish 

func (m *RPC) GetPublish() []*Message

func (*RPC) GetSubscriptions 

func (m *RPC) GetSubscriptions() []*RPC_SubOpts

func (*RPC) Marshal 

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

func (*RPC) MarshalTo 

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

func (*RPC) ProtoMessage 

func (*RPC) ProtoMessage()

func (*RPC) Reset 

func (m *RPC) Reset()

func (*RPC) Size 

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

func (*RPC) String 

func (m *RPC) String() string

func (*RPC) Unmarshal 

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

func (*RPC) XXX_DiscardUnknown 

func (m *RPC) XXX_DiscardUnknown()

func (*RPC) XXX_Marshal 

func (m *RPC) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RPC) XXX_Merge 

func (m *RPC) XXX_Merge(src proto.Message)

func (*RPC) XXX_Size 

func (m *RPC) XXX_Size() int

func (*RPC) XXX_Unmarshal 

func (m *RPC) XXX_Unmarshal(b []byte) error

type RPC_SubOpts 

type RPC_SubOpts struct {
	Subscribe            *bool    `protobuf:"varint,1,opt,name=subscribe" json:"subscribe,omitempty"`
	Topicid              *string  `protobuf:"bytes,2,opt,name=topicid" json:"topicid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RPC_SubOpts) Descriptor 

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

func (*RPC_SubOpts) GetSubscribe 

func (m *RPC_SubOpts) GetSubscribe() bool

func (*RPC_SubOpts) GetTopicid 

func (m *RPC_SubOpts) GetTopicid() string

func (*RPC_SubOpts) Marshal 

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

func (*RPC_SubOpts) MarshalTo 

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

func (*RPC_SubOpts) ProtoMessage 

func (*RPC_SubOpts) ProtoMessage()

func (*RPC_SubOpts) Reset 

func (m *RPC_SubOpts) Reset()

func (*RPC_SubOpts) Size 

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

func (*RPC_SubOpts) String 

func (m *RPC_SubOpts) String() string

func (*RPC_SubOpts) Unmarshal 

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

func (*RPC_SubOpts) XXX_DiscardUnknown 

func (m *RPC_SubOpts) XXX_DiscardUnknown()

func (*RPC_SubOpts) XXX_Marshal 

func (m *RPC_SubOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RPC_SubOpts) XXX_Merge 

func (m *RPC_SubOpts) XXX_Merge(src proto.Message)

func (*RPC_SubOpts) XXX_Size 

func (m *RPC_SubOpts) XXX_Size() int

func (*RPC_SubOpts) XXX_Unmarshal 

func (m *RPC_SubOpts) XXX_Unmarshal(b []byte) error

type TopicDescriptor 

type TopicDescriptor struct {
	Name                 *string                   `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Auth                 *TopicDescriptor_AuthOpts `protobuf:"bytes,2,opt,name=auth" json:"auth,omitempty"`
	Enc                  *TopicDescriptor_EncOpts  `protobuf:"bytes,3,opt,name=enc" json:"enc,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*TopicDescriptor) Descriptor 

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

func (*TopicDescriptor) GetAuth 

func (m *TopicDescriptor) GetAuth() *TopicDescriptor_AuthOpts

func (*TopicDescriptor) GetEnc 

func (m *TopicDescriptor) GetEnc() *TopicDescriptor_EncOpts

func (*TopicDescriptor) GetName 

func (m *TopicDescriptor) GetName() string

func (*TopicDescriptor) Marshal 

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

func (*TopicDescriptor) MarshalTo 

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

func (*TopicDescriptor) ProtoMessage 

func (*TopicDescriptor) ProtoMessage()

func (*TopicDescriptor) Reset 

func (m *TopicDescriptor) Reset()

func (*TopicDescriptor) Size 

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

func (*TopicDescriptor) String 

func (m *TopicDescriptor) String() string

func (*TopicDescriptor) Unmarshal 

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

func (*TopicDescriptor) XXX_DiscardUnknown 

func (m *TopicDescriptor) XXX_DiscardUnknown()

func (*TopicDescriptor) XXX_Marshal 

func (m *TopicDescriptor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TopicDescriptor) XXX_Merge 

func (m *TopicDescriptor) XXX_Merge(src proto.Message)

func (*TopicDescriptor) XXX_Size 

func (m *TopicDescriptor) XXX_Size() int

func (*TopicDescriptor) XXX_Unmarshal 

func (m *TopicDescriptor) XXX_Unmarshal(b []byte) error

type TopicDescriptor_AuthOpts 

type TopicDescriptor_AuthOpts struct {
	Mode                 *TopicDescriptor_AuthOpts_AuthMode `protobuf:"varint,1,opt,name=mode,enum=pubsub.pb.TopicDescriptor_AuthOpts_AuthMode" json:"mode,omitempty"`
	Keys                 [][]byte                           `protobuf:"bytes,2,rep,name=keys" json:"keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

func (*TopicDescriptor_AuthOpts) Descriptor 

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

func (*TopicDescriptor_AuthOpts) GetKeys 

func (m *TopicDescriptor_AuthOpts) GetKeys() [][]byte

func (*TopicDescriptor_AuthOpts) GetMode 

func (m *TopicDescriptor_AuthOpts) GetMode() TopicDescriptor_AuthOpts_AuthMode

func (*TopicDescriptor_AuthOpts) Marshal 

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

func (*TopicDescriptor_AuthOpts) MarshalTo 

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

func (*TopicDescriptor_AuthOpts) ProtoMessage 

func (*TopicDescriptor_AuthOpts) ProtoMessage()

func (*TopicDescriptor_AuthOpts) Reset 

func (m *TopicDescriptor_AuthOpts) Reset()

func (*TopicDescriptor_AuthOpts) Size 

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

func (*TopicDescriptor_AuthOpts) String 

func (m *TopicDescriptor_AuthOpts) String() string

func (*TopicDescriptor_AuthOpts) Unmarshal 

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

func (*TopicDescriptor_AuthOpts) XXX_DiscardUnknown 

func (m *TopicDescriptor_AuthOpts) XXX_DiscardUnknown()

func (*TopicDescriptor_AuthOpts) XXX_Marshal 

func (m *TopicDescriptor_AuthOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TopicDescriptor_AuthOpts) XXX_Merge 

func (m *TopicDescriptor_AuthOpts) XXX_Merge(src proto.Message)

func (*TopicDescriptor_AuthOpts) XXX_Size 

func (m *TopicDescriptor_AuthOpts) XXX_Size() int

func (*TopicDescriptor_AuthOpts) XXX_Unmarshal 

func (m *TopicDescriptor_AuthOpts) XXX_Unmarshal(b []byte) error

type TopicDescriptor_AuthOpts_AuthMode 

type TopicDescriptor_AuthOpts_AuthMode int32
const (
	TopicDescriptor_AuthOpts_NONE TopicDescriptor_AuthOpts_AuthMode = 0
	TopicDescriptor_AuthOpts_KEY  TopicDescriptor_AuthOpts_AuthMode = 1
	TopicDescriptor_AuthOpts_WOT  TopicDescriptor_AuthOpts_AuthMode = 2
)

func (TopicDescriptor_AuthOpts_AuthMode) Enum 

func (x TopicDescriptor_AuthOpts_AuthMode) Enum() *TopicDescriptor_AuthOpts_AuthMode

func (TopicDescriptor_AuthOpts_AuthMode) EnumDescriptor 

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

func (TopicDescriptor_AuthOpts_AuthMode) String 

func (x TopicDescriptor_AuthOpts_AuthMode) String() string

func (*TopicDescriptor_AuthOpts_AuthMode) UnmarshalJSON 

func (x *TopicDescriptor_AuthOpts_AuthMode) UnmarshalJSON(data []byte) error

type TopicDescriptor_EncOpts 

type TopicDescriptor_EncOpts struct {
	Mode                 *TopicDescriptor_EncOpts_EncMode `protobuf:"varint,1,opt,name=mode,enum=pubsub.pb.TopicDescriptor_EncOpts_EncMode" json:"mode,omitempty"`
	KeyHashes            [][]byte                         `protobuf:"bytes,2,rep,name=keyHashes" json:"keyHashes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*TopicDescriptor_EncOpts) Descriptor 

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

func (*TopicDescriptor_EncOpts) GetKeyHashes 

func (m *TopicDescriptor_EncOpts) GetKeyHashes() [][]byte

func (*TopicDescriptor_EncOpts) GetMode 

func (m *TopicDescriptor_EncOpts) GetMode() TopicDescriptor_EncOpts_EncMode

func (*TopicDescriptor_EncOpts) Marshal 

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

func (*TopicDescriptor_EncOpts) MarshalTo 

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

func (*TopicDescriptor_EncOpts) ProtoMessage 

func (*TopicDescriptor_EncOpts) ProtoMessage()

func (*TopicDescriptor_EncOpts) Reset 

func (m *TopicDescriptor_EncOpts) Reset()

func (*TopicDescriptor_EncOpts) Size 

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

func (*TopicDescriptor_EncOpts) String 

func (m *TopicDescriptor_EncOpts) String() string

func (*TopicDescriptor_EncOpts) Unmarshal 

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

func (*TopicDescriptor_EncOpts) XXX_DiscardUnknown 

func (m *TopicDescriptor_EncOpts) XXX_DiscardUnknown()

func (*TopicDescriptor_EncOpts) XXX_Marshal 

func (m *TopicDescriptor_EncOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TopicDescriptor_EncOpts) XXX_Merge 

func (m *TopicDescriptor_EncOpts) XXX_Merge(src proto.Message)

func (*TopicDescriptor_EncOpts) XXX_Size 

func (m *TopicDescriptor_EncOpts) XXX_Size() int

func (*TopicDescriptor_EncOpts) XXX_Unmarshal 

func (m *TopicDescriptor_EncOpts) XXX_Unmarshal(b []byte) error

type TopicDescriptor_EncOpts_EncMode 

type TopicDescriptor_EncOpts_EncMode int32
const (
	TopicDescriptor_EncOpts_NONE      TopicDescriptor_EncOpts_EncMode = 0
	TopicDescriptor_EncOpts_SHAREDKEY TopicDescriptor_EncOpts_EncMode = 1
	TopicDescriptor_EncOpts_WOT       TopicDescriptor_EncOpts_EncMode = 2
)

func (TopicDescriptor_EncOpts_EncMode) Enum 

func (x TopicDescriptor_EncOpts_EncMode) Enum() *TopicDescriptor_EncOpts_EncMode

func (TopicDescriptor_EncOpts_EncMode) EnumDescriptor 

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

func (TopicDescriptor_EncOpts_EncMode) String 

func (x TopicDescriptor_EncOpts_EncMode) String() string

func (*TopicDescriptor_EncOpts_EncMode) UnmarshalJSON 

func (x *TopicDescriptor_EncOpts_EncMode) UnmarshalJSON(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.