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.

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.

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

func (Heartbeat_ClientType) EnumDescriptor deprecated

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

Deprecated: Use Heartbeat_ClientType.Descriptor instead.

func (Heartbeat_ClientType) Number

func (Heartbeat_ClientType) String

func (x Heartbeat_ClientType) String() string

func (Heartbeat_ClientType) Type

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.

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 (*Subscription_SubscriptionItem) GetTopic

func (x *Subscription_SubscriptionItem) GetTopic() string

func (*Subscription_SubscriptionItem) GetType

func (*Subscription_SubscriptionItem) ProtoMessage

func (*Subscription_SubscriptionItem) ProtoMessage()

func (*Subscription_SubscriptionItem) ProtoReflect

func (*Subscription_SubscriptionItem) Reset

func (x *Subscription_SubscriptionItem) Reset()

func (*Subscription_SubscriptionItem) 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) Enum

func (Subscription_SubscriptionItem_SubscriptionMode) EnumDescriptor deprecated

Deprecated: Use Subscription_SubscriptionItem_SubscriptionMode.Descriptor instead.

func (Subscription_SubscriptionItem_SubscriptionMode) Number

func (Subscription_SubscriptionItem_SubscriptionMode) String

func (Subscription_SubscriptionItem_SubscriptionMode) Type

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

func (Subscription_SubscriptionItem_SubscriptionType) EnumDescriptor deprecated

Deprecated: Use Subscription_SubscriptionItem_SubscriptionType.Descriptor instead.

func (Subscription_SubscriptionItem_SubscriptionType) Number

func (Subscription_SubscriptionItem_SubscriptionType) String

func (Subscription_SubscriptionItem_SubscriptionType) Type

type UnimplementedConsumerServiceServer

type UnimplementedConsumerServiceServer struct {
}

UnimplementedConsumerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedConsumerServiceServer) Subscribe

func (UnimplementedConsumerServiceServer) SubscribeStream

func (UnimplementedConsumerServiceServer) Unsubscribe

type UnimplementedHeartbeatServiceServer

type UnimplementedHeartbeatServiceServer struct {
}

UnimplementedHeartbeatServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedHeartbeatServiceServer) Heartbeat

type UnimplementedPublisherServiceServer

type UnimplementedPublisherServiceServer struct {
}

UnimplementedPublisherServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPublisherServiceServer) BatchPublish

func (UnimplementedPublisherServiceServer) Publish

func (UnimplementedPublisherServiceServer) RequestReply

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.

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