proto

package
v0.0.0-...-3cd268a Latest Latest
Warning

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

 Go to latest Published: Dec 17, 2024 License: MIT Imports: 4 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_client_proto protoreflect.FileDescriptor
View Source 
var File_subtree_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type DeleteKeyRequest 

type DeleteKeyRequest struct {
	Key string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteKeyRequest) Descriptor deprecated 

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

Deprecated: Use DeleteKeyRequest.ProtoReflect.Descriptor instead.

func (*DeleteKeyRequest) GetKey 

func (x *DeleteKeyRequest) GetKey() string

func (*DeleteKeyRequest) ProtoMessage 

func (*DeleteKeyRequest) ProtoMessage()

func (*DeleteKeyRequest) ProtoReflect 

func (x *DeleteKeyRequest) ProtoReflect() protoreflect.Message

func (*DeleteKeyRequest) Reset 

func (x *DeleteKeyRequest) Reset()

func (*DeleteKeyRequest) String 

func (x *DeleteKeyRequest) String() string

type DeleteKeyResponse 

type DeleteKeyResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteKeyResponse) Descriptor deprecated 

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

Deprecated: Use DeleteKeyResponse.ProtoReflect.Descriptor instead.

func (*DeleteKeyResponse) GetMessage 

func (x *DeleteKeyResponse) GetMessage() string

func (*DeleteKeyResponse) GetSuccess 

func (x *DeleteKeyResponse) GetSuccess() bool

func (*DeleteKeyResponse) ProtoMessage 

func (*DeleteKeyResponse) ProtoMessage()

func (*DeleteKeyResponse) ProtoReflect 

func (x *DeleteKeyResponse) ProtoReflect() protoreflect.Message

func (*DeleteKeyResponse) Reset 

func (x *DeleteKeyResponse) Reset()

func (*DeleteKeyResponse) String 

func (x *DeleteKeyResponse) String() string

type DeleteKeysRequest 

type DeleteKeysRequest struct {
	Keys []string `protobuf:"bytes,1,rep,name=Keys,proto3" json:"Keys,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteKeysRequest) Descriptor deprecated 

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

Deprecated: Use DeleteKeysRequest.ProtoReflect.Descriptor instead.

func (*DeleteKeysRequest) GetKeys 

func (x *DeleteKeysRequest) GetKeys() []string

func (*DeleteKeysRequest) ProtoMessage 

func (*DeleteKeysRequest) ProtoMessage()

func (*DeleteKeysRequest) ProtoReflect 

func (x *DeleteKeysRequest) ProtoReflect() protoreflect.Message

func (*DeleteKeysRequest) Reset 

func (x *DeleteKeysRequest) Reset()

func (*DeleteKeysRequest) String 

func (x *DeleteKeysRequest) String() string

type DeleteKeysResponse 

type DeleteKeysResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteKeysResponse) Descriptor deprecated 

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

Deprecated: Use DeleteKeysResponse.ProtoReflect.Descriptor instead.

func (*DeleteKeysResponse) GetMessage 

func (x *DeleteKeysResponse) GetMessage() string

func (*DeleteKeysResponse) GetSuccess 

func (x *DeleteKeysResponse) GetSuccess() bool

func (*DeleteKeysResponse) ProtoMessage 

func (*DeleteKeysResponse) ProtoMessage()

func (*DeleteKeysResponse) ProtoReflect 

func (x *DeleteKeysResponse) ProtoReflect() protoreflect.Message

func (*DeleteKeysResponse) Reset 

func (x *DeleteKeysResponse) Reset()

func (*DeleteKeysResponse) String 

func (x *DeleteKeysResponse) String() string

type Node 

type Node struct {
	Key       string           `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`         // topic section
	FullKey   string           `protobuf:"bytes,2,opt,name=FullKey,proto3" json:"FullKey,omitempty"` // full topic
	Value     string           `protobuf:"bytes,3,opt,name=Value,proto3" json:"Value,omitempty"`
	ChildNode map[string]*Node `` // child tree
	/* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Node) Descriptor deprecated 

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetChildNode 

func (x *Node) GetChildNode() map[string]*Node

func (*Node) GetFullKey 

func (x *Node) GetFullKey() string

func (*Node) GetKey 

func (x *Node) GetKey() string

func (*Node) GetValue 

func (x *Node) GetValue() string

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

func (x *Node) ProtoReflect() protoreflect.Message

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

type PutKeyRequest 

type PutKeyRequest struct {
	Key   string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	// contains filtered or unexported fields
}

func (*PutKeyRequest) Descriptor deprecated 

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

Deprecated: Use PutKeyRequest.ProtoReflect.Descriptor instead.

func (*PutKeyRequest) GetKey 

func (x *PutKeyRequest) GetKey() string

func (*PutKeyRequest) GetValue 

func (x *PutKeyRequest) GetValue() string

func (*PutKeyRequest) ProtoMessage 

func (*PutKeyRequest) ProtoMessage()

func (*PutKeyRequest) ProtoReflect 

func (x *PutKeyRequest) ProtoReflect() protoreflect.Message

func (*PutKeyRequest) Reset 

func (x *PutKeyRequest) Reset()

func (*PutKeyRequest) String 

func (x *PutKeyRequest) String() string

type PutKeyResponse 

type PutKeyResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	// contains filtered or unexported fields
}

func (*PutKeyResponse) Descriptor deprecated 

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

Deprecated: Use PutKeyResponse.ProtoReflect.Descriptor instead.

func (*PutKeyResponse) GetMessage 

func (x *PutKeyResponse) GetMessage() string

func (*PutKeyResponse) GetSuccess 

func (x *PutKeyResponse) GetSuccess() bool

func (*PutKeyResponse) ProtoMessage 

func (*PutKeyResponse) ProtoMessage()

func (*PutKeyResponse) ProtoReflect 

func (x *PutKeyResponse) ProtoReflect() protoreflect.Message

func (*PutKeyResponse) Reset 

func (x *PutKeyResponse) Reset()

func (*PutKeyResponse) String 

func (x *PutKeyResponse) String() string

type PutKeysRequest 

type PutKeysRequest struct {
	Value map[string]string `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PutKeysRequest) Descriptor deprecated 

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

Deprecated: Use PutKeysRequest.ProtoReflect.Descriptor instead.

func (*PutKeysRequest) GetValue 

func (x *PutKeysRequest) GetValue() map[string]string

func (*PutKeysRequest) ProtoMessage 

func (*PutKeysRequest) ProtoMessage()

func (*PutKeysRequest) ProtoReflect 

func (x *PutKeysRequest) ProtoReflect() protoreflect.Message

func (*PutKeysRequest) Reset 

func (x *PutKeysRequest) Reset()

func (*PutKeysRequest) String 

func (x *PutKeysRequest) String() string

type PutKeysResponse 

type PutKeysResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	// contains filtered or unexported fields
}

func (*PutKeysResponse) Descriptor deprecated 

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

Deprecated: Use PutKeysResponse.ProtoReflect.Descriptor instead.

func (*PutKeysResponse) GetMessage 

func (x *PutKeysResponse) GetMessage() string

func (*PutKeysResponse) GetSuccess 

func (x *PutKeysResponse) GetSuccess() bool

func (*PutKeysResponse) ProtoMessage 

func (*PutKeysResponse) ProtoMessage()

func (*PutKeysResponse) ProtoReflect 

func (x *PutKeysResponse) ProtoReflect() protoreflect.Message

func (*PutKeysResponse) Reset 

func (x *PutKeysResponse) Reset()

func (*PutKeysResponse) String 

func (x *PutKeysResponse) String() string

type ReadKeyRequest 

type ReadKeyRequest struct {
	Key string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadKeyRequest) Descriptor deprecated 

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

Deprecated: Use ReadKeyRequest.ProtoReflect.Descriptor instead.

func (*ReadKeyRequest) GetKey 

func (x *ReadKeyRequest) GetKey() string

func (*ReadKeyRequest) ProtoMessage 

func (*ReadKeyRequest) ProtoMessage()

func (*ReadKeyRequest) ProtoReflect 

func (x *ReadKeyRequest) ProtoReflect() protoreflect.Message

func (*ReadKeyRequest) Reset 

func (x *ReadKeyRequest) Reset()

func (*ReadKeyRequest) String 

func (x *ReadKeyRequest) String() string

type ReadKeyResponse 

type ReadKeyResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	Value   string `protobuf:"bytes,3,opt,name=Value,proto3" json:"Value,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadKeyResponse) Descriptor deprecated 

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

Deprecated: Use ReadKeyResponse.ProtoReflect.Descriptor instead.

func (*ReadKeyResponse) GetMessage 

func (x *ReadKeyResponse) GetMessage() string

func (*ReadKeyResponse) GetSuccess 

func (x *ReadKeyResponse) GetSuccess() bool

func (*ReadKeyResponse) GetValue 

func (x *ReadKeyResponse) GetValue() string

func (*ReadKeyResponse) ProtoMessage 

func (*ReadKeyResponse) ProtoMessage()

func (*ReadKeyResponse) ProtoReflect 

func (x *ReadKeyResponse) ProtoReflect() protoreflect.Message

func (*ReadKeyResponse) Reset 

func (x *ReadKeyResponse) Reset()

func (*ReadKeyResponse) String 

func (x *ReadKeyResponse) String() string

type ReadKeysRequest 

type ReadKeysRequest struct {
	Key []string `protobuf:"bytes,1,rep,name=Key,proto3" json:"Key,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadKeysRequest) Descriptor deprecated 

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

Deprecated: Use ReadKeysRequest.ProtoReflect.Descriptor instead.

func (*ReadKeysRequest) GetKey 

func (x *ReadKeysRequest) GetKey() []string

func (*ReadKeysRequest) ProtoMessage 

func (*ReadKeysRequest) ProtoMessage()

func (*ReadKeysRequest) ProtoReflect 

func (x *ReadKeysRequest) ProtoReflect() protoreflect.Message

func (*ReadKeysRequest) Reset 

func (x *ReadKeysRequest) Reset()

func (*ReadKeysRequest) String 

func (x *ReadKeysRequest) String() string

type ReadKeysResponse 

type ReadKeysResponse struct {
	Success bool              `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	Message string            `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	Value   map[string]string `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ReadKeysResponse) Descriptor deprecated 

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

Deprecated: Use ReadKeysResponse.ProtoReflect.Descriptor instead.

func (*ReadKeysResponse) GetMessage 

func (x *ReadKeysResponse) GetMessage() string

func (*ReadKeysResponse) GetSuccess 

func (x *ReadKeysResponse) GetSuccess() bool

func (*ReadKeysResponse) GetValue 

func (x *ReadKeysResponse) GetValue() map[string]string

func (*ReadKeysResponse) ProtoMessage 

func (*ReadKeysResponse) ProtoMessage()

func (*ReadKeysResponse) ProtoReflect 

func (x *ReadKeysResponse) ProtoReflect() protoreflect.Message

func (*ReadKeysResponse) Reset 

func (x *ReadKeysResponse) Reset()

func (*ReadKeysResponse) String 

func (x *ReadKeysResponse) String() string

type ReadPrefixKeyRequest 

type ReadPrefixKeyRequest struct {
	Prefix string `protobuf:"bytes,2,opt,name=Prefix,proto3" json:"Prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadPrefixKeyRequest) Descriptor deprecated 

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

Deprecated: Use ReadPrefixKeyRequest.ProtoReflect.Descriptor instead.

func (*ReadPrefixKeyRequest) GetPrefix 

func (x *ReadPrefixKeyRequest) GetPrefix() string

func (*ReadPrefixKeyRequest) ProtoMessage 

func (*ReadPrefixKeyRequest) ProtoMessage()

func (*ReadPrefixKeyRequest) ProtoReflect 

func (x *ReadPrefixKeyRequest) ProtoReflect() protoreflect.Message

func (*ReadPrefixKeyRequest) Reset 

func (x *ReadPrefixKeyRequest) Reset()

func (*ReadPrefixKeyRequest) String 

func (x *ReadPrefixKeyRequest) String() string

type ReadPrefixKeyResponse 

type ReadPrefixKeyResponse struct {
	Success bool              `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	Message string            `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	Value   map[string]string `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ReadPrefixKeyResponse) Descriptor deprecated 

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

Deprecated: Use ReadPrefixKeyResponse.ProtoReflect.Descriptor instead.

func (*ReadPrefixKeyResponse) GetMessage 

func (x *ReadPrefixKeyResponse) GetMessage() string

func (*ReadPrefixKeyResponse) GetSuccess 

func (x *ReadPrefixKeyResponse) GetSuccess() bool

func (*ReadPrefixKeyResponse) GetValue 

func (x *ReadPrefixKeyResponse) GetValue() map[string]string

func (*ReadPrefixKeyResponse) ProtoMessage 

func (*ReadPrefixKeyResponse) ProtoMessage()

func (*ReadPrefixKeyResponse) ProtoReflect 

func (x *ReadPrefixKeyResponse) ProtoReflect() protoreflect.Message

func (*ReadPrefixKeyResponse) Reset 

func (x *ReadPrefixKeyResponse) Reset()

func (*ReadPrefixKeyResponse) String 

func (x *ReadPrefixKeyResponse) String() string

type ShareGroup 

type ShareGroup struct {
	GroupName string                `protobuf:"bytes,1,opt,name=GroupName,proto3" json:"GroupName,omitempty"`
	Client    map[string]*SubOption `` // key is clientID, value is subOption
	/* 153-byte string literal not displayed */
	Topic string `protobuf:"bytes,3,opt,name=Topic,proto3" json:"Topic,omitempty"`
	// contains filtered or unexported fields
}

func (*ShareGroup) Descriptor deprecated 

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

Deprecated: Use ShareGroup.ProtoReflect.Descriptor instead.

func (*ShareGroup) GetClient 

func (x *ShareGroup) GetClient() map[string]*SubOption

func (*ShareGroup) GetGroupName 

func (x *ShareGroup) GetGroupName() string

func (*ShareGroup) GetTopic 

func (x *ShareGroup) GetTopic() string

func (*ShareGroup) ProtoMessage 

func (*ShareGroup) ProtoMessage()

func (*ShareGroup) ProtoReflect 

func (x *ShareGroup) ProtoReflect() protoreflect.Message

func (*ShareGroup) Reset 

func (x *ShareGroup) Reset()

func (*ShareGroup) String 

func (x *ShareGroup) String() string

type ShareTopicSubTree 

type ShareTopicSubTree struct {
	Hash map[string]*ShareTopicTopicGroup `` // key is topic
	/* 149-byte string literal not displayed */
	TreeRoot *ShareTreeNode `protobuf:"bytes,2,opt,name=TreeRoot,proto3" json:"TreeRoot,omitempty"`
	// contains filtered or unexported fields
}

func (*ShareTopicSubTree) Descriptor deprecated 

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

Deprecated: Use ShareTopicSubTree.ProtoReflect.Descriptor instead.

func (*ShareTopicSubTree) GetHash 

func (x *ShareTopicSubTree) GetHash() map[string]*ShareTopicTopicGroup

func (*ShareTopicSubTree) GetTreeRoot 

func (x *ShareTopicSubTree) GetTreeRoot() *ShareTreeNode

func (*ShareTopicSubTree) ProtoMessage 

func (*ShareTopicSubTree) ProtoMessage()

func (*ShareTopicSubTree) ProtoReflect 

func (x *ShareTopicSubTree) ProtoReflect() protoreflect.Message

func (*ShareTopicSubTree) Reset 

func (x *ShareTopicSubTree) Reset()

func (*ShareTopicSubTree) String 

func (x *ShareTopicSubTree) String() string

type ShareTopicTopicGroup 

type ShareTopicTopicGroup struct {
	Topic       string                 `protobuf:"bytes,1,opt,name=Topic,proto3" json:"Topic,omitempty"`
	ShareGroups map[string]*ShareGroup `` // key is share group name
	/* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ShareTopicTopicGroup) Descriptor deprecated 

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

Deprecated: Use ShareTopicTopicGroup.ProtoReflect.Descriptor instead.

func (*ShareTopicTopicGroup) GetShareGroups 

func (x *ShareTopicTopicGroup) GetShareGroups() map[string]*ShareGroup

func (*ShareTopicTopicGroup) GetTopic 

func (x *ShareTopicTopicGroup) GetTopic() string

func (*ShareTopicTopicGroup) ProtoMessage 

func (*ShareTopicTopicGroup) ProtoMessage()

func (*ShareTopicTopicGroup) ProtoReflect 

func (x *ShareTopicTopicGroup) ProtoReflect() protoreflect.Message

func (*ShareTopicTopicGroup) Reset 

func (x *ShareTopicTopicGroup) Reset()

func (*ShareTopicTopicGroup) String 

func (x *ShareTopicTopicGroup) String() string

type ShareTreeNode 

type ShareTreeNode struct {
	TopicSection string                 `protobuf:"bytes,1,opt,name=TopicSection,proto3" json:"TopicSection,omitempty"` // topic section
	Topic        string                 `protobuf:"bytes,2,opt,name=Topic,proto3" json:"Topic,omitempty"`               // full topic
	TopicGroup   map[string]*ShareGroup ``                                                                              // sub clients, key is share group name, value is share group
	/* 161-byte string literal not displayed */
	ChildNode map[string]*ShareTreeNode `` // child tree
	/* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ShareTreeNode) Descriptor deprecated 

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

Deprecated: Use ShareTreeNode.ProtoReflect.Descriptor instead.

func (*ShareTreeNode) GetChildNode 

func (x *ShareTreeNode) GetChildNode() map[string]*ShareTreeNode

func (*ShareTreeNode) GetTopic 

func (x *ShareTreeNode) GetTopic() string

func (*ShareTreeNode) GetTopicGroup 

func (x *ShareTreeNode) GetTopicGroup() map[string]*ShareGroup

func (*ShareTreeNode) GetTopicSection 

func (x *ShareTreeNode) GetTopicSection() string

func (*ShareTreeNode) ProtoMessage 

func (*ShareTreeNode) ProtoMessage()

func (*ShareTreeNode) ProtoReflect 

func (x *ShareTreeNode) ProtoReflect() protoreflect.Message

func (*ShareTreeNode) Reset 

func (x *ShareTreeNode) Reset()

func (*ShareTreeNode) String 

func (x *ShareTreeNode) String() string

type SubOption 

type SubOption struct {
	QoS               int32  `protobuf:"varint,1,opt,name=QoS,proto3" json:"QoS,omitempty"`
	NoLocal           bool   `protobuf:"varint,2,opt,name=NoLocal,proto3" json:"NoLocal,omitempty"`
	RetainAsPublished bool   `protobuf:"varint,3,opt,name=RetainAsPublished,proto3" json:"RetainAsPublished,omitempty"`
	Share             bool   `protobuf:"varint,4,opt,name=Share,proto3" json:"Share,omitempty"`
	ShareGroup        string `protobuf:"bytes,5,opt,name=ShareGroup,proto3" json:"ShareGroup,omitempty"`
	Topic             string `protobuf:"bytes,6,opt,name=Topic,proto3" json:"Topic,omitempty"`
	// contains filtered or unexported fields
}

func (*SubOption) Descriptor deprecated 

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

Deprecated: Use SubOption.ProtoReflect.Descriptor instead.

func (*SubOption) GetNoLocal 

func (x *SubOption) GetNoLocal() bool

func (*SubOption) GetQoS 

func (x *SubOption) GetQoS() int32

func (*SubOption) GetRetainAsPublished 

func (x *SubOption) GetRetainAsPublished() bool

func (*SubOption) GetShare 

func (x *SubOption) GetShare() bool

func (*SubOption) GetShareGroup 

func (x *SubOption) GetShareGroup() string

func (*SubOption) GetTopic 

func (x *SubOption) GetTopic() string

func (*SubOption) ProtoMessage 

func (*SubOption) ProtoMessage()

func (*SubOption) ProtoReflect 

func (x *SubOption) ProtoReflect() protoreflect.Message

func (*SubOption) Reset 

func (x *SubOption) Reset()

func (*SubOption) String 

func (x *SubOption) String() string

type SubRequest 

type SubRequest struct {
	Topics     map[string]*SubOption `` /* 153-byte string literal not displayed */
	ClientID   string                `protobuf:"bytes,2,opt,name=SendClientID,proto3" json:"SendClientID,omitempty"`
	Share      bool                  `protobuf:"varint,3,opt,name=Share,proto3" json:"Share,omitempty"`
	ShareGroup string                `protobuf:"bytes,4,opt,name=ShareGroup,proto3" json:"ShareGroup,omitempty"`
	// contains filtered or unexported fields
}

func (*SubRequest) Descriptor deprecated 

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

Deprecated: Use SubRequest.ProtoReflect.Descriptor instead.

func (*SubRequest) GetClientID 

func (x *SubRequest) GetClientID() string

func (*SubRequest) GetShare 

func (x *SubRequest) GetShare() bool

func (*SubRequest) GetShareGroup 

func (x *SubRequest) GetShareGroup() string

func (*SubRequest) GetTopics 

func (x *SubRequest) GetTopics() map[string]*SubOption

func (*SubRequest) ProtoMessage 

func (*SubRequest) ProtoMessage()

func (*SubRequest) ProtoReflect 

func (x *SubRequest) ProtoReflect() protoreflect.Message

func (*SubRequest) Reset 

func (x *SubRequest) Reset()

func (*SubRequest) String 

func (x *SubRequest) String() string

type SubResponse 

type SubResponse struct {
	Topics map[string]*SubOption `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SubResponse) Descriptor deprecated 

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

Deprecated: Use SubResponse.ProtoReflect.Descriptor instead.

func (*SubResponse) GetTopics 

func (x *SubResponse) GetTopics() map[string]*SubOption

func (*SubResponse) ProtoMessage 

func (*SubResponse) ProtoMessage()

func (*SubResponse) ProtoReflect 

func (x *SubResponse) ProtoReflect() protoreflect.Message

func (*SubResponse) Reset 

func (x *SubResponse) Reset()

func (*SubResponse) String 

func (x *SubResponse) String() string

type TopicClientsID 

type TopicClientsID struct {
	Clients map[string]*SubOption `` // key is clientID
	/* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TopicClientsID) Descriptor deprecated 

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

Deprecated: Use TopicClientsID.ProtoReflect.Descriptor instead.

func (*TopicClientsID) GetClients 

func (x *TopicClientsID) GetClients() map[string]*SubOption

func (*TopicClientsID) ProtoMessage 

func (*TopicClientsID) ProtoMessage()

func (*TopicClientsID) ProtoReflect 

func (x *TopicClientsID) ProtoReflect() protoreflect.Message

func (*TopicClientsID) Reset 

func (x *TopicClientsID) Reset()

func (*TopicClientsID) String 

func (x *TopicClientsID) String() string

type TopicSubTree 

type TopicSubTree struct {
	TreeRoot *TreeNode                  `protobuf:"bytes,1,opt,name=TreeRoot,proto3" json:"TreeRoot,omitempty"`
	Hash     map[string]*TopicClientsID `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TopicSubTree) Descriptor deprecated 

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

Deprecated: Use TopicSubTree.ProtoReflect.Descriptor instead.

func (*TopicSubTree) GetHash 

func (x *TopicSubTree) GetHash() map[string]*TopicClientsID

func (*TopicSubTree) GetTreeRoot 

func (x *TopicSubTree) GetTreeRoot() *TreeNode

func (*TopicSubTree) ProtoMessage 

func (*TopicSubTree) ProtoMessage()

func (*TopicSubTree) ProtoReflect 

func (x *TopicSubTree) ProtoReflect() protoreflect.Message

func (*TopicSubTree) Reset 

func (x *TopicSubTree) Reset()

func (*TopicSubTree) String 

func (x *TopicSubTree) String() string

type TreeNode 

type TreeNode struct {
	TopicSection string                `protobuf:"bytes,1,opt,name=TopicSection,proto3" json:"TopicSection,omitempty"` // topic section
	Topic        string                `protobuf:"bytes,2,opt,name=Topic,proto3" json:"Topic,omitempty"`               // full topic
	Clients      map[string]*SubOption ``                                                                              // sub clients, key is clientID
	/* 155-byte string literal not displayed */
	ChildNode map[string]*TreeNode `` // child tree
	/* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TreeNode) Descriptor deprecated 

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

Deprecated: Use TreeNode.ProtoReflect.Descriptor instead.

func (*TreeNode) GetChildNode 

func (x *TreeNode) GetChildNode() map[string]*TreeNode

func (*TreeNode) GetClients 

func (x *TreeNode) GetClients() map[string]*SubOption

func (*TreeNode) GetTopic 

func (x *TreeNode) GetTopic() string

func (*TreeNode) GetTopicSection 

func (x *TreeNode) GetTopicSection() string

func (*TreeNode) ProtoMessage 

func (*TreeNode) ProtoMessage()

func (*TreeNode) ProtoReflect 

func (x *TreeNode) ProtoReflect() protoreflect.Message

func (*TreeNode) Reset 

func (x *TreeNode) Reset()

func (*TreeNode) String 

func (x *TreeNode) String() string

type UnSubRequest 

type UnSubRequest struct {
	Topics     []string `protobuf:"bytes,1,rep,name=Topics,proto3" json:"Topics,omitempty"`
	ClientID   string   `protobuf:"bytes,2,opt,name=SendClientID,proto3" json:"SendClientID,omitempty"`
	Share      bool     `protobuf:"varint,3,opt,name=Share,proto3" json:"Share,omitempty"`
	ShareGroup string   `protobuf:"bytes,4,opt,name=ShareGroup,proto3" json:"ShareGroup,omitempty"`
	// contains filtered or unexported fields
}

func (*UnSubRequest) Descriptor deprecated 

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

Deprecated: Use UnSubRequest.ProtoReflect.Descriptor instead.

func (*UnSubRequest) GetClientID 

func (x *UnSubRequest) GetClientID() string

func (*UnSubRequest) GetShare 

func (x *UnSubRequest) GetShare() bool

func (*UnSubRequest) GetShareGroup 

func (x *UnSubRequest) GetShareGroup() string

func (*UnSubRequest) GetTopics 

func (x *UnSubRequest) GetTopics() []string

func (*UnSubRequest) ProtoMessage 

func (*UnSubRequest) ProtoMessage()

func (*UnSubRequest) ProtoReflect 

func (x *UnSubRequest) ProtoReflect() protoreflect.Message

func (*UnSubRequest) Reset 

func (x *UnSubRequest) Reset()

func (*UnSubRequest) String 

func (x *UnSubRequest) String() string

type UnSubResponse 

type UnSubResponse struct {
	Topics map[string]int32 `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UnSubResponse) Descriptor deprecated 

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

Deprecated: Use UnSubResponse.ProtoReflect.Descriptor instead.

func (*UnSubResponse) GetTopics 

func (x *UnSubResponse) GetTopics() map[string]int32

func (*UnSubResponse) ProtoMessage 

func (*UnSubResponse) ProtoMessage()

func (*UnSubResponse) ProtoReflect 

func (x *UnSubResponse) ProtoReflect() protoreflect.Message

func (*UnSubResponse) Reset 

func (x *UnSubResponse) Reset()

func (*UnSubResponse) String 

func (x *UnSubResponse) String() string

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.