Versions in this module Expand all Collapse all v5 v5.1.2 Mar 26, 2025 Changes in this version + var AddressScheme_name = map[int32]string + var AddressScheme_value = map[string]int32 + var Admin_ServiceDesc = grpc.ServiceDesc + var ChangeLogLevelRequest_Level_name = map[int32]string + var ChangeLogLevelRequest_Level_value = map[string]int32 + var ClientType_name = map[int32]string + var ClientType_value = map[string]int32 + var Code_name = map[int32]string + var Code_value = map[string]int32 + var DigestType_name = map[int32]string + var DigestType_value = map[string]int32 + var Encoding_name = map[int32]string + var Encoding_value = map[string]int32 + var File_admin_proto protoreflect.FileDescriptor + var File_definition_proto protoreflect.FileDescriptor + var File_service_proto protoreflect.FileDescriptor + var FilterType_name = map[int32]string + var FilterType_value = map[string]int32 + var Language_name = map[int32]string + var Language_value = map[string]int32 + var MessageType_name = map[int32]string + var MessageType_value = map[string]int32 + var MessagingService_ServiceDesc = grpc.ServiceDesc + var Permission_name = map[int32]string + var Permission_value = map[string]int32 + var TransactionResolution_name = map[int32]string + var TransactionResolution_value = map[string]int32 + var TransactionSource_name = map[int32]string + var TransactionSource_value = map[string]int32 + func RegisterAdminServer(s grpc.ServiceRegistrar, srv AdminServer) + func RegisterMessagingServiceServer(s grpc.ServiceRegistrar, srv MessagingServiceServer) + type AckMessageEntry struct + MessageId string + ReceiptHandle string + func (*AckMessageEntry) Descriptor() ([]byte, []int) + func (*AckMessageEntry) ProtoMessage() + func (x *AckMessageEntry) GetMessageId() string + func (x *AckMessageEntry) GetReceiptHandle() string + func (x *AckMessageEntry) ProtoReflect() protoreflect.Message + func (x *AckMessageEntry) Reset() + func (x *AckMessageEntry) String() string + type AckMessageRequest struct + Entries []*AckMessageEntry + Group *Resource + Topic *Resource + func (*AckMessageRequest) Descriptor() ([]byte, []int) + func (*AckMessageRequest) ProtoMessage() + func (x *AckMessageRequest) GetEntries() []*AckMessageEntry + func (x *AckMessageRequest) GetGroup() *Resource + func (x *AckMessageRequest) GetTopic() *Resource + func (x *AckMessageRequest) ProtoReflect() protoreflect.Message + func (x *AckMessageRequest) Reset() + func (x *AckMessageRequest) String() string + type AckMessageResponse struct + Entries []*AckMessageResultEntry + Status *Status + func (*AckMessageResponse) Descriptor() ([]byte, []int) + func (*AckMessageResponse) ProtoMessage() + func (x *AckMessageResponse) GetEntries() []*AckMessageResultEntry + func (x *AckMessageResponse) GetStatus() *Status + func (x *AckMessageResponse) ProtoReflect() protoreflect.Message + func (x *AckMessageResponse) Reset() + func (x *AckMessageResponse) String() string + type AckMessageResultEntry struct + MessageId string + ReceiptHandle string + Status *Status + func (*AckMessageResultEntry) Descriptor() ([]byte, []int) + func (*AckMessageResultEntry) ProtoMessage() + func (x *AckMessageResultEntry) GetMessageId() string + func (x *AckMessageResultEntry) GetReceiptHandle() string + func (x *AckMessageResultEntry) GetStatus() *Status + func (x *AckMessageResultEntry) ProtoReflect() protoreflect.Message + func (x *AckMessageResultEntry) Reset() + func (x *AckMessageResultEntry) String() string + type Address struct + Host string + Port int32 + func (*Address) Descriptor() ([]byte, []int) + func (*Address) ProtoMessage() + func (x *Address) GetHost() string + func (x *Address) GetPort() int32 + func (x *Address) ProtoReflect() protoreflect.Message + func (x *Address) Reset() + func (x *Address) String() string + type AddressScheme int32 + const AddressScheme_ADDRESS_SCHEME_UNSPECIFIED + const AddressScheme_DOMAIN_NAME + const AddressScheme_IPv4 + const AddressScheme_IPv6 + func (AddressScheme) Descriptor() protoreflect.EnumDescriptor + func (AddressScheme) EnumDescriptor() ([]byte, []int) + func (AddressScheme) Type() protoreflect.EnumType + func (x AddressScheme) Enum() *AddressScheme + func (x AddressScheme) Number() protoreflect.EnumNumber + func (x AddressScheme) String() string + type AdminClient interface + ChangeLogLevel func(ctx context.Context, in *ChangeLogLevelRequest, opts ...grpc.CallOption) (*ChangeLogLevelResponse, error) + func NewAdminClient(cc grpc.ClientConnInterface) AdminClient + type AdminServer interface + ChangeLogLevel func(context.Context, *ChangeLogLevelRequest) (*ChangeLogLevelResponse, error) + type Assignment struct + MessageQueue *MessageQueue + func (*Assignment) Descriptor() ([]byte, []int) + func (*Assignment) ProtoMessage() + func (x *Assignment) GetMessageQueue() *MessageQueue + func (x *Assignment) ProtoReflect() protoreflect.Message + func (x *Assignment) Reset() + func (x *Assignment) String() string + type Broker struct + Endpoints *Endpoints + Id int32 + Name string + func (*Broker) Descriptor() ([]byte, []int) + func (*Broker) ProtoMessage() + func (x *Broker) GetEndpoints() *Endpoints + func (x *Broker) GetId() int32 + func (x *Broker) GetName() string + func (x *Broker) ProtoReflect() protoreflect.Message + func (x *Broker) Reset() + func (x *Broker) String() string + type ChangeInvisibleDurationRequest struct + Group *Resource + InvisibleDuration *durationpb.Duration + MessageId string + ReceiptHandle string + Topic *Resource + func (*ChangeInvisibleDurationRequest) Descriptor() ([]byte, []int) + func (*ChangeInvisibleDurationRequest) ProtoMessage() + func (x *ChangeInvisibleDurationRequest) GetGroup() *Resource + func (x *ChangeInvisibleDurationRequest) GetInvisibleDuration() *durationpb.Duration + func (x *ChangeInvisibleDurationRequest) GetMessageId() string + func (x *ChangeInvisibleDurationRequest) GetReceiptHandle() string + func (x *ChangeInvisibleDurationRequest) GetTopic() *Resource + func (x *ChangeInvisibleDurationRequest) ProtoReflect() protoreflect.Message + func (x *ChangeInvisibleDurationRequest) Reset() + func (x *ChangeInvisibleDurationRequest) String() string + type ChangeInvisibleDurationResponse struct + ReceiptHandle string + Status *Status + func (*ChangeInvisibleDurationResponse) Descriptor() ([]byte, []int) + func (*ChangeInvisibleDurationResponse) ProtoMessage() + func (x *ChangeInvisibleDurationResponse) GetReceiptHandle() string + func (x *ChangeInvisibleDurationResponse) GetStatus() *Status + func (x *ChangeInvisibleDurationResponse) ProtoReflect() protoreflect.Message + func (x *ChangeInvisibleDurationResponse) Reset() + func (x *ChangeInvisibleDurationResponse) String() string + type ChangeLogLevelRequest struct + Level ChangeLogLevelRequest_Level + func (*ChangeLogLevelRequest) Descriptor() ([]byte, []int) + func (*ChangeLogLevelRequest) ProtoMessage() + func (x *ChangeLogLevelRequest) GetLevel() ChangeLogLevelRequest_Level + func (x *ChangeLogLevelRequest) ProtoReflect() protoreflect.Message + func (x *ChangeLogLevelRequest) Reset() + func (x *ChangeLogLevelRequest) String() string + type ChangeLogLevelRequest_Level int32 + const ChangeLogLevelRequest_DEBUG + const ChangeLogLevelRequest_ERROR + const ChangeLogLevelRequest_INFO + const ChangeLogLevelRequest_TRACE + const ChangeLogLevelRequest_WARN + func (ChangeLogLevelRequest_Level) Descriptor() protoreflect.EnumDescriptor + func (ChangeLogLevelRequest_Level) EnumDescriptor() ([]byte, []int) + func (ChangeLogLevelRequest_Level) Type() protoreflect.EnumType + func (x ChangeLogLevelRequest_Level) Enum() *ChangeLogLevelRequest_Level + func (x ChangeLogLevelRequest_Level) Number() protoreflect.EnumNumber + func (x ChangeLogLevelRequest_Level) String() string + type ChangeLogLevelResponse struct + Remark string + func (*ChangeLogLevelResponse) Descriptor() ([]byte, []int) + func (*ChangeLogLevelResponse) ProtoMessage() + func (x *ChangeLogLevelResponse) GetRemark() string + func (x *ChangeLogLevelResponse) ProtoReflect() protoreflect.Message + func (x *ChangeLogLevelResponse) Reset() + func (x *ChangeLogLevelResponse) String() string + type ClientType int32 + const ClientType_CLIENT_TYPE_UNSPECIFIED + const ClientType_PRODUCER + const ClientType_PUSH_CONSUMER + const ClientType_SIMPLE_CONSUMER + func (ClientType) Descriptor() protoreflect.EnumDescriptor + func (ClientType) EnumDescriptor() ([]byte, []int) + func (ClientType) Type() protoreflect.EnumType + func (x ClientType) Enum() *ClientType + func (x ClientType) Number() protoreflect.EnumNumber + func (x ClientType) String() string + type Code int32 + const Code_BAD_REQUEST + const Code_CLIENT_ID_REQUIRED + const Code_CODE_UNSPECIFIED + const Code_CONSUMER_GROUP_NOT_FOUND + const Code_FAILED_TO_CONSUME_MESSAGE + const Code_FORBIDDEN + const Code_HA_NOT_AVAILABLE + const Code_ILLEGAL_ACCESS_POINT + const Code_ILLEGAL_CONSUMER_GROUP + const Code_ILLEGAL_DELIVERY_TIME + const Code_ILLEGAL_FILTER_EXPRESSION + const Code_ILLEGAL_INVISIBLE_TIME + const Code_ILLEGAL_MESSAGE_GROUP + const Code_ILLEGAL_MESSAGE_ID + const Code_ILLEGAL_MESSAGE_KEY + const Code_ILLEGAL_MESSAGE_PROPERTY_KEY + const Code_ILLEGAL_MESSAGE_TAG + const Code_ILLEGAL_TOPIC + const Code_INTERNAL_ERROR + const Code_INTERNAL_SERVER_ERROR + const Code_INVALID_RECEIPT_HANDLE + const Code_INVALID_TRANSACTION_ID + const Code_MASTER_PERSISTENCE_TIMEOUT + const Code_MESSAGE_BODY_TOO_LARGE + const Code_MESSAGE_CORRUPTED + const Code_MESSAGE_NOT_FOUND + const Code_MESSAGE_PROPERTIES_TOO_LARGE + const Code_MESSAGE_PROPERTY_CONFLICT_WITH_TYPE + const Code_MULTIPLE_RESULTS + const Code_NOT_FOUND + const Code_NOT_IMPLEMENTED + const Code_OK + const Code_PAYLOAD_TOO_LARGE + const Code_PAYMENT_REQUIRED + const Code_PRECONDITION_FAILED + const Code_PROXY_TIMEOUT + const Code_REQUEST_HEADER_FIELDS_TOO_LARGE + const Code_REQUEST_TIMEOUT + const Code_SLAVE_PERSISTENCE_TIMEOUT + const Code_TOO_MANY_REQUESTS + const Code_TOPIC_NOT_FOUND + const Code_UNAUTHORIZED + const Code_UNRECOGNIZED_CLIENT_TYPE + const Code_UNSUPPORTED + const Code_VERIFY_FIFO_MESSAGE_UNSUPPORTED + const Code_VERSION_UNSUPPORTED + func (Code) Descriptor() protoreflect.EnumDescriptor + func (Code) EnumDescriptor() ([]byte, []int) + func (Code) Type() protoreflect.EnumType + func (x Code) Enum() *Code + func (x Code) Number() protoreflect.EnumNumber + func (x Code) String() string + type CustomizedBackoff struct + Next []*durationpb.Duration + func (*CustomizedBackoff) Descriptor() ([]byte, []int) + func (*CustomizedBackoff) ProtoMessage() + func (x *CustomizedBackoff) GetNext() []*durationpb.Duration + func (x *CustomizedBackoff) ProtoReflect() protoreflect.Message + func (x *CustomizedBackoff) Reset() + func (x *CustomizedBackoff) String() string + type Digest struct + Checksum string + Type DigestType + func (*Digest) Descriptor() ([]byte, []int) + func (*Digest) ProtoMessage() + func (x *Digest) GetChecksum() string + func (x *Digest) GetType() DigestType + func (x *Digest) ProtoReflect() protoreflect.Message + func (x *Digest) Reset() + func (x *Digest) String() string + type DigestType int32 + const DigestType_CRC32 + const DigestType_DIGEST_TYPE_UNSPECIFIED + const DigestType_MD5 + const DigestType_SHA1 + func (DigestType) Descriptor() protoreflect.EnumDescriptor + func (DigestType) EnumDescriptor() ([]byte, []int) + func (DigestType) Type() protoreflect.EnumType + func (x DigestType) Enum() *DigestType + func (x DigestType) Number() protoreflect.EnumNumber + func (x DigestType) String() string + type Encoding int32 + const Encoding_ENCODING_UNSPECIFIED + const Encoding_GZIP + const Encoding_IDENTITY + func (Encoding) Descriptor() protoreflect.EnumDescriptor + func (Encoding) EnumDescriptor() ([]byte, []int) + func (Encoding) Type() protoreflect.EnumType + func (x Encoding) Enum() *Encoding + func (x Encoding) Number() protoreflect.EnumNumber + func (x Encoding) String() string + type EndTransactionRequest struct + MessageId string + Resolution TransactionResolution + Source TransactionSource + Topic *Resource + TraceContext string + TransactionId string + func (*EndTransactionRequest) Descriptor() ([]byte, []int) + func (*EndTransactionRequest) ProtoMessage() + func (x *EndTransactionRequest) GetMessageId() string + func (x *EndTransactionRequest) GetResolution() TransactionResolution + func (x *EndTransactionRequest) GetSource() TransactionSource + func (x *EndTransactionRequest) GetTopic() *Resource + func (x *EndTransactionRequest) GetTraceContext() string + func (x *EndTransactionRequest) GetTransactionId() string + func (x *EndTransactionRequest) ProtoReflect() protoreflect.Message + func (x *EndTransactionRequest) Reset() + func (x *EndTransactionRequest) String() string + type EndTransactionResponse struct + Status *Status + func (*EndTransactionResponse) Descriptor() ([]byte, []int) + func (*EndTransactionResponse) ProtoMessage() + func (x *EndTransactionResponse) GetStatus() *Status + func (x *EndTransactionResponse) ProtoReflect() protoreflect.Message + func (x *EndTransactionResponse) Reset() + func (x *EndTransactionResponse) String() string + type Endpoints struct + Addresses []*Address + Scheme AddressScheme + func (*Endpoints) Descriptor() ([]byte, []int) + func (*Endpoints) ProtoMessage() + func (x *Endpoints) GetAddresses() []*Address + func (x *Endpoints) GetScheme() AddressScheme + func (x *Endpoints) ProtoReflect() protoreflect.Message + func (x *Endpoints) Reset() + func (x *Endpoints) String() string + type ExponentialBackoff struct + Initial *durationpb.Duration + Max *durationpb.Duration + Multiplier float32 + func (*ExponentialBackoff) Descriptor() ([]byte, []int) + func (*ExponentialBackoff) ProtoMessage() + func (x *ExponentialBackoff) GetInitial() *durationpb.Duration + func (x *ExponentialBackoff) GetMax() *durationpb.Duration + func (x *ExponentialBackoff) GetMultiplier() float32 + func (x *ExponentialBackoff) ProtoReflect() protoreflect.Message + func (x *ExponentialBackoff) Reset() + func (x *ExponentialBackoff) String() string + type FilterExpression struct + Expression string + Type FilterType + func (*FilterExpression) Descriptor() ([]byte, []int) + func (*FilterExpression) ProtoMessage() + func (x *FilterExpression) GetExpression() string + func (x *FilterExpression) GetType() FilterType + func (x *FilterExpression) ProtoReflect() protoreflect.Message + func (x *FilterExpression) Reset() + func (x *FilterExpression) String() string + type FilterType int32 + const FilterType_FILTER_TYPE_UNSPECIFIED + const FilterType_SQL + const FilterType_TAG + func (FilterType) Descriptor() protoreflect.EnumDescriptor + func (FilterType) EnumDescriptor() ([]byte, []int) + func (FilterType) Type() protoreflect.EnumType + func (x FilterType) Enum() *FilterType + func (x FilterType) Number() protoreflect.EnumNumber + func (x FilterType) String() string + type ForwardMessageToDeadLetterQueueRequest struct + DeliveryAttempt int32 + Group *Resource + MaxDeliveryAttempts int32 + MessageId string + ReceiptHandle string + Topic *Resource + func (*ForwardMessageToDeadLetterQueueRequest) Descriptor() ([]byte, []int) + func (*ForwardMessageToDeadLetterQueueRequest) ProtoMessage() + func (x *ForwardMessageToDeadLetterQueueRequest) GetDeliveryAttempt() int32 + func (x *ForwardMessageToDeadLetterQueueRequest) GetGroup() *Resource + func (x *ForwardMessageToDeadLetterQueueRequest) GetMaxDeliveryAttempts() int32 + func (x *ForwardMessageToDeadLetterQueueRequest) GetMessageId() string + func (x *ForwardMessageToDeadLetterQueueRequest) GetReceiptHandle() string + func (x *ForwardMessageToDeadLetterQueueRequest) GetTopic() *Resource + func (x *ForwardMessageToDeadLetterQueueRequest) ProtoReflect() protoreflect.Message + func (x *ForwardMessageToDeadLetterQueueRequest) Reset() + func (x *ForwardMessageToDeadLetterQueueRequest) String() string + type ForwardMessageToDeadLetterQueueResponse struct + Status *Status + func (*ForwardMessageToDeadLetterQueueResponse) Descriptor() ([]byte, []int) + func (*ForwardMessageToDeadLetterQueueResponse) ProtoMessage() + func (x *ForwardMessageToDeadLetterQueueResponse) GetStatus() *Status + func (x *ForwardMessageToDeadLetterQueueResponse) ProtoReflect() protoreflect.Message + func (x *ForwardMessageToDeadLetterQueueResponse) Reset() + func (x *ForwardMessageToDeadLetterQueueResponse) String() string + type HeartbeatRequest struct + ClientType ClientType + Group *Resource + func (*HeartbeatRequest) Descriptor() ([]byte, []int) + func (*HeartbeatRequest) ProtoMessage() + func (x *HeartbeatRequest) GetClientType() ClientType + func (x *HeartbeatRequest) GetGroup() *Resource + func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message + func (x *HeartbeatRequest) Reset() + func (x *HeartbeatRequest) String() string + type HeartbeatResponse struct + Status *Status + func (*HeartbeatResponse) Descriptor() ([]byte, []int) + func (*HeartbeatResponse) ProtoMessage() + func (x *HeartbeatResponse) GetStatus() *Status + func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message + func (x *HeartbeatResponse) Reset() + func (x *HeartbeatResponse) String() string + type Language int32 + const Language_CPP + const Language_DART + const Language_DOT_NET + const Language_GOLANG + const Language_JAVA + const Language_KOTLIN + const Language_LANGUAGE_UNSPECIFIED + const Language_NODE_JS + const Language_OBJECTIVE_C + const Language_PHP + const Language_PYTHON + const Language_RUBY + const Language_RUST + func (Language) Descriptor() protoreflect.EnumDescriptor + func (Language) EnumDescriptor() ([]byte, []int) + func (Language) Type() protoreflect.EnumType + func (x Language) Enum() *Language + func (x Language) Number() protoreflect.EnumNumber + func (x Language) String() string + type Message struct + Body []byte + SystemProperties *SystemProperties + Topic *Resource + UserProperties map[string]string + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + func (x *Message) GetBody() []byte + func (x *Message) GetSystemProperties() *SystemProperties + func (x *Message) GetTopic() *Resource + func (x *Message) GetUserProperties() map[string]string + func (x *Message) ProtoReflect() protoreflect.Message + func (x *Message) Reset() + func (x *Message) String() string + type MessageQueue struct + AcceptMessageTypes []MessageType + Broker *Broker + Id int32 + Permission Permission + Topic *Resource + func (*MessageQueue) Descriptor() ([]byte, []int) + func (*MessageQueue) ProtoMessage() + func (x *MessageQueue) GetAcceptMessageTypes() []MessageType + func (x *MessageQueue) GetBroker() *Broker + func (x *MessageQueue) GetId() int32 + func (x *MessageQueue) GetPermission() Permission + func (x *MessageQueue) GetTopic() *Resource + func (x *MessageQueue) ProtoReflect() protoreflect.Message + func (x *MessageQueue) Reset() + func (x *MessageQueue) String() string + type MessageType int32 + const MessageType_DELAY + const MessageType_FIFO + const MessageType_MESSAGE_TYPE_UNSPECIFIED + const MessageType_NORMAL + const MessageType_TRANSACTION + func (MessageType) Descriptor() protoreflect.EnumDescriptor + func (MessageType) EnumDescriptor() ([]byte, []int) + func (MessageType) Type() protoreflect.EnumType + func (x MessageType) Enum() *MessageType + func (x MessageType) Number() protoreflect.EnumNumber + func (x MessageType) String() string + type MessagingServiceClient interface + AckMessage func(ctx context.Context, in *AckMessageRequest, opts ...grpc.CallOption) (*AckMessageResponse, error) + ChangeInvisibleDuration func(ctx context.Context, in *ChangeInvisibleDurationRequest, ...) (*ChangeInvisibleDurationResponse, error) + EndTransaction func(ctx context.Context, in *EndTransactionRequest, opts ...grpc.CallOption) (*EndTransactionResponse, error) + ForwardMessageToDeadLetterQueue func(ctx context.Context, in *ForwardMessageToDeadLetterQueueRequest, ...) (*ForwardMessageToDeadLetterQueueResponse, error) + Heartbeat func(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error) + NotifyClientTermination func(ctx context.Context, in *NotifyClientTerminationRequest, ...) (*NotifyClientTerminationResponse, error) + QueryAssignment func(ctx context.Context, in *QueryAssignmentRequest, opts ...grpc.CallOption) (*QueryAssignmentResponse, error) + QueryRoute func(ctx context.Context, in *QueryRouteRequest, opts ...grpc.CallOption) (*QueryRouteResponse, error) + ReceiveMessage func(ctx context.Context, in *ReceiveMessageRequest, opts ...grpc.CallOption) (MessagingService_ReceiveMessageClient, error) + SendMessage func(ctx context.Context, in *SendMessageRequest, opts ...grpc.CallOption) (*SendMessageResponse, error) + Telemetry func(ctx context.Context, opts ...grpc.CallOption) (MessagingService_TelemetryClient, error) + func NewMessagingServiceClient(cc grpc.ClientConnInterface) MessagingServiceClient + type MessagingServiceServer interface + AckMessage func(context.Context, *AckMessageRequest) (*AckMessageResponse, error) + ChangeInvisibleDuration func(context.Context, *ChangeInvisibleDurationRequest) (*ChangeInvisibleDurationResponse, error) + EndTransaction func(context.Context, *EndTransactionRequest) (*EndTransactionResponse, error) + ForwardMessageToDeadLetterQueue func(context.Context, *ForwardMessageToDeadLetterQueueRequest) (*ForwardMessageToDeadLetterQueueResponse, error) + Heartbeat func(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error) + NotifyClientTermination func(context.Context, *NotifyClientTerminationRequest) (*NotifyClientTerminationResponse, error) + QueryAssignment func(context.Context, *QueryAssignmentRequest) (*QueryAssignmentResponse, error) + QueryRoute func(context.Context, *QueryRouteRequest) (*QueryRouteResponse, error) + ReceiveMessage func(*ReceiveMessageRequest, MessagingService_ReceiveMessageServer) error + SendMessage func(context.Context, *SendMessageRequest) (*SendMessageResponse, error) + Telemetry func(MessagingService_TelemetryServer) error + type MessagingService_ReceiveMessageClient interface + Recv func() (*ReceiveMessageResponse, error) + type MessagingService_ReceiveMessageServer interface + Send func(*ReceiveMessageResponse) error + type MessagingService_TelemetryClient interface + Recv func() (*TelemetryCommand, error) + Send func(*TelemetryCommand) error + type MessagingService_TelemetryServer interface + Recv func() (*TelemetryCommand, error) + Send func(*TelemetryCommand) error + type Metric struct + Endpoints *Endpoints + On bool + func (*Metric) Descriptor() ([]byte, []int) + func (*Metric) ProtoMessage() + func (x *Metric) GetEndpoints() *Endpoints + func (x *Metric) GetOn() bool + func (x *Metric) ProtoReflect() protoreflect.Message + func (x *Metric) Reset() + func (x *Metric) String() string + type NotifyClientTerminationRequest struct + Group *Resource + func (*NotifyClientTerminationRequest) Descriptor() ([]byte, []int) + func (*NotifyClientTerminationRequest) ProtoMessage() + func (x *NotifyClientTerminationRequest) GetGroup() *Resource + func (x *NotifyClientTerminationRequest) ProtoReflect() protoreflect.Message + func (x *NotifyClientTerminationRequest) Reset() + func (x *NotifyClientTerminationRequest) String() string + type NotifyClientTerminationResponse struct + Status *Status + func (*NotifyClientTerminationResponse) Descriptor() ([]byte, []int) + func (*NotifyClientTerminationResponse) ProtoMessage() + func (x *NotifyClientTerminationResponse) GetStatus() *Status + func (x *NotifyClientTerminationResponse) ProtoReflect() protoreflect.Message + func (x *NotifyClientTerminationResponse) Reset() + func (x *NotifyClientTerminationResponse) String() string + type Permission int32 + const Permission_NONE + const Permission_PERMISSION_UNSPECIFIED + const Permission_READ + const Permission_READ_WRITE + const Permission_WRITE + func (Permission) Descriptor() protoreflect.EnumDescriptor + func (Permission) EnumDescriptor() ([]byte, []int) + func (Permission) Type() protoreflect.EnumType + func (x Permission) Enum() *Permission + func (x Permission) Number() protoreflect.EnumNumber + func (x Permission) String() string + type PrintThreadStackTraceCommand struct + Nonce string + func (*PrintThreadStackTraceCommand) Descriptor() ([]byte, []int) + func (*PrintThreadStackTraceCommand) ProtoMessage() + func (x *PrintThreadStackTraceCommand) GetNonce() string + func (x *PrintThreadStackTraceCommand) ProtoReflect() protoreflect.Message + func (x *PrintThreadStackTraceCommand) Reset() + func (x *PrintThreadStackTraceCommand) String() string + type Publishing struct + MaxBodySize int32 + Topics []*Resource + ValidateMessageType bool + func (*Publishing) Descriptor() ([]byte, []int) + func (*Publishing) ProtoMessage() + func (x *Publishing) GetMaxBodySize() int32 + func (x *Publishing) GetTopics() []*Resource + func (x *Publishing) GetValidateMessageType() bool + func (x *Publishing) ProtoReflect() protoreflect.Message + func (x *Publishing) Reset() + func (x *Publishing) String() string + type QueryAssignmentRequest struct + Endpoints *Endpoints + Group *Resource + Topic *Resource + func (*QueryAssignmentRequest) Descriptor() ([]byte, []int) + func (*QueryAssignmentRequest) ProtoMessage() + func (x *QueryAssignmentRequest) GetEndpoints() *Endpoints + func (x *QueryAssignmentRequest) GetGroup() *Resource + func (x *QueryAssignmentRequest) GetTopic() *Resource + func (x *QueryAssignmentRequest) ProtoReflect() protoreflect.Message + func (x *QueryAssignmentRequest) Reset() + func (x *QueryAssignmentRequest) String() string + type QueryAssignmentResponse struct + Assignments []*Assignment + Status *Status + func (*QueryAssignmentResponse) Descriptor() ([]byte, []int) + func (*QueryAssignmentResponse) ProtoMessage() + func (x *QueryAssignmentResponse) GetAssignments() []*Assignment + func (x *QueryAssignmentResponse) GetStatus() *Status + func (x *QueryAssignmentResponse) ProtoReflect() protoreflect.Message + func (x *QueryAssignmentResponse) Reset() + func (x *QueryAssignmentResponse) String() string + type QueryRouteRequest struct + Endpoints *Endpoints + Topic *Resource + func (*QueryRouteRequest) Descriptor() ([]byte, []int) + func (*QueryRouteRequest) ProtoMessage() + func (x *QueryRouteRequest) GetEndpoints() *Endpoints + func (x *QueryRouteRequest) GetTopic() *Resource + func (x *QueryRouteRequest) ProtoReflect() protoreflect.Message + func (x *QueryRouteRequest) Reset() + func (x *QueryRouteRequest) String() string + type QueryRouteResponse struct + MessageQueues []*MessageQueue + Status *Status + func (*QueryRouteResponse) Descriptor() ([]byte, []int) + func (*QueryRouteResponse) ProtoMessage() + func (x *QueryRouteResponse) GetMessageQueues() []*MessageQueue + func (x *QueryRouteResponse) GetStatus() *Status + func (x *QueryRouteResponse) ProtoReflect() protoreflect.Message + func (x *QueryRouteResponse) Reset() + func (x *QueryRouteResponse) String() string + type ReceiveMessageRequest struct + AutoRenew bool + BatchSize int32 + FilterExpression *FilterExpression + Group *Resource + InvisibleDuration *durationpb.Duration + MessageQueue *MessageQueue + func (*ReceiveMessageRequest) Descriptor() ([]byte, []int) + func (*ReceiveMessageRequest) ProtoMessage() + func (x *ReceiveMessageRequest) GetAutoRenew() bool + func (x *ReceiveMessageRequest) GetBatchSize() int32 + func (x *ReceiveMessageRequest) GetFilterExpression() *FilterExpression + func (x *ReceiveMessageRequest) GetGroup() *Resource + func (x *ReceiveMessageRequest) GetInvisibleDuration() *durationpb.Duration + func (x *ReceiveMessageRequest) GetMessageQueue() *MessageQueue + func (x *ReceiveMessageRequest) ProtoReflect() protoreflect.Message + func (x *ReceiveMessageRequest) Reset() + func (x *ReceiveMessageRequest) String() string + type ReceiveMessageResponse struct + Content isReceiveMessageResponse_Content + func (*ReceiveMessageResponse) Descriptor() ([]byte, []int) + func (*ReceiveMessageResponse) ProtoMessage() + func (m *ReceiveMessageResponse) GetContent() isReceiveMessageResponse_Content + func (x *ReceiveMessageResponse) GetDeliveryTimestamp() *timestamppb.Timestamp + func (x *ReceiveMessageResponse) GetMessage() *Message + func (x *ReceiveMessageResponse) GetStatus() *Status + func (x *ReceiveMessageResponse) ProtoReflect() protoreflect.Message + func (x *ReceiveMessageResponse) Reset() + func (x *ReceiveMessageResponse) String() string + type ReceiveMessageResponse_DeliveryTimestamp struct + DeliveryTimestamp *timestamppb.Timestamp + type ReceiveMessageResponse_Message struct + Message *Message + type ReceiveMessageResponse_Status struct + Status *Status + type RecoverOrphanedTransactionCommand struct + Message *Message + TransactionId string + func (*RecoverOrphanedTransactionCommand) Descriptor() ([]byte, []int) + func (*RecoverOrphanedTransactionCommand) ProtoMessage() + func (x *RecoverOrphanedTransactionCommand) GetMessage() *Message + func (x *RecoverOrphanedTransactionCommand) GetTransactionId() string + func (x *RecoverOrphanedTransactionCommand) ProtoReflect() protoreflect.Message + func (x *RecoverOrphanedTransactionCommand) Reset() + func (x *RecoverOrphanedTransactionCommand) String() string + type Resource struct + Name string + ResourceNamespace string + func (*Resource) Descriptor() ([]byte, []int) + func (*Resource) ProtoMessage() + func (x *Resource) GetName() string + func (x *Resource) GetResourceNamespace() string + func (x *Resource) ProtoReflect() protoreflect.Message + func (x *Resource) Reset() + func (x *Resource) String() string + type RetryPolicy struct + MaxAttempts int32 + Strategy isRetryPolicy_Strategy + func (*RetryPolicy) Descriptor() ([]byte, []int) + func (*RetryPolicy) ProtoMessage() + func (m *RetryPolicy) GetStrategy() isRetryPolicy_Strategy + func (x *RetryPolicy) GetCustomizedBackoff() *CustomizedBackoff + func (x *RetryPolicy) GetExponentialBackoff() *ExponentialBackoff + func (x *RetryPolicy) GetMaxAttempts() int32 + func (x *RetryPolicy) ProtoReflect() protoreflect.Message + func (x *RetryPolicy) Reset() + func (x *RetryPolicy) String() string + type RetryPolicy_CustomizedBackoff struct + CustomizedBackoff *CustomizedBackoff + type RetryPolicy_ExponentialBackoff struct + ExponentialBackoff *ExponentialBackoff + type SendMessageRequest struct + Messages []*Message + func (*SendMessageRequest) Descriptor() ([]byte, []int) + func (*SendMessageRequest) ProtoMessage() + func (x *SendMessageRequest) GetMessages() []*Message + func (x *SendMessageRequest) ProtoReflect() protoreflect.Message + func (x *SendMessageRequest) Reset() + func (x *SendMessageRequest) String() string + type SendMessageResponse struct + Entries []*SendResultEntry + Status *Status + func (*SendMessageResponse) Descriptor() ([]byte, []int) + func (*SendMessageResponse) ProtoMessage() + func (x *SendMessageResponse) GetEntries() []*SendResultEntry + func (x *SendMessageResponse) GetStatus() *Status + func (x *SendMessageResponse) ProtoReflect() protoreflect.Message + func (x *SendMessageResponse) Reset() + func (x *SendMessageResponse) String() string + type SendResultEntry struct + MessageId string + Offset int64 + Status *Status + TransactionId string + func (*SendResultEntry) Descriptor() ([]byte, []int) + func (*SendResultEntry) ProtoMessage() + func (x *SendResultEntry) GetMessageId() string + func (x *SendResultEntry) GetOffset() int64 + func (x *SendResultEntry) GetStatus() *Status + func (x *SendResultEntry) GetTransactionId() string + func (x *SendResultEntry) ProtoReflect() protoreflect.Message + func (x *SendResultEntry) Reset() + func (x *SendResultEntry) String() string + type Settings struct + AccessPoint *Endpoints + BackoffPolicy *RetryPolicy + ClientType *ClientType + Metric *Metric + PubSub isSettings_PubSub + RequestTimeout *durationpb.Duration + UserAgent *UA + func (*Settings) Descriptor() ([]byte, []int) + func (*Settings) ProtoMessage() + func (m *Settings) GetPubSub() isSettings_PubSub + func (x *Settings) GetAccessPoint() *Endpoints + func (x *Settings) GetBackoffPolicy() *RetryPolicy + func (x *Settings) GetClientType() ClientType + func (x *Settings) GetMetric() *Metric + func (x *Settings) GetPublishing() *Publishing + func (x *Settings) GetRequestTimeout() *durationpb.Duration + func (x *Settings) GetSubscription() *Subscription + func (x *Settings) GetUserAgent() *UA + func (x *Settings) ProtoReflect() protoreflect.Message + func (x *Settings) Reset() + func (x *Settings) String() string + type Settings_Publishing struct + Publishing *Publishing + type Settings_Subscription struct + Subscription *Subscription + type Status struct + Code Code + Message string + func (*Status) Descriptor() ([]byte, []int) + func (*Status) ProtoMessage() + func (x *Status) GetCode() Code + func (x *Status) GetMessage() string + func (x *Status) ProtoReflect() protoreflect.Message + func (x *Status) Reset() + func (x *Status) String() string + type Subscription struct + Fifo *bool + Group *Resource + LongPollingTimeout *durationpb.Duration + ReceiveBatchSize *int32 + Subscriptions []*SubscriptionEntry + func (*Subscription) Descriptor() ([]byte, []int) + func (*Subscription) ProtoMessage() + func (x *Subscription) GetFifo() bool + func (x *Subscription) GetGroup() *Resource + func (x *Subscription) GetLongPollingTimeout() *durationpb.Duration + func (x *Subscription) GetReceiveBatchSize() int32 + func (x *Subscription) GetSubscriptions() []*SubscriptionEntry + func (x *Subscription) ProtoReflect() protoreflect.Message + func (x *Subscription) Reset() + func (x *Subscription) String() string + type SubscriptionEntry struct + Expression *FilterExpression + Topic *Resource + func (*SubscriptionEntry) Descriptor() ([]byte, []int) + func (*SubscriptionEntry) ProtoMessage() + func (x *SubscriptionEntry) GetExpression() *FilterExpression + func (x *SubscriptionEntry) GetTopic() *Resource + func (x *SubscriptionEntry) ProtoReflect() protoreflect.Message + func (x *SubscriptionEntry) Reset() + func (x *SubscriptionEntry) String() string + type SystemProperties struct + BodyDigest *Digest + BodyEncoding Encoding + BornHost string + BornTimestamp *timestamppb.Timestamp + DeliveryAttempt *int32 + DeliveryTimestamp *timestamppb.Timestamp + InvisibleDuration *durationpb.Duration + Keys []string + MessageGroup *string + MessageId string + MessageType MessageType + OrphanedTransactionRecoveryDuration *durationpb.Duration + QueueId int32 + QueueOffset *int64 + ReceiptHandle *string + StoreHost string + StoreTimestamp *timestamppb.Timestamp + Tag *string + TraceContext *string + func (*SystemProperties) Descriptor() ([]byte, []int) + func (*SystemProperties) ProtoMessage() + func (x *SystemProperties) GetBodyDigest() *Digest + func (x *SystemProperties) GetBodyEncoding() Encoding + func (x *SystemProperties) GetBornHost() string + func (x *SystemProperties) GetBornTimestamp() *timestamppb.Timestamp + func (x *SystemProperties) GetDeliveryAttempt() int32 + func (x *SystemProperties) GetDeliveryTimestamp() *timestamppb.Timestamp + func (x *SystemProperties) GetInvisibleDuration() *durationpb.Duration + func (x *SystemProperties) GetKeys() []string + func (x *SystemProperties) GetMessageGroup() string + func (x *SystemProperties) GetMessageId() string + func (x *SystemProperties) GetMessageType() MessageType + func (x *SystemProperties) GetOrphanedTransactionRecoveryDuration() *durationpb.Duration + func (x *SystemProperties) GetQueueId() int32 + func (x *SystemProperties) GetQueueOffset() int64 + func (x *SystemProperties) GetReceiptHandle() string + func (x *SystemProperties) GetStoreHost() string + func (x *SystemProperties) GetStoreTimestamp() *timestamppb.Timestamp + func (x *SystemProperties) GetTag() string + func (x *SystemProperties) GetTraceContext() string + func (x *SystemProperties) ProtoReflect() protoreflect.Message + func (x *SystemProperties) Reset() + func (x *SystemProperties) String() string + type TelemetryCommand struct + Command isTelemetryCommand_Command + Status *Status + func (*TelemetryCommand) Descriptor() ([]byte, []int) + func (*TelemetryCommand) ProtoMessage() + func (m *TelemetryCommand) GetCommand() isTelemetryCommand_Command + func (x *TelemetryCommand) GetPrintThreadStackTraceCommand() *PrintThreadStackTraceCommand + func (x *TelemetryCommand) GetRecoverOrphanedTransactionCommand() *RecoverOrphanedTransactionCommand + func (x *TelemetryCommand) GetSettings() *Settings + func (x *TelemetryCommand) GetStatus() *Status + func (x *TelemetryCommand) GetThreadStackTrace() *ThreadStackTrace + func (x *TelemetryCommand) GetVerifyMessageCommand() *VerifyMessageCommand + func (x *TelemetryCommand) GetVerifyMessageResult() *VerifyMessageResult + func (x *TelemetryCommand) ProtoReflect() protoreflect.Message + func (x *TelemetryCommand) Reset() + func (x *TelemetryCommand) String() string + type TelemetryCommand_PrintThreadStackTraceCommand struct + PrintThreadStackTraceCommand *PrintThreadStackTraceCommand + type TelemetryCommand_RecoverOrphanedTransactionCommand struct + RecoverOrphanedTransactionCommand *RecoverOrphanedTransactionCommand + type TelemetryCommand_Settings struct + Settings *Settings + type TelemetryCommand_ThreadStackTrace struct + ThreadStackTrace *ThreadStackTrace + type TelemetryCommand_VerifyMessageCommand struct + VerifyMessageCommand *VerifyMessageCommand + type TelemetryCommand_VerifyMessageResult struct + VerifyMessageResult *VerifyMessageResult + type ThreadStackTrace struct + Nonce string + ThreadStackTrace *string + func (*ThreadStackTrace) Descriptor() ([]byte, []int) + func (*ThreadStackTrace) ProtoMessage() + func (x *ThreadStackTrace) GetNonce() string + func (x *ThreadStackTrace) GetThreadStackTrace() string + func (x *ThreadStackTrace) ProtoReflect() protoreflect.Message + func (x *ThreadStackTrace) Reset() + func (x *ThreadStackTrace) String() string + type TransactionResolution int32 + const TransactionResolution_COMMIT + const TransactionResolution_ROLLBACK + const TransactionResolution_TRANSACTION_RESOLUTION_UNSPECIFIED + func (TransactionResolution) Descriptor() protoreflect.EnumDescriptor + func (TransactionResolution) EnumDescriptor() ([]byte, []int) + func (TransactionResolution) Type() protoreflect.EnumType + func (x TransactionResolution) Enum() *TransactionResolution + func (x TransactionResolution) Number() protoreflect.EnumNumber + func (x TransactionResolution) String() string + type TransactionSource int32 + const TransactionSource_SOURCE_CLIENT + const TransactionSource_SOURCE_SERVER_CHECK + const TransactionSource_SOURCE_UNSPECIFIED + func (TransactionSource) Descriptor() protoreflect.EnumDescriptor + func (TransactionSource) EnumDescriptor() ([]byte, []int) + func (TransactionSource) Type() protoreflect.EnumType + func (x TransactionSource) Enum() *TransactionSource + func (x TransactionSource) Number() protoreflect.EnumNumber + func (x TransactionSource) String() string + type UA struct + Hostname string + Language Language + Platform string + Version string + func (*UA) Descriptor() ([]byte, []int) + func (*UA) ProtoMessage() + func (x *UA) GetHostname() string + func (x *UA) GetLanguage() Language + func (x *UA) GetPlatform() string + func (x *UA) GetVersion() string + func (x *UA) ProtoReflect() protoreflect.Message + func (x *UA) Reset() + func (x *UA) String() string + type UnimplementedAdminServer struct + func (UnimplementedAdminServer) ChangeLogLevel(context.Context, *ChangeLogLevelRequest) (*ChangeLogLevelResponse, error) + type UnimplementedMessagingServiceServer struct + func (UnimplementedMessagingServiceServer) AckMessage(context.Context, *AckMessageRequest) (*AckMessageResponse, error) + func (UnimplementedMessagingServiceServer) ChangeInvisibleDuration(context.Context, *ChangeInvisibleDurationRequest) (*ChangeInvisibleDurationResponse, error) + func (UnimplementedMessagingServiceServer) EndTransaction(context.Context, *EndTransactionRequest) (*EndTransactionResponse, error) + func (UnimplementedMessagingServiceServer) ForwardMessageToDeadLetterQueue(context.Context, *ForwardMessageToDeadLetterQueueRequest) (*ForwardMessageToDeadLetterQueueResponse, error) + func (UnimplementedMessagingServiceServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error) + func (UnimplementedMessagingServiceServer) NotifyClientTermination(context.Context, *NotifyClientTerminationRequest) (*NotifyClientTerminationResponse, error) + func (UnimplementedMessagingServiceServer) QueryAssignment(context.Context, *QueryAssignmentRequest) (*QueryAssignmentResponse, error) + func (UnimplementedMessagingServiceServer) QueryRoute(context.Context, *QueryRouteRequest) (*QueryRouteResponse, error) + func (UnimplementedMessagingServiceServer) ReceiveMessage(*ReceiveMessageRequest, MessagingService_ReceiveMessageServer) error + func (UnimplementedMessagingServiceServer) SendMessage(context.Context, *SendMessageRequest) (*SendMessageResponse, error) + func (UnimplementedMessagingServiceServer) Telemetry(MessagingService_TelemetryServer) error + type UnsafeAdminServer interface + type UnsafeMessagingServiceServer interface + type VerifyMessageCommand struct + Message *Message + Nonce string + func (*VerifyMessageCommand) Descriptor() ([]byte, []int) + func (*VerifyMessageCommand) ProtoMessage() + func (x *VerifyMessageCommand) GetMessage() *Message + func (x *VerifyMessageCommand) GetNonce() string + func (x *VerifyMessageCommand) ProtoReflect() protoreflect.Message + func (x *VerifyMessageCommand) Reset() + func (x *VerifyMessageCommand) String() string + type VerifyMessageResult struct + Nonce string + func (*VerifyMessageResult) Descriptor() ([]byte, []int) + func (*VerifyMessageResult) ProtoMessage() + func (x *VerifyMessageResult) GetNonce() string + func (x *VerifyMessageResult) ProtoReflect() protoreflect.Message + func (x *VerifyMessageResult) Reset() + func (x *VerifyMessageResult) String() string v5.1.1-rc1 May 28, 2024 v5.1.0-rc.1 Jan 10, 2024 v5.0.1-rc.5 Sep 5, 2023 v5.0.1-rc.4 Apr 18, 2023 v5.0.1-rc.3 Mar 22, 2023 v5.0.1-rc.2 Mar 22, 2023
Go to main page