floodsub_pb

package
v1.7.1 Latest Latest
Warning

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

 Go to latest Published: Jan 29, 2021 License: MIT Imports: 3 Imported by: 0

Documentation

Overview

Package floodsub_pb is a generated protocol buffer package.

It is generated from these files: 

rpc.proto

It has these top-level messages: 

RPC
Message
TopicDescriptor

Index

Constants

This section is empty.

Variables

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 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"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*Message) GetData 

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

func (*Message) GetFrom 

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

func (*Message) GetSeqno 

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

func (*Message) GetTopicIDs 

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

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) String 

func (m *Message) String() string

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"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*RPC) GetPublish 

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

func (*RPC) GetSubscriptions 

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

func (*RPC) ProtoMessage 

func (*RPC) ProtoMessage()

func (*RPC) Reset 

func (m *RPC) Reset()

func (*RPC) String 

func (m *RPC) String() string

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_unrecognized []byte  `json:"-"`
}

func (*RPC_SubOpts) GetSubscribe 

func (m *RPC_SubOpts) GetSubscribe() bool

func (*RPC_SubOpts) GetTopicid 

func (m *RPC_SubOpts) GetTopicid() string

func (*RPC_SubOpts) ProtoMessage 

func (*RPC_SubOpts) ProtoMessage()

func (*RPC_SubOpts) Reset 

func (m *RPC_SubOpts) Reset()

func (*RPC_SubOpts) String 

func (m *RPC_SubOpts) String() string

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_unrecognized []byte                    `json:"-"`
}

topicID = hash(topicDescriptor); (not the topic.name)

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

func (*TopicDescriptor) ProtoMessage()

func (*TopicDescriptor) Reset 

func (m *TopicDescriptor) Reset()

func (*TopicDescriptor) String 

func (m *TopicDescriptor) String() string

type TopicDescriptor_AuthOpts 

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

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

func (*TopicDescriptor_AuthOpts) ProtoMessage()

func (*TopicDescriptor_AuthOpts) Reset 

func (m *TopicDescriptor_AuthOpts) Reset()

func (*TopicDescriptor_AuthOpts) String 

func (m *TopicDescriptor_AuthOpts) String() string

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) 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=floodsub.pb.TopicDescriptor_EncOpts_EncMode" json:"mode,omitempty"`
	KeyHashes        [][]byte                         `protobuf:"bytes,2,rep,name=keyHashes" json:"keyHashes,omitempty"`
	XXX_unrecognized []byte                           `json:"-"`
}

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

func (*TopicDescriptor_EncOpts) ProtoMessage()

func (*TopicDescriptor_EncOpts) Reset 

func (m *TopicDescriptor_EncOpts) Reset()

func (*TopicDescriptor_EncOpts) String 

func (m *TopicDescriptor_EncOpts) String() string

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