topicproto

package
v0.4.30 Latest Latest
Warning

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

 Go to latest Published: Jun 9, 2022 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterTopicServiceServer 

func RegisterTopicServiceServer(s *grpc.Server, srv TopicServiceServer)

Types

type CheckTopicExistRequest 

type CheckTopicExistRequest struct {
	Topic                string   `protobuf:"bytes,1,opt,name=Topic,proto3" json:"Topic,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CheckTopicExistRequest) Descriptor 

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

func (*CheckTopicExistRequest) GetTopic 

func (m *CheckTopicExistRequest) GetTopic() string

func (*CheckTopicExistRequest) ProtoMessage 

func (*CheckTopicExistRequest) ProtoMessage()

func (*CheckTopicExistRequest) Reset 

func (m *CheckTopicExistRequest) Reset()

func (*CheckTopicExistRequest) String 

func (m *CheckTopicExistRequest) String() string

func (*CheckTopicExistRequest) XXX_DiscardUnknown 

func (m *CheckTopicExistRequest) XXX_DiscardUnknown()

func (*CheckTopicExistRequest) XXX_Marshal 

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

func (*CheckTopicExistRequest) XXX_Merge 

func (dst *CheckTopicExistRequest) XXX_Merge(src proto.Message)

func (*CheckTopicExistRequest) XXX_Size 

func (m *CheckTopicExistRequest) XXX_Size() int

func (*CheckTopicExistRequest) XXX_Unmarshal 

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

type CheckTopicExistResponse 

type CheckTopicExistResponse struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=Ok,proto3" json:"Ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CheckTopicExistResponse) Descriptor 

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

func (*CheckTopicExistResponse) GetOk 

func (m *CheckTopicExistResponse) GetOk() bool

func (*CheckTopicExistResponse) ProtoMessage 

func (*CheckTopicExistResponse) ProtoMessage()

func (*CheckTopicExistResponse) Reset 

func (m *CheckTopicExistResponse) Reset()

func (*CheckTopicExistResponse) String 

func (m *CheckTopicExistResponse) String() string

func (*CheckTopicExistResponse) XXX_DiscardUnknown 

func (m *CheckTopicExistResponse) XXX_DiscardUnknown()

func (*CheckTopicExistResponse) XXX_Marshal 

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

func (*CheckTopicExistResponse) XXX_Merge 

func (dst *CheckTopicExistResponse) XXX_Merge(src proto.Message)

func (*CheckTopicExistResponse) XXX_Size 

func (m *CheckTopicExistResponse) XXX_Size() int

func (*CheckTopicExistResponse) XXX_Unmarshal 

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

type GetConnectNumRequest 

type GetConnectNumRequest struct {
	Topic                string   `protobuf:"bytes,1,opt,name=Topic,proto3" json:"Topic,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetConnectNumRequest) Descriptor 

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

func (*GetConnectNumRequest) GetTopic 

func (m *GetConnectNumRequest) GetTopic() string

func (*GetConnectNumRequest) ProtoMessage 

func (*GetConnectNumRequest) ProtoMessage()

func (*GetConnectNumRequest) Reset 

func (m *GetConnectNumRequest) Reset()

func (*GetConnectNumRequest) String 

func (m *GetConnectNumRequest) String() string

func (*GetConnectNumRequest) XXX_DiscardUnknown 

func (m *GetConnectNumRequest) XXX_DiscardUnknown()

func (*GetConnectNumRequest) XXX_Marshal 

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

func (*GetConnectNumRequest) XXX_Merge 

func (dst *GetConnectNumRequest) XXX_Merge(src proto.Message)

func (*GetConnectNumRequest) XXX_Size 

func (m *GetConnectNumRequest) XXX_Size() int

func (*GetConnectNumRequest) XXX_Unmarshal 

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

type GetConnectNumResponse 

type GetConnectNumResponse struct {
	Number               int64    `protobuf:"varint,1,opt,name=Number,proto3" json:"Number,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetConnectNumResponse) Descriptor 

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

func (*GetConnectNumResponse) GetNumber 

func (m *GetConnectNumResponse) GetNumber() int64

func (*GetConnectNumResponse) ProtoMessage 

func (*GetConnectNumResponse) ProtoMessage()

func (*GetConnectNumResponse) Reset 

func (m *GetConnectNumResponse) Reset()

func (*GetConnectNumResponse) String 

func (m *GetConnectNumResponse) String() string

func (*GetConnectNumResponse) XXX_DiscardUnknown 

func (m *GetConnectNumResponse) XXX_DiscardUnknown()

func (*GetConnectNumResponse) XXX_Marshal 

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

func (*GetConnectNumResponse) XXX_Merge 

func (dst *GetConnectNumResponse) XXX_Merge(src proto.Message)

func (*GetConnectNumResponse) XXX_Size 

func (m *GetConnectNumResponse) XXX_Size() int

func (*GetConnectNumResponse) XXX_Unmarshal 

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

type PublishRequest 

type PublishRequest struct {
	Topic                string   `protobuf:"bytes,1,opt,name=Topic,proto3" json:"Topic,omitempty"`
	Data                 []byte   `protobuf:"bytes,2,opt,name=Data,proto3" json:"Data,omitempty"`
	MessageId            string   `protobuf:"bytes,3,opt,name=MessageId,proto3" json:"MessageId,omitempty"`
	Source               string   `protobuf:"bytes,4,opt,name=Source,proto3" json:"Source,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PublishRequest) Descriptor 

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

func (*PublishRequest) GetData 

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

func (*PublishRequest) GetMessageId 

func (m *PublishRequest) GetMessageId() string

func (*PublishRequest) GetSource 

func (m *PublishRequest) GetSource() string

func (*PublishRequest) GetTopic 

func (m *PublishRequest) GetTopic() string

func (*PublishRequest) ProtoMessage 

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) Reset 

func (m *PublishRequest) Reset()

func (*PublishRequest) String 

func (m *PublishRequest) String() string

func (*PublishRequest) XXX_DiscardUnknown 

func (m *PublishRequest) XXX_DiscardUnknown()

func (*PublishRequest) XXX_Marshal 

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

func (*PublishRequest) XXX_Merge 

func (dst *PublishRequest) XXX_Merge(src proto.Message)

func (*PublishRequest) XXX_Size 

func (m *PublishRequest) XXX_Size() int

func (*PublishRequest) XXX_Unmarshal 

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

type PublishResponse 

type PublishResponse struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=Ok,proto3" json:"Ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PublishResponse) Descriptor 

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

func (*PublishResponse) GetOk 

func (m *PublishResponse) GetOk() bool

func (*PublishResponse) ProtoMessage 

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) Reset 

func (m *PublishResponse) Reset()

func (*PublishResponse) String 

func (m *PublishResponse) String() string

func (*PublishResponse) XXX_DiscardUnknown 

func (m *PublishResponse) XXX_DiscardUnknown()

func (*PublishResponse) XXX_Marshal 

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

func (*PublishResponse) XXX_Merge 

func (dst *PublishResponse) XXX_Merge(src proto.Message)

func (*PublishResponse) XXX_Size 

func (m *PublishResponse) XXX_Size() int

func (*PublishResponse) XXX_Unmarshal 

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

type SubscribeTopicRequest 

type SubscribeTopicRequest struct {
	Topic                []string `protobuf:"bytes,1,rep,name=Topic,proto3" json:"Topic,omitempty"`
	Ip                   string   `protobuf:"bytes,2,opt,name=Ip,proto3" json:"Ip,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubscribeTopicRequest) Descriptor 

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

func (*SubscribeTopicRequest) GetIp 

func (m *SubscribeTopicRequest) GetIp() string

func (*SubscribeTopicRequest) GetTopic 

func (m *SubscribeTopicRequest) GetTopic() []string

func (*SubscribeTopicRequest) ProtoMessage 

func (*SubscribeTopicRequest) ProtoMessage()

func (*SubscribeTopicRequest) Reset 

func (m *SubscribeTopicRequest) Reset()

func (*SubscribeTopicRequest) String 

func (m *SubscribeTopicRequest) String() string

func (*SubscribeTopicRequest) XXX_DiscardUnknown 

func (m *SubscribeTopicRequest) XXX_DiscardUnknown()

func (*SubscribeTopicRequest) XXX_Marshal 

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

func (*SubscribeTopicRequest) XXX_Merge 

func (dst *SubscribeTopicRequest) XXX_Merge(src proto.Message)

func (*SubscribeTopicRequest) XXX_Size 

func (m *SubscribeTopicRequest) XXX_Size() int

func (*SubscribeTopicRequest) XXX_Unmarshal 

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

type SubscribeTopicResponse 

type SubscribeTopicResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubscribeTopicResponse) Descriptor 

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

func (*SubscribeTopicResponse) ProtoMessage 

func (*SubscribeTopicResponse) ProtoMessage()

func (*SubscribeTopicResponse) Reset 

func (m *SubscribeTopicResponse) Reset()

func (*SubscribeTopicResponse) String 

func (m *SubscribeTopicResponse) String() string

func (*SubscribeTopicResponse) XXX_DiscardUnknown 

func (m *SubscribeTopicResponse) XXX_DiscardUnknown()

func (*SubscribeTopicResponse) XXX_Marshal 

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

func (*SubscribeTopicResponse) XXX_Merge 

func (dst *SubscribeTopicResponse) XXX_Merge(src proto.Message)

func (*SubscribeTopicResponse) XXX_Size 

func (m *SubscribeTopicResponse) XXX_Size() int

func (*SubscribeTopicResponse) XXX_Unmarshal 

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

type TopicServiceClient 

type TopicServiceClient interface {
	GetConnectNum(ctx context.Context, in *GetConnectNumRequest, opts ...grpc.CallOption) (*GetConnectNumResponse, error)
	SubscribeTopic(ctx context.Context, in *SubscribeTopicRequest, opts ...grpc.CallOption) (*SubscribeTopicResponse, error)
	UnSubscribeTopic(ctx context.Context, in *UnSubscribeTopicRequest, opts ...grpc.CallOption) (*UnSubscribeTopicResponse, error)
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)
	CheckTopicExist(ctx context.Context, in *CheckTopicExistRequest, opts ...grpc.CallOption) (*CheckTopicExistResponse, error)
}

TopicServiceClient is the client API for TopicService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTopicServiceClient 

func NewTopicServiceClient(cc *grpc.ClientConn) TopicServiceClient

type TopicServiceServer 

type TopicServiceServer interface {
	GetConnectNum(context.Context, *GetConnectNumRequest) (*GetConnectNumResponse, error)
	SubscribeTopic(context.Context, *SubscribeTopicRequest) (*SubscribeTopicResponse, error)
	UnSubscribeTopic(context.Context, *UnSubscribeTopicRequest) (*UnSubscribeTopicResponse, error)
	Publish(context.Context, *PublishRequest) (*PublishResponse, error)
	CheckTopicExist(context.Context, *CheckTopicExistRequest) (*CheckTopicExistResponse, error)
}

TopicServiceServer is the server API for TopicService service.

type UnSubscribeTopicRequest 

type UnSubscribeTopicRequest struct {
	Topic                []string `protobuf:"bytes,1,rep,name=Topic,proto3" json:"Topic,omitempty"`
	Ip                   string   `protobuf:"bytes,2,opt,name=Ip,proto3" json:"Ip,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnSubscribeTopicRequest) Descriptor 

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

func (*UnSubscribeTopicRequest) GetIp 

func (m *UnSubscribeTopicRequest) GetIp() string

func (*UnSubscribeTopicRequest) GetTopic 

func (m *UnSubscribeTopicRequest) GetTopic() []string

func (*UnSubscribeTopicRequest) ProtoMessage 

func (*UnSubscribeTopicRequest) ProtoMessage()

func (*UnSubscribeTopicRequest) Reset 

func (m *UnSubscribeTopicRequest) Reset()

func (*UnSubscribeTopicRequest) String 

func (m *UnSubscribeTopicRequest) String() string

func (*UnSubscribeTopicRequest) XXX_DiscardUnknown 

func (m *UnSubscribeTopicRequest) XXX_DiscardUnknown()

func (*UnSubscribeTopicRequest) XXX_Marshal 

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

func (*UnSubscribeTopicRequest) XXX_Merge 

func (dst *UnSubscribeTopicRequest) XXX_Merge(src proto.Message)

func (*UnSubscribeTopicRequest) XXX_Size 

func (m *UnSubscribeTopicRequest) XXX_Size() int

func (*UnSubscribeTopicRequest) XXX_Unmarshal 

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

type UnSubscribeTopicResponse 

type UnSubscribeTopicResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnSubscribeTopicResponse) Descriptor 

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

func (*UnSubscribeTopicResponse) ProtoMessage 

func (*UnSubscribeTopicResponse) ProtoMessage()

func (*UnSubscribeTopicResponse) Reset 

func (m *UnSubscribeTopicResponse) Reset()

func (*UnSubscribeTopicResponse) String 

func (m *UnSubscribeTopicResponse) String() string

func (*UnSubscribeTopicResponse) XXX_DiscardUnknown 

func (m *UnSubscribeTopicResponse) XXX_DiscardUnknown()

func (*UnSubscribeTopicResponse) XXX_Marshal 

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

func (*UnSubscribeTopicResponse) XXX_Merge 

func (dst *UnSubscribeTopicResponse) XXX_Merge(src proto.Message)

func (*UnSubscribeTopicResponse) XXX_Size 

func (m *UnSubscribeTopicResponse) XXX_Size() int

func (*UnSubscribeTopicResponse) XXX_Unmarshal 

func (m *UnSubscribeTopicResponse) XXX_Unmarshal(b []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.