pb

package
v0.0.0-...-32ff608 Latest Latest
Warning

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

 Go to latest Published: Mar 28, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

README

how to generate proto go files

generate go files by the protoc-gen-go owned by Google

  1. install the latest protoc-gen-go and protoc-gen-go-grpc
go install google.golang.org/protobuf/cmd/protoc-gen-go
go install google.golang.org/grpc/cmd/protoc-gen-go-grpc
  1. run command
protoc --go_out=. eventmesh-client.proto
protoc --go-grpc_out=. eventmesh-client.proto

if you use the latest version protoc-gen-go, and generate by the old command, you will got these error:

--go_out: protoc-gen-go: plugins are not supported; use 'protoc --go-grpc_out=...' to generate gRPC

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Subscription_SubscriptionItem_SubscriptionMode_name = map[int32]string{
		0: "CLUSTERING",
		1: "BROADCASTING",
	}
	Subscription_SubscriptionItem_SubscriptionMode_value = map[string]int32{
		"CLUSTERING":   0,
		"BROADCASTING": 1,
	}
)

Enum value maps for Subscription_SubscriptionItem_SubscriptionMode.

View Source 
var (
	Subscription_SubscriptionItem_SubscriptionType_name = map[int32]string{
		0: "ASYNC",
		1: "SYNC",
	}
	Subscription_SubscriptionItem_SubscriptionType_value = map[string]int32{
		"ASYNC": 0,
		"SYNC":  1,
	}
)

Enum value maps for Subscription_SubscriptionItem_SubscriptionType.

View Source 
var (
	Heartbeat_ClientType_name = map[int32]string{
		0: "PUB",
		1: "SUB",
	}
	Heartbeat_ClientType_value = map[string]int32{
		"PUB": 0,
		"SUB": 1,
	}
)

Enum value maps for Heartbeat_ClientType.

View Source 
var ConsumerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "eventmesh.common.protocol.grpc.ConsumerService",
	HandlerType: (*ConsumerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "subscribe",
			Handler:    _ConsumerService_Subscribe_Handler,
		},
		{
			MethodName: "unsubscribe",
			Handler:    _ConsumerService_Unsubscribe_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "subscribeStream",
			Handler:       _ConsumerService_SubscribeStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "eventmesh-client.proto",
}

ConsumerService_ServiceDesc is the grpc.ServiceDesc for ConsumerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_eventmesh_client_proto protoreflect.FileDescriptor
View Source 
var HeartbeatService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "eventmesh.common.protocol.grpc.HeartbeatService",
	HandlerType: (*HeartbeatServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "heartbeat",
			Handler:    _HeartbeatService_Heartbeat_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "eventmesh-client.proto",
}

HeartbeatService_ServiceDesc is the grpc.ServiceDesc for HeartbeatService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var PublisherService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "eventmesh.common.protocol.grpc.PublisherService",
	HandlerType: (*PublisherServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "publish",
			Handler:    _PublisherService_Publish_Handler,
		},
		{
			MethodName: "requestReply",
			Handler:    _PublisherService_RequestReply_Handler,
		},
		{
			MethodName: "batchPublish",
			Handler:    _PublisherService_BatchPublish_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "eventmesh-client.proto",
}

PublisherService_ServiceDesc is the grpc.ServiceDesc for PublisherService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterConsumerServiceServer 

func RegisterConsumerServiceServer(s grpc.ServiceRegistrar, srv ConsumerServiceServer)

func RegisterHeartbeatServiceServer 

func RegisterHeartbeatServiceServer(s grpc.ServiceRegistrar, srv HeartbeatServiceServer)

func RegisterPublisherServiceServer 

func RegisterPublisherServiceServer(s grpc.ServiceRegistrar, srv PublisherServiceServer)

Types

type BatchMessage 

type BatchMessage struct {
	Header        *RequestHeader              `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	ProducerGroup string                      `protobuf:"bytes,2,opt,name=producerGroup,proto3" json:"producerGroup,omitempty"`
	Topic         string                      `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	MessageItem   []*BatchMessage_MessageItem `protobuf:"bytes,4,rep,name=messageItem,proto3" json:"messageItem,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchMessage) Descriptor deprecated 

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

Deprecated: Use BatchMessage.ProtoReflect.Descriptor instead.

func (*BatchMessage) GetHeader 

func (x *BatchMessage) GetHeader() *RequestHeader

func (*BatchMessage) GetMessageItem 

func (x *BatchMessage) GetMessageItem() []*BatchMessage_MessageItem

func (*BatchMessage) GetProducerGroup 

func (x *BatchMessage) GetProducerGroup() string

func (*BatchMessage) GetTopic 

func (x *BatchMessage) GetTopic() string

func (*BatchMessage) ProtoMessage 

func (*BatchMessage) ProtoMessage()

func (*BatchMessage) ProtoReflect 

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

func (*BatchMessage) Reset 

func (x *BatchMessage) Reset()

func (*BatchMessage) String 

func (x *BatchMessage) String() string

type BatchMessage_MessageItem 

type BatchMessage_MessageItem struct {
	Content    string            `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	Ttl        string            `protobuf:"bytes,2,opt,name=ttl,proto3" json:"ttl,omitempty"`
	UniqueId   string            `protobuf:"bytes,3,opt,name=uniqueId,proto3" json:"uniqueId,omitempty"`
	SeqNum     string            `protobuf:"bytes,4,opt,name=seqNum,proto3" json:"seqNum,omitempty"`
	Tag        string            `protobuf:"bytes,5,opt,name=tag,proto3" json:"tag,omitempty"`
	Properties map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*BatchMessage_MessageItem) Descriptor deprecated 

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

Deprecated: Use BatchMessage_MessageItem.ProtoReflect.Descriptor instead.

func (*BatchMessage_MessageItem) GetContent 

func (x *BatchMessage_MessageItem) GetContent() string

func (*BatchMessage_MessageItem) GetProperties 

func (x *BatchMessage_MessageItem) GetProperties() map[string]string

func (*BatchMessage_MessageItem) GetSeqNum 

func (x *BatchMessage_MessageItem) GetSeqNum() string

func (*BatchMessage_MessageItem) GetTag 

func (x *BatchMessage_MessageItem) GetTag() string

func (*BatchMessage_MessageItem) GetTtl 

func (x *BatchMessage_MessageItem) GetTtl() string

func (*BatchMessage_MessageItem) GetUniqueId 

func (x *BatchMessage_MessageItem) GetUniqueId() string

func (*BatchMessage_MessageItem) ProtoMessage 

func (*BatchMessage_MessageItem) ProtoMessage()

func (*BatchMessage_MessageItem) ProtoReflect 

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

func (*BatchMessage_MessageItem) Reset 

func (x *BatchMessage_MessageItem) Reset()

func (*BatchMessage_MessageItem) String 

func (x *BatchMessage_MessageItem) String() string

type ConsumerServiceClient 

type ConsumerServiceClient interface {
	// The subscribed event will be delivered by invoking the webhook url in the Subscription
	Subscribe(ctx context.Context, in *Subscription, opts ...grpc.CallOption) (*Response, error)
	//  The subscribed event will be delivered through stream of Message
	SubscribeStream(ctx context.Context, opts ...grpc.CallOption) (ConsumerService_SubscribeStreamClient, error)
	Unsubscribe(ctx context.Context, in *Subscription, opts ...grpc.CallOption) (*Response, error)
}

ConsumerServiceClient is the client API for ConsumerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewConsumerServiceClient 

func NewConsumerServiceClient(cc grpc.ClientConnInterface) ConsumerServiceClient

type ConsumerServiceServer 

type ConsumerServiceServer interface {
	// The subscribed event will be delivered by invoking the webhook url in the Subscription
	Subscribe(context.Context, *Subscription) (*Response, error)
	//  The subscribed event will be delivered through stream of Message
	SubscribeStream(ConsumerService_SubscribeStreamServer) error
	Unsubscribe(context.Context, *Subscription) (*Response, error)
	// contains filtered or unexported methods
}

ConsumerServiceServer is the server API for ConsumerService service. All implementations must embed UnimplementedConsumerServiceServer for forward compatibility

type ConsumerService_SubscribeStreamClient 

type ConsumerService_SubscribeStreamClient interface {
	Send(*Subscription) error
	Recv() (*SimpleMessage, error)
	grpc.ClientStream
}

type ConsumerService_SubscribeStreamServer 

type ConsumerService_SubscribeStreamServer interface {
	Send(*SimpleMessage) error
	Recv() (*Subscription, error)
	grpc.ServerStream
}

type Heartbeat 

type Heartbeat struct {
	Header         *RequestHeader             `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	ClientType     Heartbeat_ClientType       `` /* 131-byte string literal not displayed */
	ProducerGroup  string                     `protobuf:"bytes,3,opt,name=producerGroup,proto3" json:"producerGroup,omitempty"`
	ConsumerGroup  string                     `protobuf:"bytes,4,opt,name=consumerGroup,proto3" json:"consumerGroup,omitempty"`
	HeartbeatItems []*Heartbeat_HeartbeatItem `protobuf:"bytes,5,rep,name=heartbeatItems,proto3" json:"heartbeatItems,omitempty"`
	// contains filtered or unexported fields
}

func (*Heartbeat) Descriptor deprecated 

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

Deprecated: Use Heartbeat.ProtoReflect.Descriptor instead.

func (*Heartbeat) GetClientType 

func (x *Heartbeat) GetClientType() Heartbeat_ClientType

func (*Heartbeat) GetConsumerGroup 

func (x *Heartbeat) GetConsumerGroup() string

func (*Heartbeat) GetHeader 

func (x *Heartbeat) GetHeader() *RequestHeader

func (*Heartbeat) GetHeartbeatItems 

func (x *Heartbeat) GetHeartbeatItems() []*Heartbeat_HeartbeatItem

func (*Heartbeat) GetProducerGroup 

func (x *Heartbeat) GetProducerGroup() string

func (*Heartbeat) ProtoMessage 

func (*Heartbeat) ProtoMessage()

func (*Heartbeat) ProtoReflect 

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

func (*Heartbeat) Reset 

func (x *Heartbeat) Reset()

func (*Heartbeat) String 

func (x *Heartbeat) String() string

type HeartbeatServiceClient 

type HeartbeatServiceClient interface {
	Heartbeat(ctx context.Context, in *Heartbeat, opts ...grpc.CallOption) (*Response, error)
}

HeartbeatServiceClient is the client API for HeartbeatService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewHeartbeatServiceClient 

func NewHeartbeatServiceClient(cc grpc.ClientConnInterface) HeartbeatServiceClient

type HeartbeatServiceServer 

type HeartbeatServiceServer interface {
	Heartbeat(context.Context, *Heartbeat) (*Response, error)
	// contains filtered or unexported methods
}

HeartbeatServiceServer is the server API for HeartbeatService service. All implementations must embed UnimplementedHeartbeatServiceServer for forward compatibility

type Heartbeat_ClientType 

type Heartbeat_ClientType int32
const (
	Heartbeat_PUB Heartbeat_ClientType = 0
	Heartbeat_SUB Heartbeat_ClientType = 1
)

func (Heartbeat_ClientType) Descriptor 

func (Heartbeat_ClientType) Descriptor() protoreflect.EnumDescriptor

func (Heartbeat_ClientType) Enum 

func (x Heartbeat_ClientType) Enum() *Heartbeat_ClientType

func (Heartbeat_ClientType) EnumDescriptor deprecated 

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

Deprecated: Use Heartbeat_ClientType.Descriptor instead.

func (Heartbeat_ClientType) Number 

func (x Heartbeat_ClientType) Number() protoreflect.EnumNumber

func (Heartbeat_ClientType) String 

func (x Heartbeat_ClientType) String() string

func (Heartbeat_ClientType) Type 

func (Heartbeat_ClientType) Type() protoreflect.EnumType

type Heartbeat_HeartbeatItem 

type Heartbeat_HeartbeatItem struct {
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Url   string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*Heartbeat_HeartbeatItem) Descriptor deprecated 

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

Deprecated: Use Heartbeat_HeartbeatItem.ProtoReflect.Descriptor instead.

func (*Heartbeat_HeartbeatItem) GetTopic 

func (x *Heartbeat_HeartbeatItem) GetTopic() string

func (*Heartbeat_HeartbeatItem) GetUrl 

func (x *Heartbeat_HeartbeatItem) GetUrl() string

func (*Heartbeat_HeartbeatItem) ProtoMessage 

func (*Heartbeat_HeartbeatItem) ProtoMessage()

func (*Heartbeat_HeartbeatItem) ProtoReflect 

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

func (*Heartbeat_HeartbeatItem) Reset 

func (x *Heartbeat_HeartbeatItem) Reset()

func (*Heartbeat_HeartbeatItem) String 

func (x *Heartbeat_HeartbeatItem) String() string

type PublisherServiceClient 

type PublisherServiceClient interface {
	// Async event publish
	Publish(ctx context.Context, in *SimpleMessage, opts ...grpc.CallOption) (*Response, error)
	// Sync event publish
	RequestReply(ctx context.Context, in *SimpleMessage, opts ...grpc.CallOption) (*SimpleMessage, error)
	// Async batch event publish
	BatchPublish(ctx context.Context, in *BatchMessage, opts ...grpc.CallOption) (*Response, error)
}

PublisherServiceClient is the client API for PublisherService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewPublisherServiceClient 

func NewPublisherServiceClient(cc grpc.ClientConnInterface) PublisherServiceClient

type PublisherServiceServer 

type PublisherServiceServer interface {
	// Async event publish
	Publish(context.Context, *SimpleMessage) (*Response, error)
	// Sync event publish
	RequestReply(context.Context, *SimpleMessage) (*SimpleMessage, error)
	// Async batch event publish
	BatchPublish(context.Context, *BatchMessage) (*Response, error)
	// contains filtered or unexported methods
}

PublisherServiceServer is the server API for PublisherService service. All implementations must embed UnimplementedPublisherServiceServer for forward compatibility

type RequestHeader 

type RequestHeader struct {
	Env             string `protobuf:"bytes,1,opt,name=env,proto3" json:"env,omitempty"`
	Region          string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
	Idc             string `protobuf:"bytes,3,opt,name=idc,proto3" json:"idc,omitempty"`
	Ip              string `protobuf:"bytes,4,opt,name=ip,proto3" json:"ip,omitempty"`
	Pid             string `protobuf:"bytes,5,opt,name=pid,proto3" json:"pid,omitempty"`
	Sys             string `protobuf:"bytes,6,opt,name=sys,proto3" json:"sys,omitempty"`
	Username        string `protobuf:"bytes,7,opt,name=username,proto3" json:"username,omitempty"`
	Password        string `protobuf:"bytes,8,opt,name=password,proto3" json:"password,omitempty"`
	Language        string `protobuf:"bytes,9,opt,name=language,proto3" json:"language,omitempty"`
	ProtocolType    string `protobuf:"bytes,10,opt,name=protocolType,proto3" json:"protocolType,omitempty"`
	ProtocolVersion string `protobuf:"bytes,11,opt,name=protocolVersion,proto3" json:"protocolVersion,omitempty"`
	ProtocolDesc    string `protobuf:"bytes,12,opt,name=protocolDesc,proto3" json:"protocolDesc,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestHeader) Descriptor deprecated 

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

Deprecated: Use RequestHeader.ProtoReflect.Descriptor instead.

func (*RequestHeader) GetEnv 

func (x *RequestHeader) GetEnv() string

func (*RequestHeader) GetIdc 

func (x *RequestHeader) GetIdc() string

func (*RequestHeader) GetIp 

func (x *RequestHeader) GetIp() string

func (*RequestHeader) GetLanguage 

func (x *RequestHeader) GetLanguage() string

func (*RequestHeader) GetPassword 

func (x *RequestHeader) GetPassword() string

func (*RequestHeader) GetPid 

func (x *RequestHeader) GetPid() string

func (*RequestHeader) GetProtocolDesc 

func (x *RequestHeader) GetProtocolDesc() string

func (*RequestHeader) GetProtocolType 

func (x *RequestHeader) GetProtocolType() string

func (*RequestHeader) GetProtocolVersion 

func (x *RequestHeader) GetProtocolVersion() string

func (*RequestHeader) GetRegion 

func (x *RequestHeader) GetRegion() string

func (*RequestHeader) GetSys 

func (x *RequestHeader) GetSys() string

func (*RequestHeader) GetUsername 

func (x *RequestHeader) GetUsername() string

func (*RequestHeader) ProtoMessage 

func (*RequestHeader) ProtoMessage()

func (*RequestHeader) ProtoReflect 

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

func (*RequestHeader) Reset 

func (x *RequestHeader) Reset()

func (*RequestHeader) String 

func (x *RequestHeader) String() string

type Response 

type Response struct {
	RespCode string `protobuf:"bytes,1,opt,name=respCode,proto3" json:"respCode,omitempty"`
	RespMsg  string `protobuf:"bytes,2,opt,name=respMsg,proto3" json:"respMsg,omitempty"`
	RespTime string `protobuf:"bytes,3,opt,name=respTime,proto3" json:"respTime,omitempty"`
	// contains filtered or unexported fields
}

func (*Response) Descriptor deprecated 

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

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetRespCode 

func (x *Response) GetRespCode() string

func (*Response) GetRespMsg 

func (x *Response) GetRespMsg() string

func (*Response) GetRespTime 

func (x *Response) GetRespTime() string

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

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

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type SimpleMessage 

type SimpleMessage struct {
	Header        *RequestHeader    `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	ProducerGroup string            `protobuf:"bytes,2,opt,name=producerGroup,proto3" json:"producerGroup,omitempty"`
	Topic         string            `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	Content       string            `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"`
	Ttl           string            `protobuf:"bytes,5,opt,name=ttl,proto3" json:"ttl,omitempty"`
	UniqueId      string            `protobuf:"bytes,6,opt,name=uniqueId,proto3" json:"uniqueId,omitempty"`
	SeqNum        string            `protobuf:"bytes,7,opt,name=seqNum,proto3" json:"seqNum,omitempty"`
	Tag           string            `protobuf:"bytes,8,opt,name=tag,proto3" json:"tag,omitempty"`
	Properties    map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SimpleMessage) Descriptor deprecated 

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

Deprecated: Use SimpleMessage.ProtoReflect.Descriptor instead.

func (*SimpleMessage) GetContent 

func (x *SimpleMessage) GetContent() string

func (*SimpleMessage) GetHeader 

func (x *SimpleMessage) GetHeader() *RequestHeader

func (*SimpleMessage) GetProducerGroup 

func (x *SimpleMessage) GetProducerGroup() string

func (*SimpleMessage) GetProperties 

func (x *SimpleMessage) GetProperties() map[string]string

func (*SimpleMessage) GetSeqNum 

func (x *SimpleMessage) GetSeqNum() string

func (*SimpleMessage) GetTag 

func (x *SimpleMessage) GetTag() string

func (*SimpleMessage) GetTopic 

func (x *SimpleMessage) GetTopic() string

func (*SimpleMessage) GetTtl 

func (x *SimpleMessage) GetTtl() string

func (*SimpleMessage) GetUniqueId 

func (x *SimpleMessage) GetUniqueId() string

func (*SimpleMessage) ProtoMessage 

func (*SimpleMessage) ProtoMessage()

func (*SimpleMessage) ProtoReflect 

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

func (*SimpleMessage) Reset 

func (x *SimpleMessage) Reset()

func (*SimpleMessage) String 

func (x *SimpleMessage) String() string

type Subscription 

type Subscription struct {
	Header            *RequestHeader                   `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	ConsumerGroup     string                           `protobuf:"bytes,2,opt,name=consumerGroup,proto3" json:"consumerGroup,omitempty"`
	SubscriptionItems []*Subscription_SubscriptionItem `protobuf:"bytes,3,rep,name=subscriptionItems,proto3" json:"subscriptionItems,omitempty"`
	Url               string                           `protobuf:"bytes,4,opt,name=url,proto3" json:"url,omitempty"`
	Reply             *Subscription_Reply              `protobuf:"bytes,5,opt,name=reply,proto3" json:"reply,omitempty"`
	// contains filtered or unexported fields
}

func (*Subscription) Descriptor deprecated 

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

Deprecated: Use Subscription.ProtoReflect.Descriptor instead.

func (*Subscription) GetConsumerGroup 

func (x *Subscription) GetConsumerGroup() string

func (*Subscription) GetHeader 

func (x *Subscription) GetHeader() *RequestHeader

func (*Subscription) GetReply 

func (x *Subscription) GetReply() *Subscription_Reply

func (*Subscription) GetSubscriptionItems 

func (x *Subscription) GetSubscriptionItems() []*Subscription_SubscriptionItem

func (*Subscription) GetUrl 

func (x *Subscription) GetUrl() string

func (*Subscription) ProtoMessage 

func (*Subscription) ProtoMessage()

func (*Subscription) ProtoReflect 

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

func (*Subscription) Reset 

func (x *Subscription) Reset()

func (*Subscription) String 

func (x *Subscription) String() string

type Subscription_Reply 

type Subscription_Reply struct {
	ProducerGroup string            `protobuf:"bytes,1,opt,name=producerGroup,proto3" json:"producerGroup,omitempty"`
	Topic         string            `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Content       string            `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	Ttl           string            `protobuf:"bytes,4,opt,name=ttl,proto3" json:"ttl,omitempty"`
	UniqueId      string            `protobuf:"bytes,5,opt,name=uniqueId,proto3" json:"uniqueId,omitempty"`
	SeqNum        string            `protobuf:"bytes,6,opt,name=seqNum,proto3" json:"seqNum,omitempty"`
	Tag           string            `protobuf:"bytes,7,opt,name=tag,proto3" json:"tag,omitempty"`
	Properties    map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Subscription_Reply) Descriptor deprecated 

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

Deprecated: Use Subscription_Reply.ProtoReflect.Descriptor instead.

func (*Subscription_Reply) GetContent 

func (x *Subscription_Reply) GetContent() string

func (*Subscription_Reply) GetProducerGroup 

func (x *Subscription_Reply) GetProducerGroup() string

func (*Subscription_Reply) GetProperties 

func (x *Subscription_Reply) GetProperties() map[string]string

func (*Subscription_Reply) GetSeqNum 

func (x *Subscription_Reply) GetSeqNum() string

func (*Subscription_Reply) GetTag 

func (x *Subscription_Reply) GetTag() string

func (*Subscription_Reply) GetTopic 

func (x *Subscription_Reply) GetTopic() string

func (*Subscription_Reply) GetTtl 

func (x *Subscription_Reply) GetTtl() string

func (*Subscription_Reply) GetUniqueId 

func (x *Subscription_Reply) GetUniqueId() string

func (*Subscription_Reply) ProtoMessage 

func (*Subscription_Reply) ProtoMessage()

func (*Subscription_Reply) ProtoReflect 

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

func (*Subscription_Reply) Reset 

func (x *Subscription_Reply) Reset()

func (*Subscription_Reply) String 

func (x *Subscription_Reply) String() string

type Subscription_SubscriptionItem 

type Subscription_SubscriptionItem struct {
	Topic string                                         `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Mode  Subscription_SubscriptionItem_SubscriptionMode `` /* 145-byte string literal not displayed */
	Type  Subscription_SubscriptionItem_SubscriptionType `` /* 145-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Subscription_SubscriptionItem) Descriptor deprecated 

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

Deprecated: Use Subscription_SubscriptionItem.ProtoReflect.Descriptor instead.

func (*Subscription_SubscriptionItem) GetMode 

func (x *Subscription_SubscriptionItem) GetMode() Subscription_SubscriptionItem_SubscriptionMode

func (*Subscription_SubscriptionItem) GetTopic 

func (x *Subscription_SubscriptionItem) GetTopic() string

func (*Subscription_SubscriptionItem) GetType 

func (x *Subscription_SubscriptionItem) GetType() Subscription_SubscriptionItem_SubscriptionType

func (*Subscription_SubscriptionItem) ProtoMessage 

func (*Subscription_SubscriptionItem) ProtoMessage()

func (*Subscription_SubscriptionItem) ProtoReflect 

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

func (*Subscription_SubscriptionItem) Reset 

func (x *Subscription_SubscriptionItem) Reset()

func (*Subscription_SubscriptionItem) String 

func (x *Subscription_SubscriptionItem) String() string

type Subscription_SubscriptionItem_SubscriptionMode 

type Subscription_SubscriptionItem_SubscriptionMode int32
const (
	Subscription_SubscriptionItem_CLUSTERING   Subscription_SubscriptionItem_SubscriptionMode = 0
	Subscription_SubscriptionItem_BROADCASTING Subscription_SubscriptionItem_SubscriptionMode = 1
)

func (Subscription_SubscriptionItem_SubscriptionMode) Descriptor 

func (Subscription_SubscriptionItem_SubscriptionMode) Descriptor() protoreflect.EnumDescriptor

func (Subscription_SubscriptionItem_SubscriptionMode) Enum 

func (x Subscription_SubscriptionItem_SubscriptionMode) Enum() *Subscription_SubscriptionItem_SubscriptionMode

func (Subscription_SubscriptionItem_SubscriptionMode) EnumDescriptor deprecated 

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

Deprecated: Use Subscription_SubscriptionItem_SubscriptionMode.Descriptor instead.

func (Subscription_SubscriptionItem_SubscriptionMode) Number 

func (x Subscription_SubscriptionItem_SubscriptionMode) Number() protoreflect.EnumNumber

func (Subscription_SubscriptionItem_SubscriptionMode) String 

func (x Subscription_SubscriptionItem_SubscriptionMode) String() string

func (Subscription_SubscriptionItem_SubscriptionMode) Type 

func (Subscription_SubscriptionItem_SubscriptionMode) Type() protoreflect.EnumType

type Subscription_SubscriptionItem_SubscriptionType 

type Subscription_SubscriptionItem_SubscriptionType int32
const (
	Subscription_SubscriptionItem_ASYNC Subscription_SubscriptionItem_SubscriptionType = 0
	Subscription_SubscriptionItem_SYNC  Subscription_SubscriptionItem_SubscriptionType = 1
)

func (Subscription_SubscriptionItem_SubscriptionType) Descriptor 

func (Subscription_SubscriptionItem_SubscriptionType) Descriptor() protoreflect.EnumDescriptor

func (Subscription_SubscriptionItem_SubscriptionType) Enum 

func (x Subscription_SubscriptionItem_SubscriptionType) Enum() *Subscription_SubscriptionItem_SubscriptionType

func (Subscription_SubscriptionItem_SubscriptionType) EnumDescriptor deprecated 

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

Deprecated: Use Subscription_SubscriptionItem_SubscriptionType.Descriptor instead.

func (Subscription_SubscriptionItem_SubscriptionType) Number 

func (x Subscription_SubscriptionItem_SubscriptionType) Number() protoreflect.EnumNumber

func (Subscription_SubscriptionItem_SubscriptionType) String 

func (x Subscription_SubscriptionItem_SubscriptionType) String() string

func (Subscription_SubscriptionItem_SubscriptionType) Type 

func (Subscription_SubscriptionItem_SubscriptionType) Type() protoreflect.EnumType

type UnimplementedConsumerServiceServer 

type UnimplementedConsumerServiceServer struct {
}

UnimplementedConsumerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedConsumerServiceServer) Subscribe 

func (UnimplementedConsumerServiceServer) Subscribe(context.Context, *Subscription) (*Response, error)

func (UnimplementedConsumerServiceServer) SubscribeStream 

func (UnimplementedConsumerServiceServer) SubscribeStream(ConsumerService_SubscribeStreamServer) error

func (UnimplementedConsumerServiceServer) Unsubscribe 

func (UnimplementedConsumerServiceServer) Unsubscribe(context.Context, *Subscription) (*Response, error)

type UnimplementedHeartbeatServiceServer 

type UnimplementedHeartbeatServiceServer struct {
}

UnimplementedHeartbeatServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedHeartbeatServiceServer) Heartbeat 

func (UnimplementedHeartbeatServiceServer) Heartbeat(context.Context, *Heartbeat) (*Response, error)

type UnimplementedPublisherServiceServer 

type UnimplementedPublisherServiceServer struct {
}

UnimplementedPublisherServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPublisherServiceServer) BatchPublish 

func (UnimplementedPublisherServiceServer) BatchPublish(context.Context, *BatchMessage) (*Response, error)

func (UnimplementedPublisherServiceServer) Publish 

func (UnimplementedPublisherServiceServer) Publish(context.Context, *SimpleMessage) (*Response, error)

func (UnimplementedPublisherServiceServer) RequestReply 

func (UnimplementedPublisherServiceServer) RequestReply(context.Context, *SimpleMessage) (*SimpleMessage, error)

type UnsafeConsumerServiceServer 

type UnsafeConsumerServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeConsumerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ConsumerServiceServer will result in compilation errors.

type UnsafeHeartbeatServiceServer 

type UnsafeHeartbeatServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeHeartbeatServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HeartbeatServiceServer will result in compilation errors.

type UnsafePublisherServiceServer 

type UnsafePublisherServiceServer interface {
	// contains filtered or unexported methods
}

UnsafePublisherServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PublisherServiceServer will result in compilation errors.

Source Files

View all Source files

Directories

Path Synopsis
Package mocks is a generated GoMock package.
 Package mocks is a generated GoMock package.

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.