v2

package
v5.1.0-rc.1 Latest Latest
Warning

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

 Go to latest Published: Jan 10, 2024 License: Apache-2.0 Imports: 10 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ChangeLogLevelRequest_Level_name = map[int32]string{
		0: "TRACE",
		1: "DEBUG",
		2: "INFO",
		3: "WARN",
		4: "ERROR",
	}
	ChangeLogLevelRequest_Level_value = map[string]int32{
		"TRACE": 0,
		"DEBUG": 1,
		"INFO":  2,
		"WARN":  3,
		"ERROR": 4,
	}
)

Enum value maps for ChangeLogLevelRequest_Level.

View Source 
var (
	TransactionResolution_name = map[int32]string{
		0: "TRANSACTION_RESOLUTION_UNSPECIFIED",
		1: "COMMIT",
		2: "ROLLBACK",
	}
	TransactionResolution_value = map[string]int32{
		"TRANSACTION_RESOLUTION_UNSPECIFIED": 0,
		"COMMIT":                             1,
		"ROLLBACK":                           2,
	}
)

Enum value maps for TransactionResolution.

View Source 
var (
	TransactionSource_name = map[int32]string{
		0: "SOURCE_UNSPECIFIED",
		1: "SOURCE_CLIENT",
		2: "SOURCE_SERVER_CHECK",
	}
	TransactionSource_value = map[string]int32{
		"SOURCE_UNSPECIFIED":  0,
		"SOURCE_CLIENT":       1,
		"SOURCE_SERVER_CHECK": 2,
	}
)

Enum value maps for TransactionSource.

View Source 
var (
	Permission_name = map[int32]string{
		0: "PERMISSION_UNSPECIFIED",
		1: "NONE",
		2: "READ",
		3: "WRITE",
		4: "READ_WRITE",
	}
	Permission_value = map[string]int32{
		"PERMISSION_UNSPECIFIED": 0,
		"NONE":                   1,
		"READ":                   2,
		"WRITE":                  3,
		"READ_WRITE":             4,
	}
)

Enum value maps for Permission.

View Source 
var (
	FilterType_name = map[int32]string{
		0: "FILTER_TYPE_UNSPECIFIED",
		1: "TAG",
		2: "SQL",
	}
	FilterType_value = map[string]int32{
		"FILTER_TYPE_UNSPECIFIED": 0,
		"TAG":                     1,
		"SQL":                     2,
	}
)

Enum value maps for FilterType.

View Source 
var (
	AddressScheme_name = map[int32]string{
		0: "ADDRESS_SCHEME_UNSPECIFIED",
		1: "IPv4",
		2: "IPv6",
		3: "DOMAIN_NAME",
	}
	AddressScheme_value = map[string]int32{
		"ADDRESS_SCHEME_UNSPECIFIED": 0,
		"IPv4":                       1,
		"IPv6":                       2,
		"DOMAIN_NAME":                3,
	}
)

Enum value maps for AddressScheme.

View Source 
var (
	MessageType_name = map[int32]string{
		0: "MESSAGE_TYPE_UNSPECIFIED",
		1: "NORMAL",
		2: "FIFO",
		3: "DELAY",
		4: "TRANSACTION",
	}
	MessageType_value = map[string]int32{
		"MESSAGE_TYPE_UNSPECIFIED": 0,
		"NORMAL":                   1,
		"FIFO":                     2,
		"DELAY":                    3,
		"TRANSACTION":              4,
	}
)

Enum value maps for MessageType.

View Source 
var (
	DigestType_name = map[int32]string{
		0: "DIGEST_TYPE_UNSPECIFIED",
		1: "CRC32",
		2: "MD5",
		3: "SHA1",
	}
	DigestType_value = map[string]int32{
		"DIGEST_TYPE_UNSPECIFIED": 0,
		"CRC32":                   1,
		"MD5":                     2,
		"SHA1":                    3,
	}
)

Enum value maps for DigestType.

View Source 
var (
	ClientType_name = map[int32]string{
		0: "CLIENT_TYPE_UNSPECIFIED",
		1: "PRODUCER",
		2: "PUSH_CONSUMER",
		3: "SIMPLE_CONSUMER",
	}
	ClientType_value = map[string]int32{
		"CLIENT_TYPE_UNSPECIFIED": 0,
		"PRODUCER":                1,
		"PUSH_CONSUMER":           2,
		"SIMPLE_CONSUMER":         3,
	}
)

Enum value maps for ClientType.

View Source 
var (
	Encoding_name = map[int32]string{
		0: "ENCODING_UNSPECIFIED",
		1: "IDENTITY",
		2: "GZIP",
	}
	Encoding_value = map[string]int32{
		"ENCODING_UNSPECIFIED": 0,
		"IDENTITY":             1,
		"GZIP":                 2,
	}
)

Enum value maps for Encoding.

View Source 
var (
	Code_name = map[int32]string{
		0:     "CODE_UNSPECIFIED",
		20000: "OK",
		30000: "MULTIPLE_RESULTS",
		40000: "BAD_REQUEST",
		40001: "ILLEGAL_ACCESS_POINT",
		40002: "ILLEGAL_TOPIC",
		40003: "ILLEGAL_CONSUMER_GROUP",
		40004: "ILLEGAL_MESSAGE_TAG",
		40005: "ILLEGAL_MESSAGE_KEY",
		40006: "ILLEGAL_MESSAGE_GROUP",
		40007: "ILLEGAL_MESSAGE_PROPERTY_KEY",
		40008: "INVALID_TRANSACTION_ID",
		40009: "ILLEGAL_MESSAGE_ID",
		40010: "ILLEGAL_FILTER_EXPRESSION",
		40011: "ILLEGAL_INVISIBLE_TIME",
		40012: "ILLEGAL_DELIVERY_TIME",
		40013: "INVALID_RECEIPT_HANDLE",
		40014: "MESSAGE_PROPERTY_CONFLICT_WITH_TYPE",
		40015: "UNRECOGNIZED_CLIENT_TYPE",
		40016: "MESSAGE_CORRUPTED",
		40017: "CLIENT_ID_REQUIRED",
		40100: "UNAUTHORIZED",
		40200: "PAYMENT_REQUIRED",
		40300: "FORBIDDEN",
		40400: "NOT_FOUND",
		40401: "MESSAGE_NOT_FOUND",
		40402: "TOPIC_NOT_FOUND",
		40403: "CONSUMER_GROUP_NOT_FOUND",
		40800: "REQUEST_TIMEOUT",
		41300: "PAYLOAD_TOO_LARGE",
		41301: "MESSAGE_BODY_TOO_LARGE",
		42800: "PRECONDITION_FAILED",
		42900: "TOO_MANY_REQUESTS",
		43100: "REQUEST_HEADER_FIELDS_TOO_LARGE",
		43101: "MESSAGE_PROPERTIES_TOO_LARGE",
		50000: "INTERNAL_ERROR",
		50001: "INTERNAL_SERVER_ERROR",
		50002: "HA_NOT_AVAILABLE",
		50100: "NOT_IMPLEMENTED",
		50400: "PROXY_TIMEOUT",
		50401: "MASTER_PERSISTENCE_TIMEOUT",
		50402: "SLAVE_PERSISTENCE_TIMEOUT",
		50500: "UNSUPPORTED",
		50501: "VERSION_UNSUPPORTED",
		50502: "VERIFY_FIFO_MESSAGE_UNSUPPORTED",
		60000: "FAILED_TO_CONSUME_MESSAGE",
	}
	Code_value = map[string]int32{
		"CODE_UNSPECIFIED":                    0,
		"OK":                                  20000,
		"MULTIPLE_RESULTS":                    30000,
		"BAD_REQUEST":                         40000,
		"ILLEGAL_ACCESS_POINT":                40001,
		"ILLEGAL_TOPIC":                       40002,
		"ILLEGAL_CONSUMER_GROUP":              40003,
		"ILLEGAL_MESSAGE_TAG":                 40004,
		"ILLEGAL_MESSAGE_KEY":                 40005,
		"ILLEGAL_MESSAGE_GROUP":               40006,
		"ILLEGAL_MESSAGE_PROPERTY_KEY":        40007,
		"INVALID_TRANSACTION_ID":              40008,
		"ILLEGAL_MESSAGE_ID":                  40009,
		"ILLEGAL_FILTER_EXPRESSION":           40010,
		"ILLEGAL_INVISIBLE_TIME":              40011,
		"ILLEGAL_DELIVERY_TIME":               40012,
		"INVALID_RECEIPT_HANDLE":              40013,
		"MESSAGE_PROPERTY_CONFLICT_WITH_TYPE": 40014,
		"UNRECOGNIZED_CLIENT_TYPE":            40015,
		"MESSAGE_CORRUPTED":                   40016,
		"CLIENT_ID_REQUIRED":                  40017,
		"UNAUTHORIZED":                        40100,
		"PAYMENT_REQUIRED":                    40200,
		"FORBIDDEN":                           40300,
		"NOT_FOUND":                           40400,
		"MESSAGE_NOT_FOUND":                   40401,
		"TOPIC_NOT_FOUND":                     40402,
		"CONSUMER_GROUP_NOT_FOUND":            40403,
		"REQUEST_TIMEOUT":                     40800,
		"PAYLOAD_TOO_LARGE":                   41300,
		"MESSAGE_BODY_TOO_LARGE":              41301,
		"PRECONDITION_FAILED":                 42800,
		"TOO_MANY_REQUESTS":                   42900,
		"REQUEST_HEADER_FIELDS_TOO_LARGE":     43100,
		"MESSAGE_PROPERTIES_TOO_LARGE":        43101,
		"INTERNAL_ERROR":                      50000,
		"INTERNAL_SERVER_ERROR":               50001,
		"HA_NOT_AVAILABLE":                    50002,
		"NOT_IMPLEMENTED":                     50100,
		"PROXY_TIMEOUT":                       50400,
		"MASTER_PERSISTENCE_TIMEOUT":          50401,
		"SLAVE_PERSISTENCE_TIMEOUT":           50402,
		"UNSUPPORTED":                         50500,
		"VERSION_UNSUPPORTED":                 50501,
		"VERIFY_FIFO_MESSAGE_UNSUPPORTED":     50502,
		"FAILED_TO_CONSUME_MESSAGE":           60000,
	}
)

Enum value maps for Code.

View Source 
var (
	Language_name = map[int32]string{
		0:  "LANGUAGE_UNSPECIFIED",
		1:  "JAVA",
		2:  "CPP",
		3:  "DOT_NET",
		4:  "GOLANG",
		5:  "RUST",
		6:  "PYTHON",
		7:  "PHP",
		8:  "NODE_JS",
		9:  "RUBY",
		10: "OBJECTIVE_C",
		11: "DART",
		12: "KOTLIN",
	}
	Language_value = map[string]int32{
		"LANGUAGE_UNSPECIFIED": 0,
		"JAVA":                 1,
		"CPP":                  2,
		"DOT_NET":              3,
		"GOLANG":               4,
		"RUST":                 5,
		"PYTHON":               6,
		"PHP":                  7,
		"NODE_JS":              8,
		"RUBY":                 9,
		"OBJECTIVE_C":          10,
		"DART":                 11,
		"KOTLIN":               12,
	}
)

Enum value maps for Language.

View Source 
var Admin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "apache.rocketmq.v2.Admin",
	HandlerType: (*AdminServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ChangeLogLevel",
			Handler:    _Admin_ChangeLogLevel_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "admin.proto",
}

Admin_ServiceDesc is the grpc.ServiceDesc for Admin 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_admin_proto protoreflect.FileDescriptor
View Source 
var File_definition_proto protoreflect.FileDescriptor
View Source 
var File_service_proto protoreflect.FileDescriptor
View Source 
var MessagingService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "apache.rocketmq.v2.MessagingService",
	HandlerType: (*MessagingServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "QueryRoute",
			Handler:    _MessagingService_QueryRoute_Handler,
		},
		{
			MethodName: "Heartbeat",
			Handler:    _MessagingService_Heartbeat_Handler,
		},
		{
			MethodName: "SendMessage",
			Handler:    _MessagingService_SendMessage_Handler,
		},
		{
			MethodName: "QueryAssignment",
			Handler:    _MessagingService_QueryAssignment_Handler,
		},
		{
			MethodName: "AckMessage",
			Handler:    _MessagingService_AckMessage_Handler,
		},
		{
			MethodName: "ForwardMessageToDeadLetterQueue",
			Handler:    _MessagingService_ForwardMessageToDeadLetterQueue_Handler,
		},
		{
			MethodName: "EndTransaction",
			Handler:    _MessagingService_EndTransaction_Handler,
		},
		{
			MethodName: "NotifyClientTermination",
			Handler:    _MessagingService_NotifyClientTermination_Handler,
		},
		{
			MethodName: "ChangeInvisibleDuration",
			Handler:    _MessagingService_ChangeInvisibleDuration_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ReceiveMessage",
			Handler:       _MessagingService_ReceiveMessage_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Telemetry",
			Handler:       _MessagingService_Telemetry_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "service.proto",
}

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

Functions

func RegisterAdminServer 

func RegisterAdminServer(s grpc.ServiceRegistrar, srv AdminServer)

func RegisterMessagingServiceServer 

func RegisterMessagingServiceServer(s grpc.ServiceRegistrar, srv MessagingServiceServer)

Types

type AckMessageEntry 

type AckMessageEntry struct {
	MessageId     string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	ReceiptHandle string `protobuf:"bytes,2,opt,name=receipt_handle,json=receiptHandle,proto3" json:"receipt_handle,omitempty"`
	// contains filtered or unexported fields
}

func (*AckMessageEntry) Descriptor deprecated 

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

Deprecated: Use AckMessageEntry.ProtoReflect.Descriptor instead.

func (*AckMessageEntry) GetMessageId 

func (x *AckMessageEntry) GetMessageId() string

func (*AckMessageEntry) GetReceiptHandle 

func (x *AckMessageEntry) GetReceiptHandle() string

func (*AckMessageEntry) ProtoMessage 

func (*AckMessageEntry) ProtoMessage()

func (*AckMessageEntry) ProtoReflect 

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

func (*AckMessageEntry) Reset 

func (x *AckMessageEntry) Reset()

func (*AckMessageEntry) String 

func (x *AckMessageEntry) String() string

type AckMessageRequest 

type AckMessageRequest struct {
	Group   *Resource          `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	Topic   *Resource          `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Entries []*AckMessageEntry `protobuf:"bytes,3,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*AckMessageRequest) Descriptor deprecated 

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

Deprecated: Use AckMessageRequest.ProtoReflect.Descriptor instead.

func (*AckMessageRequest) GetEntries 

func (x *AckMessageRequest) GetEntries() []*AckMessageEntry

func (*AckMessageRequest) GetGroup 

func (x *AckMessageRequest) GetGroup() *Resource

func (*AckMessageRequest) GetTopic 

func (x *AckMessageRequest) GetTopic() *Resource

func (*AckMessageRequest) ProtoMessage 

func (*AckMessageRequest) ProtoMessage()

func (*AckMessageRequest) ProtoReflect 

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

func (*AckMessageRequest) Reset 

func (x *AckMessageRequest) Reset()

func (*AckMessageRequest) String 

func (x *AckMessageRequest) String() string

type AckMessageResponse 

type AckMessageResponse struct {

	// RPC tier status, which is used to represent RPC-level errors including
	// authentication, authorization, throttling and other general failures.
	Status  *Status                  `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Entries []*AckMessageResultEntry `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*AckMessageResponse) Descriptor deprecated 

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

Deprecated: Use AckMessageResponse.ProtoReflect.Descriptor instead.

func (*AckMessageResponse) GetEntries 

func (x *AckMessageResponse) GetEntries() []*AckMessageResultEntry

func (*AckMessageResponse) GetStatus 

func (x *AckMessageResponse) GetStatus() *Status

func (*AckMessageResponse) ProtoMessage 

func (*AckMessageResponse) ProtoMessage()

func (*AckMessageResponse) ProtoReflect 

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

func (*AckMessageResponse) Reset 

func (x *AckMessageResponse) Reset()

func (*AckMessageResponse) String 

func (x *AckMessageResponse) String() string

type AckMessageResultEntry 

type AckMessageResultEntry struct {
	MessageId     string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	ReceiptHandle string `protobuf:"bytes,2,opt,name=receipt_handle,json=receiptHandle,proto3" json:"receipt_handle,omitempty"`
	// Acknowledge result may be acquired through inspecting
	// `status.code`; In case acknowledgement failed, `status.message`
	// is the explanation of the failure.
	Status *Status `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*AckMessageResultEntry) Descriptor deprecated 

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

Deprecated: Use AckMessageResultEntry.ProtoReflect.Descriptor instead.

func (*AckMessageResultEntry) GetMessageId 

func (x *AckMessageResultEntry) GetMessageId() string

func (*AckMessageResultEntry) GetReceiptHandle 

func (x *AckMessageResultEntry) GetReceiptHandle() string

func (*AckMessageResultEntry) GetStatus 

func (x *AckMessageResultEntry) GetStatus() *Status

func (*AckMessageResultEntry) ProtoMessage 

func (*AckMessageResultEntry) ProtoMessage()

func (*AckMessageResultEntry) ProtoReflect 

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

func (*AckMessageResultEntry) Reset 

func (x *AckMessageResultEntry) Reset()

func (*AckMessageResultEntry) String 

func (x *AckMessageResultEntry) String() string

type Address 

type Address struct {
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port int32  `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*Address) Descriptor deprecated 

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

Deprecated: Use Address.ProtoReflect.Descriptor instead.

func (*Address) GetHost 

func (x *Address) GetHost() string

func (*Address) GetPort 

func (x *Address) GetPort() int32

func (*Address) ProtoMessage 

func (*Address) ProtoMessage()

func (*Address) ProtoReflect 

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

func (*Address) Reset 

func (x *Address) Reset()

func (*Address) String 

func (x *Address) String() string

type AddressScheme 

type AddressScheme int32
const (
	AddressScheme_ADDRESS_SCHEME_UNSPECIFIED AddressScheme = 0
	AddressScheme_IPv4                       AddressScheme = 1
	AddressScheme_IPv6                       AddressScheme = 2
	AddressScheme_DOMAIN_NAME                AddressScheme = 3
)

func (AddressScheme) Descriptor 

func (AddressScheme) Descriptor() protoreflect.EnumDescriptor

func (AddressScheme) Enum 

func (x AddressScheme) Enum() *AddressScheme

func (AddressScheme) EnumDescriptor deprecated 

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

Deprecated: Use AddressScheme.Descriptor instead.

func (AddressScheme) Number 

func (x AddressScheme) Number() protoreflect.EnumNumber

func (AddressScheme) String 

func (x AddressScheme) String() string

func (AddressScheme) Type 

func (AddressScheme) Type() protoreflect.EnumType

type AdminClient 

type AdminClient interface {
	ChangeLogLevel(ctx context.Context, in *ChangeLogLevelRequest, opts ...grpc.CallOption) (*ChangeLogLevelResponse, error)
}

AdminClient is the client API for Admin 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 NewAdminClient 

func NewAdminClient(cc grpc.ClientConnInterface) AdminClient

type AdminServer 

type AdminServer interface {
	ChangeLogLevel(context.Context, *ChangeLogLevelRequest) (*ChangeLogLevelResponse, error)
	// contains filtered or unexported methods
}

AdminServer is the server API for Admin service. All implementations must embed UnimplementedAdminServer for forward compatibility

type Assignment 

type Assignment struct {
	MessageQueue *MessageQueue `protobuf:"bytes,1,opt,name=message_queue,json=messageQueue,proto3" json:"message_queue,omitempty"`
	// contains filtered or unexported fields
}

func (*Assignment) Descriptor deprecated 

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

Deprecated: Use Assignment.ProtoReflect.Descriptor instead.

func (*Assignment) GetMessageQueue 

func (x *Assignment) GetMessageQueue() *MessageQueue

func (*Assignment) ProtoMessage 

func (*Assignment) ProtoMessage()

func (*Assignment) ProtoReflect 

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

func (*Assignment) Reset 

func (x *Assignment) Reset()

func (*Assignment) String 

func (x *Assignment) String() string

type Broker 

type Broker struct {

	// Name of the broker
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Broker index. Canonically, index = 0 implies that the broker is playing
	// leader role while brokers with index > 0 play follower role.
	Id int32 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// Address of the broker, complying with the following scheme
	// 1. dns:[//authority/]host[:port]
	// 2. ipv4:address[:port][,address[:port],...] – IPv4 addresses
	// 3. ipv6:address[:port][,address[:port],...] – IPv6 addresses
	Endpoints *Endpoints `protobuf:"bytes,3,opt,name=endpoints,proto3" json:"endpoints,omitempty"`
	// contains filtered or unexported fields
}

func (*Broker) Descriptor deprecated 

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

Deprecated: Use Broker.ProtoReflect.Descriptor instead.

func (*Broker) GetEndpoints 

func (x *Broker) GetEndpoints() *Endpoints

func (*Broker) GetId 

func (x *Broker) GetId() int32

func (*Broker) GetName 

func (x *Broker) GetName() string

func (*Broker) ProtoMessage 

func (*Broker) ProtoMessage()

func (*Broker) ProtoReflect 

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

func (*Broker) Reset 

func (x *Broker) Reset()

func (*Broker) String 

func (x *Broker) String() string

type ChangeInvisibleDurationRequest 

type ChangeInvisibleDurationRequest struct {
	Group *Resource `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	Topic *Resource `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// Unique receipt handle to identify message to change
	ReceiptHandle string `protobuf:"bytes,3,opt,name=receipt_handle,json=receiptHandle,proto3" json:"receipt_handle,omitempty"`
	// New invisible duration
	InvisibleDuration *durationpb.Duration `protobuf:"bytes,4,opt,name=invisible_duration,json=invisibleDuration,proto3" json:"invisible_duration,omitempty"`
	// For message tracing
	MessageId string `protobuf:"bytes,5,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeInvisibleDurationRequest) Descriptor deprecated 

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

Deprecated: Use ChangeInvisibleDurationRequest.ProtoReflect.Descriptor instead.

func (*ChangeInvisibleDurationRequest) GetGroup 

func (x *ChangeInvisibleDurationRequest) GetGroup() *Resource

func (*ChangeInvisibleDurationRequest) GetInvisibleDuration 

func (x *ChangeInvisibleDurationRequest) GetInvisibleDuration() *durationpb.Duration

func (*ChangeInvisibleDurationRequest) GetMessageId 

func (x *ChangeInvisibleDurationRequest) GetMessageId() string

func (*ChangeInvisibleDurationRequest) GetReceiptHandle 

func (x *ChangeInvisibleDurationRequest) GetReceiptHandle() string

func (*ChangeInvisibleDurationRequest) GetTopic 

func (x *ChangeInvisibleDurationRequest) GetTopic() *Resource

func (*ChangeInvisibleDurationRequest) ProtoMessage 

func (*ChangeInvisibleDurationRequest) ProtoMessage()

func (*ChangeInvisibleDurationRequest) ProtoReflect 

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

func (*ChangeInvisibleDurationRequest) Reset 

func (x *ChangeInvisibleDurationRequest) Reset()

func (*ChangeInvisibleDurationRequest) String 

func (x *ChangeInvisibleDurationRequest) String() string

type ChangeInvisibleDurationResponse 

type ChangeInvisibleDurationResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// Server may generate a new receipt handle for the message.
	ReceiptHandle string `protobuf:"bytes,2,opt,name=receipt_handle,json=receiptHandle,proto3" json:"receipt_handle,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeInvisibleDurationResponse) Descriptor deprecated 

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

Deprecated: Use ChangeInvisibleDurationResponse.ProtoReflect.Descriptor instead.

func (*ChangeInvisibleDurationResponse) GetReceiptHandle 

func (x *ChangeInvisibleDurationResponse) GetReceiptHandle() string

func (*ChangeInvisibleDurationResponse) GetStatus 

func (x *ChangeInvisibleDurationResponse) GetStatus() *Status

func (*ChangeInvisibleDurationResponse) ProtoMessage 

func (*ChangeInvisibleDurationResponse) ProtoMessage()

func (*ChangeInvisibleDurationResponse) ProtoReflect 

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

func (*ChangeInvisibleDurationResponse) Reset 

func (x *ChangeInvisibleDurationResponse) Reset()

func (*ChangeInvisibleDurationResponse) String 

func (x *ChangeInvisibleDurationResponse) String() string

type ChangeLogLevelRequest 

type ChangeLogLevelRequest struct {
	Level ChangeLogLevelRequest_Level `protobuf:"varint,1,opt,name=level,proto3,enum=apache.rocketmq.v2.ChangeLogLevelRequest_Level" json:"level,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeLogLevelRequest) Descriptor deprecated 

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

Deprecated: Use ChangeLogLevelRequest.ProtoReflect.Descriptor instead.

func (*ChangeLogLevelRequest) GetLevel 

func (x *ChangeLogLevelRequest) GetLevel() ChangeLogLevelRequest_Level

func (*ChangeLogLevelRequest) ProtoMessage 

func (*ChangeLogLevelRequest) ProtoMessage()

func (*ChangeLogLevelRequest) ProtoReflect 

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

func (*ChangeLogLevelRequest) Reset 

func (x *ChangeLogLevelRequest) Reset()

func (*ChangeLogLevelRequest) String 

func (x *ChangeLogLevelRequest) String() string

type ChangeLogLevelRequest_Level 

type ChangeLogLevelRequest_Level int32
const (
	ChangeLogLevelRequest_TRACE ChangeLogLevelRequest_Level = 0
	ChangeLogLevelRequest_DEBUG ChangeLogLevelRequest_Level = 1
	ChangeLogLevelRequest_INFO  ChangeLogLevelRequest_Level = 2
	ChangeLogLevelRequest_WARN  ChangeLogLevelRequest_Level = 3
	ChangeLogLevelRequest_ERROR ChangeLogLevelRequest_Level = 4
)

func (ChangeLogLevelRequest_Level) Descriptor 

func (ChangeLogLevelRequest_Level) Descriptor() protoreflect.EnumDescriptor

func (ChangeLogLevelRequest_Level) Enum 

func (x ChangeLogLevelRequest_Level) Enum() *ChangeLogLevelRequest_Level

func (ChangeLogLevelRequest_Level) EnumDescriptor deprecated 

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

Deprecated: Use ChangeLogLevelRequest_Level.Descriptor instead.

func (ChangeLogLevelRequest_Level) Number 

func (x ChangeLogLevelRequest_Level) Number() protoreflect.EnumNumber

func (ChangeLogLevelRequest_Level) String 

func (x ChangeLogLevelRequest_Level) String() string

func (ChangeLogLevelRequest_Level) Type 

func (ChangeLogLevelRequest_Level) Type() protoreflect.EnumType

type ChangeLogLevelResponse 

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

func (*ChangeLogLevelResponse) Descriptor deprecated 

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

Deprecated: Use ChangeLogLevelResponse.ProtoReflect.Descriptor instead.

func (*ChangeLogLevelResponse) GetRemark 

func (x *ChangeLogLevelResponse) GetRemark() string

func (*ChangeLogLevelResponse) ProtoMessage 

func (*ChangeLogLevelResponse) ProtoMessage()

func (*ChangeLogLevelResponse) ProtoReflect 

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

func (*ChangeLogLevelResponse) Reset 

func (x *ChangeLogLevelResponse) Reset()

func (*ChangeLogLevelResponse) String 

func (x *ChangeLogLevelResponse) String() string

type ClientType 

type ClientType int32
const (
	ClientType_CLIENT_TYPE_UNSPECIFIED ClientType = 0
	ClientType_PRODUCER                ClientType = 1
	ClientType_PUSH_CONSUMER           ClientType = 2
	ClientType_SIMPLE_CONSUMER         ClientType = 3
)

func (ClientType) Descriptor 

func (ClientType) Descriptor() protoreflect.EnumDescriptor

func (ClientType) Enum 

func (x ClientType) Enum() *ClientType

func (ClientType) EnumDescriptor deprecated 

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

Deprecated: Use ClientType.Descriptor instead.

func (ClientType) Number 

func (x ClientType) Number() protoreflect.EnumNumber

func (ClientType) String 

func (x ClientType) String() string

func (ClientType) Type 

func (ClientType) Type() protoreflect.EnumType

type Code 

type Code int32
const (
	Code_CODE_UNSPECIFIED Code = 0
	// Generic code for success.
	Code_OK Code = 20000
	// Generic code for multiple return results.
	Code_MULTIPLE_RESULTS Code = 30000
	// Generic code for bad request, indicating that required fields or headers are missing.
	Code_BAD_REQUEST Code = 40000
	// Format of access point is illegal.
	Code_ILLEGAL_ACCESS_POINT Code = 40001
	// Format of topic is illegal.
	Code_ILLEGAL_TOPIC Code = 40002
	// Format of consumer group is illegal.
	Code_ILLEGAL_CONSUMER_GROUP Code = 40003
	// Format of message tag is illegal.
	Code_ILLEGAL_MESSAGE_TAG Code = 40004
	// Format of message key is illegal.
	Code_ILLEGAL_MESSAGE_KEY Code = 40005
	// Format of message group is illegal.
	Code_ILLEGAL_MESSAGE_GROUP Code = 40006
	// Format of message property key is illegal.
	Code_ILLEGAL_MESSAGE_PROPERTY_KEY Code = 40007
	// Transaction id is invalid.
	Code_INVALID_TRANSACTION_ID Code = 40008
	// Format of message id is illegal.
	Code_ILLEGAL_MESSAGE_ID Code = 40009
	// Format of filter expression is illegal.
	Code_ILLEGAL_FILTER_EXPRESSION Code = 40010
	// The invisible time of request is invalid.
	Code_ILLEGAL_INVISIBLE_TIME Code = 40011
	// The delivery timestamp of message is invalid.
	Code_ILLEGAL_DELIVERY_TIME Code = 40012
	// Receipt handle of message is invalid.
	Code_INVALID_RECEIPT_HANDLE Code = 40013
	// Message property conflicts with its type.
	Code_MESSAGE_PROPERTY_CONFLICT_WITH_TYPE Code = 40014
	// Client type could not be recognized.
	Code_UNRECOGNIZED_CLIENT_TYPE Code = 40015
	// Message is corrupted.
	Code_MESSAGE_CORRUPTED Code = 40016
	// Request is rejected due to missing of x-mq-client-id header.
	Code_CLIENT_ID_REQUIRED Code = 40017
	// Generic code indicates that the client request lacks valid authentication
	// credentials for the requested resource.
	Code_UNAUTHORIZED Code = 40100
	// Generic code indicates that the account is suspended due to overdue of payment.
	Code_PAYMENT_REQUIRED Code = 40200
	// Generic code for the case that user does not have the permission to operate.
	Code_FORBIDDEN Code = 40300
	// Generic code for resource not found.
	Code_NOT_FOUND Code = 40400
	// Message not found from server.
	Code_MESSAGE_NOT_FOUND Code = 40401
	// Topic resource does not exist.
	Code_TOPIC_NOT_FOUND Code = 40402
	// Consumer group resource does not exist.
	Code_CONSUMER_GROUP_NOT_FOUND Code = 40403
	// Generic code representing client side timeout when connecting to, reading data from, or write data to server.
	Code_REQUEST_TIMEOUT Code = 40800
	// Generic code represents that the request entity is larger than limits defined by server.
	Code_PAYLOAD_TOO_LARGE Code = 41300
	// Message body size exceeds the threshold.
	Code_MESSAGE_BODY_TOO_LARGE Code = 41301
	// Generic code for use cases where pre-conditions are not met.
	// For example, if a producer instance is used to publish messages without prior start() invocation,
	// this error code will be raised.
	Code_PRECONDITION_FAILED Code = 42800
	// Generic code indicates that too many requests are made in short period of duration.
	// Requests are throttled.
	Code_TOO_MANY_REQUESTS Code = 42900
	// Generic code for the case that the server is unwilling to process the request because its header fields are too large.
	// The request may be resubmitted after reducing the size of the request header fields.
	Code_REQUEST_HEADER_FIELDS_TOO_LARGE Code = 43100
	// Message properties total size exceeds the threshold.
	Code_MESSAGE_PROPERTIES_TOO_LARGE Code = 43101
	// Generic code indicates that server/client encountered an unexpected
	// condition that prevented it from fulfilling the request.
	Code_INTERNAL_ERROR Code = 50000
	// Code indicates that the server encountered an unexpected condition
	// that prevented it from fulfilling the request.
	// This error response is a generic "catch-all" response.
	// Usually, this indicates the server cannot find a better alternative
	// error code to response. Sometimes, server administrators log error
	// responses like the 500 status code with more details about the request
	// to prevent the error from happening again in the future.
	//
	// See https://developer.mozilla.org/en-US/docs/Web/HTTP/Status/500
	Code_INTERNAL_SERVER_ERROR Code = 50001
	// The HA-mechanism is not working now.
	Code_HA_NOT_AVAILABLE Code = 50002
	// Generic code means that the server or client does not support the
	// functionality required to fulfill the request.
	Code_NOT_IMPLEMENTED Code = 50100
	// Generic code represents that the server, which acts as a gateway or proxy,
	// does not get an satisfied response in time from its upstream servers.
	// See https://developer.mozilla.org/en-US/docs/Web/HTTP/Status/504
	Code_PROXY_TIMEOUT Code = 50400
	// Message persistence timeout.
	Code_MASTER_PERSISTENCE_TIMEOUT Code = 50401
	// Slave persistence timeout.
	Code_SLAVE_PERSISTENCE_TIMEOUT Code = 50402
	// Generic code for unsupported operation.
	Code_UNSUPPORTED Code = 50500
	// Operation is not allowed in current version.
	Code_VERSION_UNSUPPORTED Code = 50501
	// Not allowed to verify message. Chances are that you are verifying
	// a FIFO message, as is violating FIFO semantics.
	Code_VERIFY_FIFO_MESSAGE_UNSUPPORTED Code = 50502
	// Generic code for failed message consumption.
	Code_FAILED_TO_CONSUME_MESSAGE Code = 60000
)

func (Code) Descriptor 

func (Code) Descriptor() protoreflect.EnumDescriptor

func (Code) Enum 

func (x Code) Enum() *Code

func (Code) EnumDescriptor deprecated 

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

Deprecated: Use Code.Descriptor instead.

func (Code) Number 

func (x Code) Number() protoreflect.EnumNumber

func (Code) String 

func (x Code) String() string

func (Code) Type 

func (Code) Type() protoreflect.EnumType

type CustomizedBackoff 

type CustomizedBackoff struct {

	// To support classic backoff strategy which is arbitrary defined by end users.
	// Typical values are: `1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h`
	Next []*durationpb.Duration `protobuf:"bytes,1,rep,name=next,proto3" json:"next,omitempty"`
	// contains filtered or unexported fields
}

func (*CustomizedBackoff) Descriptor deprecated 

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

Deprecated: Use CustomizedBackoff.ProtoReflect.Descriptor instead.

func (*CustomizedBackoff) GetNext 

func (x *CustomizedBackoff) GetNext() []*durationpb.Duration

func (*CustomizedBackoff) ProtoMessage 

func (*CustomizedBackoff) ProtoMessage()

func (*CustomizedBackoff) ProtoReflect 

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

func (*CustomizedBackoff) Reset 

func (x *CustomizedBackoff) Reset()

func (*CustomizedBackoff) String 

func (x *CustomizedBackoff) String() string

type Digest 

type Digest struct {
	Type     DigestType `protobuf:"varint,1,opt,name=type,proto3,enum=apache.rocketmq.v2.DigestType" json:"type,omitempty"`
	Checksum string     `protobuf:"bytes,2,opt,name=checksum,proto3" json:"checksum,omitempty"`
	// contains filtered or unexported fields
}

When publishing messages to or subscribing messages from brokers, clients shall include or validate digests of message body to ensure data integrity.

For message publishing, when an invalid digest were detected, brokers need respond client with BAD_REQUEST.

For messages subscription, when an invalid digest were detected, consumers need to handle this case according to message type: 1) Standard messages should be negatively acknowledged instantly, causing immediate re-delivery; 2) FIFO messages require special RPC, to re-fetch previously acquired messages batch;

func (*Digest) Descriptor deprecated 

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

Deprecated: Use Digest.ProtoReflect.Descriptor instead.

func (*Digest) GetChecksum 

func (x *Digest) GetChecksum() string

func (*Digest) GetType 

func (x *Digest) GetType() DigestType

func (*Digest) ProtoMessage 

func (*Digest) ProtoMessage()

func (*Digest) ProtoReflect 

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

func (*Digest) Reset 

func (x *Digest) Reset()

func (*Digest) String 

func (x *Digest) String() string

type DigestType 

type DigestType int32
const (
	DigestType_DIGEST_TYPE_UNSPECIFIED DigestType = 0
	// CRC algorithm achieves goal of detecting random data error with lowest
	// computation overhead.
	DigestType_CRC32 DigestType = 1
	// MD5 algorithm achieves good balance between collision rate and computation
	// overhead.
	DigestType_MD5 DigestType = 2
	// SHA-family has substantially fewer collision with fair amount of
	// computation.
	DigestType_SHA1 DigestType = 3
)

func (DigestType) Descriptor 

func (DigestType) Descriptor() protoreflect.EnumDescriptor

func (DigestType) Enum 

func (x DigestType) Enum() *DigestType

func (DigestType) EnumDescriptor deprecated 

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

Deprecated: Use DigestType.Descriptor instead.

func (DigestType) Number 

func (x DigestType) Number() protoreflect.EnumNumber

func (DigestType) String 

func (x DigestType) String() string

func (DigestType) Type 

func (DigestType) Type() protoreflect.EnumType

type Encoding 

type Encoding int32
const (
	Encoding_ENCODING_UNSPECIFIED Encoding = 0
	Encoding_IDENTITY             Encoding = 1
	Encoding_GZIP                 Encoding = 2
)

func (Encoding) Descriptor 

func (Encoding) Descriptor() protoreflect.EnumDescriptor

func (Encoding) Enum 

func (x Encoding) Enum() *Encoding

func (Encoding) EnumDescriptor deprecated 

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

Deprecated: Use Encoding.Descriptor instead.

func (Encoding) Number 

func (x Encoding) Number() protoreflect.EnumNumber

func (Encoding) String 

func (x Encoding) String() string

func (Encoding) Type 

func (Encoding) Type() protoreflect.EnumType

type EndTransactionRequest 

type EndTransactionRequest struct {
	Topic         *Resource             `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	MessageId     string                `protobuf:"bytes,2,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	TransactionId string                `protobuf:"bytes,3,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	Resolution    TransactionResolution `protobuf:"varint,4,opt,name=resolution,proto3,enum=apache.rocketmq.v2.TransactionResolution" json:"resolution,omitempty"`
	Source        TransactionSource     `protobuf:"varint,5,opt,name=source,proto3,enum=apache.rocketmq.v2.TransactionSource" json:"source,omitempty"`
	TraceContext  string                `protobuf:"bytes,6,opt,name=trace_context,json=traceContext,proto3" json:"trace_context,omitempty"`
	// contains filtered or unexported fields
}

func (*EndTransactionRequest) Descriptor deprecated 

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

Deprecated: Use EndTransactionRequest.ProtoReflect.Descriptor instead.

func (*EndTransactionRequest) GetMessageId 

func (x *EndTransactionRequest) GetMessageId() string

func (*EndTransactionRequest) GetResolution 

func (x *EndTransactionRequest) GetResolution() TransactionResolution

func (*EndTransactionRequest) GetSource 

func (x *EndTransactionRequest) GetSource() TransactionSource

func (*EndTransactionRequest) GetTopic 

func (x *EndTransactionRequest) GetTopic() *Resource

func (*EndTransactionRequest) GetTraceContext 

func (x *EndTransactionRequest) GetTraceContext() string

func (*EndTransactionRequest) GetTransactionId 

func (x *EndTransactionRequest) GetTransactionId() string

func (*EndTransactionRequest) ProtoMessage 

func (*EndTransactionRequest) ProtoMessage()

func (*EndTransactionRequest) ProtoReflect 

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

func (*EndTransactionRequest) Reset 

func (x *EndTransactionRequest) Reset()

func (*EndTransactionRequest) String 

func (x *EndTransactionRequest) String() string

type EndTransactionResponse 

type EndTransactionResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*EndTransactionResponse) Descriptor deprecated 

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

Deprecated: Use EndTransactionResponse.ProtoReflect.Descriptor instead.

func (*EndTransactionResponse) GetStatus 

func (x *EndTransactionResponse) GetStatus() *Status

func (*EndTransactionResponse) ProtoMessage 

func (*EndTransactionResponse) ProtoMessage()

func (*EndTransactionResponse) ProtoReflect 

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

func (*EndTransactionResponse) Reset 

func (x *EndTransactionResponse) Reset()

func (*EndTransactionResponse) String 

func (x *EndTransactionResponse) String() string

type Endpoints 

type Endpoints struct {
	Scheme    AddressScheme `protobuf:"varint,1,opt,name=scheme,proto3,enum=apache.rocketmq.v2.AddressScheme" json:"scheme,omitempty"`
	Addresses []*Address    `protobuf:"bytes,2,rep,name=addresses,proto3" json:"addresses,omitempty"`
	// contains filtered or unexported fields
}

func (*Endpoints) Descriptor deprecated 

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

Deprecated: Use Endpoints.ProtoReflect.Descriptor instead.

func (*Endpoints) GetAddresses 

func (x *Endpoints) GetAddresses() []*Address

func (*Endpoints) GetScheme 

func (x *Endpoints) GetScheme() AddressScheme

func (*Endpoints) ProtoMessage 

func (*Endpoints) ProtoMessage()

func (*Endpoints) ProtoReflect 

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

func (*Endpoints) Reset 

func (x *Endpoints) Reset()

func (*Endpoints) String 

func (x *Endpoints) String() string

type ExponentialBackoff 

type ExponentialBackoff struct {
	Initial    *durationpb.Duration `protobuf:"bytes,1,opt,name=initial,proto3" json:"initial,omitempty"`
	Max        *durationpb.Duration `protobuf:"bytes,2,opt,name=max,proto3" json:"max,omitempty"`
	Multiplier float32              `protobuf:"fixed32,3,opt,name=multiplier,proto3" json:"multiplier,omitempty"`
	// contains filtered or unexported fields
}

https://en.wikipedia.org/wiki/Exponential_backoff

func (*ExponentialBackoff) Descriptor deprecated 

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

Deprecated: Use ExponentialBackoff.ProtoReflect.Descriptor instead.

func (*ExponentialBackoff) GetInitial 

func (x *ExponentialBackoff) GetInitial() *durationpb.Duration

func (*ExponentialBackoff) GetMax 

func (x *ExponentialBackoff) GetMax() *durationpb.Duration

func (*ExponentialBackoff) GetMultiplier 

func (x *ExponentialBackoff) GetMultiplier() float32

func (*ExponentialBackoff) ProtoMessage 

func (*ExponentialBackoff) ProtoMessage()

func (*ExponentialBackoff) ProtoReflect 

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

func (*ExponentialBackoff) Reset 

func (x *ExponentialBackoff) Reset()

func (*ExponentialBackoff) String 

func (x *ExponentialBackoff) String() string

type FilterExpression 

type FilterExpression struct {
	Type       FilterType `protobuf:"varint,1,opt,name=type,proto3,enum=apache.rocketmq.v2.FilterType" json:"type,omitempty"`
	Expression string     `protobuf:"bytes,2,opt,name=expression,proto3" json:"expression,omitempty"`
	// contains filtered or unexported fields
}

func (*FilterExpression) Descriptor deprecated 

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

Deprecated: Use FilterExpression.ProtoReflect.Descriptor instead.

func (*FilterExpression) GetExpression 

func (x *FilterExpression) GetExpression() string

func (*FilterExpression) GetType 

func (x *FilterExpression) GetType() FilterType

func (*FilterExpression) ProtoMessage 

func (*FilterExpression) ProtoMessage()

func (*FilterExpression) ProtoReflect 

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

func (*FilterExpression) Reset 

func (x *FilterExpression) Reset()

func (*FilterExpression) String 

func (x *FilterExpression) String() string

type FilterType 

type FilterType int32
const (
	FilterType_FILTER_TYPE_UNSPECIFIED FilterType = 0
	FilterType_TAG                     FilterType = 1
	FilterType_SQL                     FilterType = 2
)

func (FilterType) Descriptor 

func (FilterType) Descriptor() protoreflect.EnumDescriptor

func (FilterType) Enum 

func (x FilterType) Enum() *FilterType

func (FilterType) EnumDescriptor deprecated 

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

Deprecated: Use FilterType.Descriptor instead.

func (FilterType) Number 

func (x FilterType) Number() protoreflect.EnumNumber

func (FilterType) String 

func (x FilterType) String() string

func (FilterType) Type 

func (FilterType) Type() protoreflect.EnumType

type ForwardMessageToDeadLetterQueueRequest 

type ForwardMessageToDeadLetterQueueRequest struct {
	Group               *Resource `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	Topic               *Resource `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	ReceiptHandle       string    `protobuf:"bytes,3,opt,name=receipt_handle,json=receiptHandle,proto3" json:"receipt_handle,omitempty"`
	MessageId           string    `protobuf:"bytes,4,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	DeliveryAttempt     int32     `protobuf:"varint,5,opt,name=delivery_attempt,json=deliveryAttempt,proto3" json:"delivery_attempt,omitempty"`
	MaxDeliveryAttempts int32     `protobuf:"varint,6,opt,name=max_delivery_attempts,json=maxDeliveryAttempts,proto3" json:"max_delivery_attempts,omitempty"`
	// contains filtered or unexported fields
}

func (*ForwardMessageToDeadLetterQueueRequest) Descriptor deprecated 

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

Deprecated: Use ForwardMessageToDeadLetterQueueRequest.ProtoReflect.Descriptor instead.

func (*ForwardMessageToDeadLetterQueueRequest) GetDeliveryAttempt 

func (x *ForwardMessageToDeadLetterQueueRequest) GetDeliveryAttempt() int32

func (*ForwardMessageToDeadLetterQueueRequest) GetGroup 

func (x *ForwardMessageToDeadLetterQueueRequest) GetGroup() *Resource

func (*ForwardMessageToDeadLetterQueueRequest) GetMaxDeliveryAttempts 

func (x *ForwardMessageToDeadLetterQueueRequest) GetMaxDeliveryAttempts() int32

func (*ForwardMessageToDeadLetterQueueRequest) GetMessageId 

func (x *ForwardMessageToDeadLetterQueueRequest) GetMessageId() string

func (*ForwardMessageToDeadLetterQueueRequest) GetReceiptHandle 

func (x *ForwardMessageToDeadLetterQueueRequest) GetReceiptHandle() string

func (*ForwardMessageToDeadLetterQueueRequest) GetTopic 

func (x *ForwardMessageToDeadLetterQueueRequest) GetTopic() *Resource

func (*ForwardMessageToDeadLetterQueueRequest) ProtoMessage 

func (*ForwardMessageToDeadLetterQueueRequest) ProtoMessage()

func (*ForwardMessageToDeadLetterQueueRequest) ProtoReflect 

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

func (*ForwardMessageToDeadLetterQueueRequest) Reset 

func (x *ForwardMessageToDeadLetterQueueRequest) Reset()

func (*ForwardMessageToDeadLetterQueueRequest) String 

func (x *ForwardMessageToDeadLetterQueueRequest) String() string

type ForwardMessageToDeadLetterQueueResponse 

type ForwardMessageToDeadLetterQueueResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ForwardMessageToDeadLetterQueueResponse) Descriptor deprecated 

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

Deprecated: Use ForwardMessageToDeadLetterQueueResponse.ProtoReflect.Descriptor instead.

func (*ForwardMessageToDeadLetterQueueResponse) GetStatus 

func (x *ForwardMessageToDeadLetterQueueResponse) GetStatus() *Status

func (*ForwardMessageToDeadLetterQueueResponse) ProtoMessage 

func (*ForwardMessageToDeadLetterQueueResponse) ProtoMessage()

func (*ForwardMessageToDeadLetterQueueResponse) ProtoReflect 

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

func (*ForwardMessageToDeadLetterQueueResponse) Reset 

func (x *ForwardMessageToDeadLetterQueueResponse) Reset()

func (*ForwardMessageToDeadLetterQueueResponse) String 

func (x *ForwardMessageToDeadLetterQueueResponse) String() string

type HeartbeatRequest 

type HeartbeatRequest struct {
	Group      *Resource  `protobuf:"bytes,1,opt,name=group,proto3,oneof" json:"group,omitempty"`
	ClientType ClientType `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*HeartbeatRequest) Descriptor deprecated 

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

Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.

func (*HeartbeatRequest) GetClientType 

func (x *HeartbeatRequest) GetClientType() ClientType

func (*HeartbeatRequest) GetGroup 

func (x *HeartbeatRequest) GetGroup() *Resource

func (*HeartbeatRequest) ProtoMessage 

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) ProtoReflect 

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

func (*HeartbeatRequest) Reset 

func (x *HeartbeatRequest) Reset()

func (*HeartbeatRequest) String 

func (x *HeartbeatRequest) String() string

type HeartbeatResponse 

type HeartbeatResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatResponse) Descriptor deprecated 

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

Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.

func (*HeartbeatResponse) GetStatus 

func (x *HeartbeatResponse) GetStatus() *Status

func (*HeartbeatResponse) ProtoMessage 

func (*HeartbeatResponse) ProtoMessage()

func (*HeartbeatResponse) ProtoReflect 

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

func (*HeartbeatResponse) Reset 

func (x *HeartbeatResponse) Reset()

func (*HeartbeatResponse) String 

func (x *HeartbeatResponse) String() string

type Language 

type Language int32
const (
	Language_LANGUAGE_UNSPECIFIED Language = 0
	Language_JAVA                 Language = 1
	Language_CPP                  Language = 2
	Language_DOT_NET              Language = 3
	Language_GOLANG               Language = 4
	Language_RUST                 Language = 5
	Language_PYTHON               Language = 6
	Language_PHP                  Language = 7
	Language_NODE_JS              Language = 8
	Language_RUBY                 Language = 9
	Language_OBJECTIVE_C          Language = 10
	Language_DART                 Language = 11
	Language_KOTLIN               Language = 12
)

func (Language) Descriptor 

func (Language) Descriptor() protoreflect.EnumDescriptor

func (Language) Enum 

func (x Language) Enum() *Language

func (Language) EnumDescriptor deprecated 

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

Deprecated: Use Language.Descriptor instead.

func (Language) Number 

func (x Language) Number() protoreflect.EnumNumber

func (Language) String 

func (x Language) String() string

func (Language) Type 

func (Language) Type() protoreflect.EnumType

type Message 

type Message struct {
	Topic *Resource `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// User defined key-value pairs.
	// If user_properties contain the reserved keys by RocketMQ,
	// the send message request will be aborted with status `INVALID_ARGUMENT`.
	// See below links for the reserved keys
	// https://github.com/apache/rocketmq/blob/master/common/src/main/java/org/apache/rocketmq/common/message/MessageConst.java#L58
	UserProperties   map[string]string `` /* 191-byte string literal not displayed */
	SystemProperties *SystemProperties `protobuf:"bytes,3,opt,name=system_properties,json=systemProperties,proto3" json:"system_properties,omitempty"`
	Body             []byte            `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetBody 

func (x *Message) GetBody() []byte

func (*Message) GetSystemProperties 

func (x *Message) GetSystemProperties() *SystemProperties

func (*Message) GetTopic 

func (x *Message) GetTopic() *Resource

func (*Message) GetUserProperties 

func (x *Message) GetUserProperties() map[string]string

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

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

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type MessageQueue 

type MessageQueue struct {
	Topic              *Resource     `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Id                 int32         `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Permission         Permission    `protobuf:"varint,3,opt,name=permission,proto3,enum=apache.rocketmq.v2.Permission" json:"permission,omitempty"`
	Broker             *Broker       `protobuf:"bytes,4,opt,name=broker,proto3" json:"broker,omitempty"`
	AcceptMessageTypes []MessageType `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MessageQueue) Descriptor deprecated 

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

Deprecated: Use MessageQueue.ProtoReflect.Descriptor instead.

func (*MessageQueue) GetAcceptMessageTypes 

func (x *MessageQueue) GetAcceptMessageTypes() []MessageType

func (*MessageQueue) GetBroker 

func (x *MessageQueue) GetBroker() *Broker

func (*MessageQueue) GetId 

func (x *MessageQueue) GetId() int32

func (*MessageQueue) GetPermission 

func (x *MessageQueue) GetPermission() Permission

func (*MessageQueue) GetTopic 

func (x *MessageQueue) GetTopic() *Resource

func (*MessageQueue) ProtoMessage 

func (*MessageQueue) ProtoMessage()

func (*MessageQueue) ProtoReflect 

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

func (*MessageQueue) Reset 

func (x *MessageQueue) Reset()

func (*MessageQueue) String 

func (x *MessageQueue) String() string

type MessageType 

type MessageType int32
const (
	MessageType_MESSAGE_TYPE_UNSPECIFIED MessageType = 0
	MessageType_NORMAL                   MessageType = 1
	// Sequenced message
	MessageType_FIFO MessageType = 2
	// Messages that are delivered after the specified duration.
	MessageType_DELAY MessageType = 3
	// Messages that are transactional. Only committed messages are delivered to
	// subscribers.
	MessageType_TRANSACTION MessageType = 4
)

func (MessageType) Descriptor 

func (MessageType) Descriptor() protoreflect.EnumDescriptor

func (MessageType) Enum 

func (x MessageType) Enum() *MessageType

func (MessageType) EnumDescriptor deprecated 

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

Deprecated: Use MessageType.Descriptor instead.

func (MessageType) Number 

func (x MessageType) Number() protoreflect.EnumNumber

func (MessageType) String 

func (x MessageType) String() string

func (MessageType) Type 

func (MessageType) Type() protoreflect.EnumType

type MessagingServiceClient 

type MessagingServiceClient interface {
	// Queries the route entries of the requested topic in the perspective of the
	// given endpoints. On success, servers should return a collection of
	// addressable message-queues. Note servers may return customized route
	// entries based on endpoints provided.
	//
	// If the requested topic doesn't exist, returns `NOT_FOUND`.
	// If the specific endpoints is empty, returns `INVALID_ARGUMENT`.
	QueryRoute(ctx context.Context, in *QueryRouteRequest, opts ...grpc.CallOption) (*QueryRouteResponse, error)
	// Producer or consumer sends HeartbeatRequest to servers periodically to
	// keep-alive. Additionally, it also reports client-side configuration,
	// including topic subscription, load-balancing group name, etc.
	//
	// Returns `OK` if success.
	//
	// If a client specifies a language that is not yet supported by servers,
	// returns `INVALID_ARGUMENT`
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error)
	// Delivers messages to brokers.
	// Clients may further:
	// 1. Refine a message destination to message-queues which fulfills parts of
	// FIFO semantic;
	// 2. Flag a message as transactional, which keeps it invisible to consumers
	// until it commits;
	// 3. Time a message, making it invisible to consumers till specified
	// time-point;
	// 4. And more...
	//
	// Returns message-id or transaction-id with status `OK` on success.
	//
	// If the destination topic doesn't exist, returns `NOT_FOUND`.
	SendMessage(ctx context.Context, in *SendMessageRequest, opts ...grpc.CallOption) (*SendMessageResponse, error)
	// Queries the assigned route info of a topic for current consumer,
	// the returned assignment result is decided by server-side load balancer.
	//
	// If the corresponding topic doesn't exist, returns `NOT_FOUND`.
	// If the specific endpoints is empty, returns `INVALID_ARGUMENT`.
	QueryAssignment(ctx context.Context, in *QueryAssignmentRequest, opts ...grpc.CallOption) (*QueryAssignmentResponse, error)
	// Receives messages from the server in batch manner, returns a set of
	// messages if success. The received messages should be acked or redelivered
	// after processed.
	//
	// If the pending concurrent receive requests exceed the quota of the given
	// consumer group, returns `UNAVAILABLE`. If the upstream store server hangs,
	// return `DEADLINE_EXCEEDED` in a timely manner. If the corresponding topic
	// or consumer group doesn't exist, returns `NOT_FOUND`. If there is no new
	// message in the specific topic, returns `OK` with an empty message set.
	// Please note that client may suffer from false empty responses.
	//
	// If failed to receive message from remote, server must return only one
	// `ReceiveMessageResponse` as the reply to the request, whose `Status` indicates
	// the specific reason of failure, otherwise, the reply is considered successful.
	ReceiveMessage(ctx context.Context, in *ReceiveMessageRequest, opts ...grpc.CallOption) (MessagingService_ReceiveMessageClient, error)
	// Acknowledges the message associated with the `receipt_handle` or `offset`
	// in the `AckMessageRequest`, it means the message has been successfully
	// processed. Returns `OK` if the message server remove the relevant message
	// successfully.
	//
	// If the given receipt_handle is illegal or out of date, returns
	// `INVALID_ARGUMENT`.
	AckMessage(ctx context.Context, in *AckMessageRequest, opts ...grpc.CallOption) (*AckMessageResponse, error)
	// Forwards one message to dead letter queue if the max delivery attempts is
	// exceeded by this message at client-side, return `OK` if success.
	ForwardMessageToDeadLetterQueue(ctx context.Context, in *ForwardMessageToDeadLetterQueueRequest, opts ...grpc.CallOption) (*ForwardMessageToDeadLetterQueueResponse, error)
	// Commits or rollback one transactional message.
	EndTransaction(ctx context.Context, in *EndTransactionRequest, opts ...grpc.CallOption) (*EndTransactionResponse, error)
	// Once a client starts, it would immediately establishes bi-lateral stream
	// RPCs with brokers, reporting its settings as the initiative command.
	//
	// When servers have need of inspecting client status, they would issue
	// telemetry commands to clients. After executing received instructions,
	// clients shall report command execution results through client-side streams.
	Telemetry(ctx context.Context, opts ...grpc.CallOption) (MessagingService_TelemetryClient, error)
	// Notify the server that the client is terminated.
	NotifyClientTermination(ctx context.Context, in *NotifyClientTerminationRequest, opts ...grpc.CallOption) (*NotifyClientTerminationResponse, error)
	// Once a message is retrieved from consume queue on behalf of the group, it
	// will be kept invisible to other clients of the same group for a period of
	// time. The message is supposed to be processed within the invisible
	// duration. If the client, which is in charge of the invisible message, is
	// not capable of processing the message timely, it may use
	// ChangeInvisibleDuration to lengthen invisible duration.
	ChangeInvisibleDuration(ctx context.Context, in *ChangeInvisibleDurationRequest, opts ...grpc.CallOption) (*ChangeInvisibleDurationResponse, error)
}

MessagingServiceClient is the client API for MessagingService 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 NewMessagingServiceClient 

func NewMessagingServiceClient(cc grpc.ClientConnInterface) MessagingServiceClient

type MessagingServiceServer 

type MessagingServiceServer interface {
	// Queries the route entries of the requested topic in the perspective of the
	// given endpoints. On success, servers should return a collection of
	// addressable message-queues. Note servers may return customized route
	// entries based on endpoints provided.
	//
	// If the requested topic doesn't exist, returns `NOT_FOUND`.
	// If the specific endpoints is empty, returns `INVALID_ARGUMENT`.
	QueryRoute(context.Context, *QueryRouteRequest) (*QueryRouteResponse, error)
	// Producer or consumer sends HeartbeatRequest to servers periodically to
	// keep-alive. Additionally, it also reports client-side configuration,
	// including topic subscription, load-balancing group name, etc.
	//
	// Returns `OK` if success.
	//
	// If a client specifies a language that is not yet supported by servers,
	// returns `INVALID_ARGUMENT`
	Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
	// Delivers messages to brokers.
	// Clients may further:
	// 1. Refine a message destination to message-queues which fulfills parts of
	// FIFO semantic;
	// 2. Flag a message as transactional, which keeps it invisible to consumers
	// until it commits;
	// 3. Time a message, making it invisible to consumers till specified
	// time-point;
	// 4. And more...
	//
	// Returns message-id or transaction-id with status `OK` on success.
	//
	// If the destination topic doesn't exist, returns `NOT_FOUND`.
	SendMessage(context.Context, *SendMessageRequest) (*SendMessageResponse, error)
	// Queries the assigned route info of a topic for current consumer,
	// the returned assignment result is decided by server-side load balancer.
	//
	// If the corresponding topic doesn't exist, returns `NOT_FOUND`.
	// If the specific endpoints is empty, returns `INVALID_ARGUMENT`.
	QueryAssignment(context.Context, *QueryAssignmentRequest) (*QueryAssignmentResponse, error)
	// Receives messages from the server in batch manner, returns a set of
	// messages if success. The received messages should be acked or redelivered
	// after processed.
	//
	// If the pending concurrent receive requests exceed the quota of the given
	// consumer group, returns `UNAVAILABLE`. If the upstream store server hangs,
	// return `DEADLINE_EXCEEDED` in a timely manner. If the corresponding topic
	// or consumer group doesn't exist, returns `NOT_FOUND`. If there is no new
	// message in the specific topic, returns `OK` with an empty message set.
	// Please note that client may suffer from false empty responses.
	//
	// If failed to receive message from remote, server must return only one
	// `ReceiveMessageResponse` as the reply to the request, whose `Status` indicates
	// the specific reason of failure, otherwise, the reply is considered successful.
	ReceiveMessage(*ReceiveMessageRequest, MessagingService_ReceiveMessageServer) error
	// Acknowledges the message associated with the `receipt_handle` or `offset`
	// in the `AckMessageRequest`, it means the message has been successfully
	// processed. Returns `OK` if the message server remove the relevant message
	// successfully.
	//
	// If the given receipt_handle is illegal or out of date, returns
	// `INVALID_ARGUMENT`.
	AckMessage(context.Context, *AckMessageRequest) (*AckMessageResponse, error)
	// Forwards one message to dead letter queue if the max delivery attempts is
	// exceeded by this message at client-side, return `OK` if success.
	ForwardMessageToDeadLetterQueue(context.Context, *ForwardMessageToDeadLetterQueueRequest) (*ForwardMessageToDeadLetterQueueResponse, error)
	// Commits or rollback one transactional message.
	EndTransaction(context.Context, *EndTransactionRequest) (*EndTransactionResponse, error)
	// Once a client starts, it would immediately establishes bi-lateral stream
	// RPCs with brokers, reporting its settings as the initiative command.
	//
	// When servers have need of inspecting client status, they would issue
	// telemetry commands to clients. After executing received instructions,
	// clients shall report command execution results through client-side streams.
	Telemetry(MessagingService_TelemetryServer) error
	// Notify the server that the client is terminated.
	NotifyClientTermination(context.Context, *NotifyClientTerminationRequest) (*NotifyClientTerminationResponse, error)
	// Once a message is retrieved from consume queue on behalf of the group, it
	// will be kept invisible to other clients of the same group for a period of
	// time. The message is supposed to be processed within the invisible
	// duration. If the client, which is in charge of the invisible message, is
	// not capable of processing the message timely, it may use
	// ChangeInvisibleDuration to lengthen invisible duration.
	ChangeInvisibleDuration(context.Context, *ChangeInvisibleDurationRequest) (*ChangeInvisibleDurationResponse, error)
	// contains filtered or unexported methods
}

MessagingServiceServer is the server API for MessagingService service. All implementations must embed UnimplementedMessagingServiceServer for forward compatibility

type MessagingService_ReceiveMessageClient 

type MessagingService_ReceiveMessageClient interface {
	Recv() (*ReceiveMessageResponse, error)
	grpc.ClientStream
}

type MessagingService_ReceiveMessageServer 

type MessagingService_ReceiveMessageServer interface {
	Send(*ReceiveMessageResponse) error
	grpc.ServerStream
}

type MessagingService_TelemetryClient 

type MessagingService_TelemetryClient interface {
	Send(*TelemetryCommand) error
	Recv() (*TelemetryCommand, error)
	grpc.ClientStream
}

type MessagingService_TelemetryServer 

type MessagingService_TelemetryServer interface {
	Send(*TelemetryCommand) error
	Recv() (*TelemetryCommand, error)
	grpc.ServerStream
}

type Metric 

type Metric struct {

	// Indicates that if client should export local metrics to server.
	On bool `protobuf:"varint,1,opt,name=on,proto3" json:"on,omitempty"`
	// The endpoint that client metrics should be exported to, which is required if the switch is on.
	Endpoints *Endpoints `protobuf:"bytes,2,opt,name=endpoints,proto3,oneof" json:"endpoints,omitempty"`
	// contains filtered or unexported fields
}

func (*Metric) Descriptor deprecated 

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

Deprecated: Use Metric.ProtoReflect.Descriptor instead.

func (*Metric) GetEndpoints 

func (x *Metric) GetEndpoints() *Endpoints

func (*Metric) GetOn 

func (x *Metric) GetOn() bool

func (*Metric) ProtoMessage 

func (*Metric) ProtoMessage()

func (*Metric) ProtoReflect 

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

func (*Metric) Reset 

func (x *Metric) Reset()

func (*Metric) String 

func (x *Metric) String() string

type NotifyClientTerminationRequest 

type NotifyClientTerminationRequest struct {

	// Consumer group, which is absent for producer.
	Group *Resource `protobuf:"bytes,1,opt,name=group,proto3,oneof" json:"group,omitempty"`
	// contains filtered or unexported fields
}

func (*NotifyClientTerminationRequest) Descriptor deprecated 

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

Deprecated: Use NotifyClientTerminationRequest.ProtoReflect.Descriptor instead.

func (*NotifyClientTerminationRequest) GetGroup 

func (x *NotifyClientTerminationRequest) GetGroup() *Resource

func (*NotifyClientTerminationRequest) ProtoMessage 

func (*NotifyClientTerminationRequest) ProtoMessage()

func (*NotifyClientTerminationRequest) ProtoReflect 

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

func (*NotifyClientTerminationRequest) Reset 

func (x *NotifyClientTerminationRequest) Reset()

func (*NotifyClientTerminationRequest) String 

func (x *NotifyClientTerminationRequest) String() string

type NotifyClientTerminationResponse 

type NotifyClientTerminationResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*NotifyClientTerminationResponse) Descriptor deprecated 

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

Deprecated: Use NotifyClientTerminationResponse.ProtoReflect.Descriptor instead.

func (*NotifyClientTerminationResponse) GetStatus 

func (x *NotifyClientTerminationResponse) GetStatus() *Status

func (*NotifyClientTerminationResponse) ProtoMessage 

func (*NotifyClientTerminationResponse) ProtoMessage()

func (*NotifyClientTerminationResponse) ProtoReflect 

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

func (*NotifyClientTerminationResponse) Reset 

func (x *NotifyClientTerminationResponse) Reset()

func (*NotifyClientTerminationResponse) String 

func (x *NotifyClientTerminationResponse) String() string

type Permission 

type Permission int32
const (
	Permission_PERMISSION_UNSPECIFIED Permission = 0
	Permission_NONE                   Permission = 1
	Permission_READ                   Permission = 2
	Permission_WRITE                  Permission = 3
	Permission_READ_WRITE             Permission = 4
)

func (Permission) Descriptor 

func (Permission) Descriptor() protoreflect.EnumDescriptor

func (Permission) Enum 

func (x Permission) Enum() *Permission

func (Permission) EnumDescriptor deprecated 

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

Deprecated: Use Permission.Descriptor instead.

func (Permission) Number 

func (x Permission) Number() protoreflect.EnumNumber

func (Permission) String 

func (x Permission) String() string

func (Permission) Type 

func (Permission) Type() protoreflect.EnumType

type PrintThreadStackTraceCommand 

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

func (*PrintThreadStackTraceCommand) Descriptor deprecated 

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

Deprecated: Use PrintThreadStackTraceCommand.ProtoReflect.Descriptor instead.

func (*PrintThreadStackTraceCommand) GetNonce 

func (x *PrintThreadStackTraceCommand) GetNonce() string

func (*PrintThreadStackTraceCommand) ProtoMessage 

func (*PrintThreadStackTraceCommand) ProtoMessage()

func (*PrintThreadStackTraceCommand) ProtoReflect 

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

func (*PrintThreadStackTraceCommand) Reset 

func (x *PrintThreadStackTraceCommand) Reset()

func (*PrintThreadStackTraceCommand) String 

func (x *PrintThreadStackTraceCommand) String() string

type Publishing 

type Publishing struct {

	// Publishing settings below here is appointed by client, thus it is
	// unnecessary for server to push at present.
	//
	// List of topics to which messages will publish to.
	Topics []*Resource `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	// If the message body size exceeds `max_body_size`, broker servers would
	// reject the request. As a result, it is advisable that Producer performs
	// client-side check validation.
	MaxBodySize int32 `protobuf:"varint,2,opt,name=max_body_size,json=maxBodySize,proto3" json:"max_body_size,omitempty"`
	// When `validate_message_type` flag set `false`, no need to validate message's type
	// with messageQueue's `accept_message_types` before publishing.
	ValidateMessageType bool `protobuf:"varint,3,opt,name=validate_message_type,json=validateMessageType,proto3" json:"validate_message_type,omitempty"`
	// contains filtered or unexported fields
}

func (*Publishing) Descriptor deprecated 

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

Deprecated: Use Publishing.ProtoReflect.Descriptor instead.

func (*Publishing) GetMaxBodySize 

func (x *Publishing) GetMaxBodySize() int32

func (*Publishing) GetTopics 

func (x *Publishing) GetTopics() []*Resource

func (*Publishing) GetValidateMessageType 

func (x *Publishing) GetValidateMessageType() bool

func (*Publishing) ProtoMessage 

func (*Publishing) ProtoMessage()

func (*Publishing) ProtoReflect 

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

func (*Publishing) Reset 

func (x *Publishing) Reset()

func (*Publishing) String 

func (x *Publishing) String() string

type QueryAssignmentRequest 

type QueryAssignmentRequest struct {
	Topic     *Resource  `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Group     *Resource  `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"`
	Endpoints *Endpoints `protobuf:"bytes,3,opt,name=endpoints,proto3" json:"endpoints,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryAssignmentRequest) Descriptor deprecated 

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

Deprecated: Use QueryAssignmentRequest.ProtoReflect.Descriptor instead.

func (*QueryAssignmentRequest) GetEndpoints 

func (x *QueryAssignmentRequest) GetEndpoints() *Endpoints

func (*QueryAssignmentRequest) GetGroup 

func (x *QueryAssignmentRequest) GetGroup() *Resource

func (*QueryAssignmentRequest) GetTopic 

func (x *QueryAssignmentRequest) GetTopic() *Resource

func (*QueryAssignmentRequest) ProtoMessage 

func (*QueryAssignmentRequest) ProtoMessage()

func (*QueryAssignmentRequest) ProtoReflect 

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

func (*QueryAssignmentRequest) Reset 

func (x *QueryAssignmentRequest) Reset()

func (*QueryAssignmentRequest) String 

func (x *QueryAssignmentRequest) String() string

type QueryAssignmentResponse 

type QueryAssignmentResponse struct {
	Status      *Status       `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Assignments []*Assignment `protobuf:"bytes,2,rep,name=assignments,proto3" json:"assignments,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryAssignmentResponse) Descriptor deprecated 

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

Deprecated: Use QueryAssignmentResponse.ProtoReflect.Descriptor instead.

func (*QueryAssignmentResponse) GetAssignments 

func (x *QueryAssignmentResponse) GetAssignments() []*Assignment

func (*QueryAssignmentResponse) GetStatus 

func (x *QueryAssignmentResponse) GetStatus() *Status

func (*QueryAssignmentResponse) ProtoMessage 

func (*QueryAssignmentResponse) ProtoMessage()

func (*QueryAssignmentResponse) ProtoReflect 

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

func (*QueryAssignmentResponse) Reset 

func (x *QueryAssignmentResponse) Reset()

func (*QueryAssignmentResponse) String 

func (x *QueryAssignmentResponse) String() string

type QueryRouteRequest 

type QueryRouteRequest struct {
	Topic     *Resource  `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Endpoints *Endpoints `protobuf:"bytes,2,opt,name=endpoints,proto3" json:"endpoints,omitempty"`
	// contains filtered or unexported fields
}

Topics are destination of messages to publish to or subscribe from. Similar to domain names, they will be addressable after resolution through the provided access point.

Access points are usually the addresses of name servers, which fulfill service discovery, load-balancing and other auxiliary services. Name servers receive periodic heartbeats from affiliate brokers and erase those which failed to maintain alive status.

Name servers answer queries of QueryRouteRequest, responding clients with addressable message-queues, which they may directly publish messages to or subscribe messages from.

QueryRouteRequest shall include source endpoints, aka, configured access-point, which annotates tenant-id, instance-id or other vendor-specific settings. Purpose-built name servers may respond customized results based on these particular requirements.

func (*QueryRouteRequest) Descriptor deprecated 

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

Deprecated: Use QueryRouteRequest.ProtoReflect.Descriptor instead.

func (*QueryRouteRequest) GetEndpoints 

func (x *QueryRouteRequest) GetEndpoints() *Endpoints

func (*QueryRouteRequest) GetTopic 

func (x *QueryRouteRequest) GetTopic() *Resource

func (*QueryRouteRequest) ProtoMessage 

func (*QueryRouteRequest) ProtoMessage()

func (*QueryRouteRequest) ProtoReflect 

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

func (*QueryRouteRequest) Reset 

func (x *QueryRouteRequest) Reset()

func (*QueryRouteRequest) String 

func (x *QueryRouteRequest) String() string

type QueryRouteResponse 

type QueryRouteResponse struct {
	Status        *Status         `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	MessageQueues []*MessageQueue `protobuf:"bytes,2,rep,name=message_queues,json=messageQueues,proto3" json:"message_queues,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryRouteResponse) Descriptor deprecated 

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

Deprecated: Use QueryRouteResponse.ProtoReflect.Descriptor instead.

func (*QueryRouteResponse) GetMessageQueues 

func (x *QueryRouteResponse) GetMessageQueues() []*MessageQueue

func (*QueryRouteResponse) GetStatus 

func (x *QueryRouteResponse) GetStatus() *Status

func (*QueryRouteResponse) ProtoMessage 

func (*QueryRouteResponse) ProtoMessage()

func (*QueryRouteResponse) ProtoReflect 

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

func (*QueryRouteResponse) Reset 

func (x *QueryRouteResponse) Reset()

func (*QueryRouteResponse) String 

func (x *QueryRouteResponse) String() string

type ReceiveMessageRequest 

type ReceiveMessageRequest struct {
	Group            *Resource         `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	MessageQueue     *MessageQueue     `protobuf:"bytes,2,opt,name=message_queue,json=messageQueue,proto3" json:"message_queue,omitempty"`
	FilterExpression *FilterExpression `protobuf:"bytes,3,opt,name=filter_expression,json=filterExpression,proto3" json:"filter_expression,omitempty"`
	BatchSize        int32             `protobuf:"varint,4,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// Required if client type is simple consumer.
	InvisibleDuration *durationpb.Duration `protobuf:"bytes,5,opt,name=invisible_duration,json=invisibleDuration,proto3,oneof" json:"invisible_duration,omitempty"`
	// For message auto renew and clean
	AutoRenew bool `protobuf:"varint,6,opt,name=auto_renew,json=autoRenew,proto3" json:"auto_renew,omitempty"`
	// contains filtered or unexported fields
}

func (*ReceiveMessageRequest) Descriptor deprecated 

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

Deprecated: Use ReceiveMessageRequest.ProtoReflect.Descriptor instead.

func (*ReceiveMessageRequest) GetAutoRenew 

func (x *ReceiveMessageRequest) GetAutoRenew() bool

func (*ReceiveMessageRequest) GetBatchSize 

func (x *ReceiveMessageRequest) GetBatchSize() int32

func (*ReceiveMessageRequest) GetFilterExpression 

func (x *ReceiveMessageRequest) GetFilterExpression() *FilterExpression

func (*ReceiveMessageRequest) GetGroup 

func (x *ReceiveMessageRequest) GetGroup() *Resource

func (*ReceiveMessageRequest) GetInvisibleDuration 

func (x *ReceiveMessageRequest) GetInvisibleDuration() *durationpb.Duration

func (*ReceiveMessageRequest) GetMessageQueue 

func (x *ReceiveMessageRequest) GetMessageQueue() *MessageQueue

func (*ReceiveMessageRequest) ProtoMessage 

func (*ReceiveMessageRequest) ProtoMessage()

func (*ReceiveMessageRequest) ProtoReflect 

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

func (*ReceiveMessageRequest) Reset 

func (x *ReceiveMessageRequest) Reset()

func (*ReceiveMessageRequest) String 

func (x *ReceiveMessageRequest) String() string

type ReceiveMessageResponse 

type ReceiveMessageResponse struct {

	// Types that are assignable to Content:
	//	*ReceiveMessageResponse_Status
	//	*ReceiveMessageResponse_Message
	//	*ReceiveMessageResponse_DeliveryTimestamp
	Content isReceiveMessageResponse_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

func (*ReceiveMessageResponse) Descriptor deprecated 

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

Deprecated: Use ReceiveMessageResponse.ProtoReflect.Descriptor instead.

func (*ReceiveMessageResponse) GetContent 

func (m *ReceiveMessageResponse) GetContent() isReceiveMessageResponse_Content

func (*ReceiveMessageResponse) GetDeliveryTimestamp 

func (x *ReceiveMessageResponse) GetDeliveryTimestamp() *timestamppb.Timestamp

func (*ReceiveMessageResponse) GetMessage 

func (x *ReceiveMessageResponse) GetMessage() *Message

func (*ReceiveMessageResponse) GetStatus 

func (x *ReceiveMessageResponse) GetStatus() *Status

func (*ReceiveMessageResponse) ProtoMessage 

func (*ReceiveMessageResponse) ProtoMessage()

func (*ReceiveMessageResponse) ProtoReflect 

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

func (*ReceiveMessageResponse) Reset 

func (x *ReceiveMessageResponse) Reset()

func (*ReceiveMessageResponse) String 

func (x *ReceiveMessageResponse) String() string

type ReceiveMessageResponse_DeliveryTimestamp 

type ReceiveMessageResponse_DeliveryTimestamp struct {
	// The timestamp that brokers start to deliver status line or message.
	DeliveryTimestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=delivery_timestamp,json=deliveryTimestamp,proto3,oneof"`
}

type ReceiveMessageResponse_Message 

type ReceiveMessageResponse_Message struct {
	Message *Message `protobuf:"bytes,2,opt,name=message,proto3,oneof"`
}

type ReceiveMessageResponse_Status 

type ReceiveMessageResponse_Status struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3,oneof"`
}

type RecoverOrphanedTransactionCommand 

type RecoverOrphanedTransactionCommand struct {
	Message       *Message `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	TransactionId string   `protobuf:"bytes,2,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RecoverOrphanedTransactionCommand) Descriptor deprecated 

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

Deprecated: Use RecoverOrphanedTransactionCommand.ProtoReflect.Descriptor instead.

func (*RecoverOrphanedTransactionCommand) GetMessage 

func (x *RecoverOrphanedTransactionCommand) GetMessage() *Message

func (*RecoverOrphanedTransactionCommand) GetTransactionId 

func (x *RecoverOrphanedTransactionCommand) GetTransactionId() string

func (*RecoverOrphanedTransactionCommand) ProtoMessage 

func (*RecoverOrphanedTransactionCommand) ProtoMessage()

func (*RecoverOrphanedTransactionCommand) ProtoReflect 

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

func (*RecoverOrphanedTransactionCommand) Reset 

func (x *RecoverOrphanedTransactionCommand) Reset()

func (*RecoverOrphanedTransactionCommand) String 

func (x *RecoverOrphanedTransactionCommand) String() string

type Resource 

type Resource struct {
	ResourceNamespace string `protobuf:"bytes,1,opt,name=resource_namespace,json=resourceNamespace,proto3" json:"resource_namespace,omitempty"`
	// Resource name identifier, which remains unique within the abstract resource
	// namespace.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*Resource) Descriptor deprecated 

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

Deprecated: Use Resource.ProtoReflect.Descriptor instead.

func (*Resource) GetName 

func (x *Resource) GetName() string

func (*Resource) GetResourceNamespace 

func (x *Resource) GetResourceNamespace() string

func (*Resource) ProtoMessage 

func (*Resource) ProtoMessage()

func (*Resource) ProtoReflect 

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

func (*Resource) Reset 

func (x *Resource) Reset()

func (*Resource) String 

func (x *Resource) String() string

type RetryPolicy 

type RetryPolicy struct {
	MaxAttempts int32 `protobuf:"varint,1,opt,name=max_attempts,json=maxAttempts,proto3" json:"max_attempts,omitempty"`
	// Types that are assignable to Strategy:
	//	*RetryPolicy_ExponentialBackoff
	//	*RetryPolicy_CustomizedBackoff
	Strategy isRetryPolicy_Strategy `protobuf_oneof:"strategy"`
	// contains filtered or unexported fields
}

func (*RetryPolicy) Descriptor deprecated 

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

Deprecated: Use RetryPolicy.ProtoReflect.Descriptor instead.

func (*RetryPolicy) GetCustomizedBackoff 

func (x *RetryPolicy) GetCustomizedBackoff() *CustomizedBackoff

func (*RetryPolicy) GetExponentialBackoff 

func (x *RetryPolicy) GetExponentialBackoff() *ExponentialBackoff

func (*RetryPolicy) GetMaxAttempts 

func (x *RetryPolicy) GetMaxAttempts() int32

func (*RetryPolicy) GetStrategy 

func (m *RetryPolicy) GetStrategy() isRetryPolicy_Strategy

func (*RetryPolicy) ProtoMessage 

func (*RetryPolicy) ProtoMessage()

func (*RetryPolicy) ProtoReflect 

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

func (*RetryPolicy) Reset 

func (x *RetryPolicy) Reset()

func (*RetryPolicy) String 

func (x *RetryPolicy) String() string

type RetryPolicy_CustomizedBackoff 

type RetryPolicy_CustomizedBackoff struct {
	CustomizedBackoff *CustomizedBackoff `protobuf:"bytes,3,opt,name=customized_backoff,json=customizedBackoff,proto3,oneof"`
}

type RetryPolicy_ExponentialBackoff 

type RetryPolicy_ExponentialBackoff struct {
	ExponentialBackoff *ExponentialBackoff `protobuf:"bytes,2,opt,name=exponential_backoff,json=exponentialBackoff,proto3,oneof"`
}

type SendMessageRequest 

type SendMessageRequest struct {
	Messages []*Message `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*SendMessageRequest) Descriptor deprecated 

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

Deprecated: Use SendMessageRequest.ProtoReflect.Descriptor instead.

func (*SendMessageRequest) GetMessages 

func (x *SendMessageRequest) GetMessages() []*Message

func (*SendMessageRequest) ProtoMessage 

func (*SendMessageRequest) ProtoMessage()

func (*SendMessageRequest) ProtoReflect 

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

func (*SendMessageRequest) Reset 

func (x *SendMessageRequest) Reset()

func (*SendMessageRequest) String 

func (x *SendMessageRequest) String() string

type SendMessageResponse 

type SendMessageResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// Some implementation may have partial failure issues. Client SDK developers are expected to inspect
	// each entry for best certainty.
	Entries []*SendResultEntry `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*SendMessageResponse) Descriptor deprecated 

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

Deprecated: Use SendMessageResponse.ProtoReflect.Descriptor instead.

func (*SendMessageResponse) GetEntries 

func (x *SendMessageResponse) GetEntries() []*SendResultEntry

func (*SendMessageResponse) GetStatus 

func (x *SendMessageResponse) GetStatus() *Status

func (*SendMessageResponse) ProtoMessage 

func (*SendMessageResponse) ProtoMessage()

func (*SendMessageResponse) ProtoReflect 

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

func (*SendMessageResponse) Reset 

func (x *SendMessageResponse) Reset()

func (*SendMessageResponse) String 

func (x *SendMessageResponse) String() string

type SendResultEntry 

type SendResultEntry struct {
	Status        *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	MessageId     string  `protobuf:"bytes,2,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	TransactionId string  `protobuf:"bytes,3,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	Offset        int64   `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*SendResultEntry) Descriptor deprecated 

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

Deprecated: Use SendResultEntry.ProtoReflect.Descriptor instead.

func (*SendResultEntry) GetMessageId 

func (x *SendResultEntry) GetMessageId() string

func (*SendResultEntry) GetOffset 

func (x *SendResultEntry) GetOffset() int64

func (*SendResultEntry) GetStatus 

func (x *SendResultEntry) GetStatus() *Status

func (*SendResultEntry) GetTransactionId 

func (x *SendResultEntry) GetTransactionId() string

func (*SendResultEntry) ProtoMessage 

func (*SendResultEntry) ProtoMessage()

func (*SendResultEntry) ProtoReflect 

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

func (*SendResultEntry) Reset 

func (x *SendResultEntry) Reset()

func (*SendResultEntry) String 

func (x *SendResultEntry) String() string

type Settings 

type Settings struct {

	// Configurations for all clients.
	ClientType  *ClientType `` /* 133-byte string literal not displayed */
	AccessPoint *Endpoints  `protobuf:"bytes,2,opt,name=access_point,json=accessPoint,proto3,oneof" json:"access_point,omitempty"`
	// If publishing of messages encounters throttling or server internal errors,
	// publishers should implement automatic retries after progressive longer
	// back-offs for consecutive errors.
	//
	// When processing message fails, `backoff_policy` describes an interval
	// after which the message should be available to consume again.
	//
	// For FIFO messages, the interval should be relatively small because
	// messages of the same message group would not be readily available until
	// the prior one depletes its lifecycle.
	BackoffPolicy *RetryPolicy `protobuf:"bytes,3,opt,name=backoff_policy,json=backoffPolicy,proto3,oneof" json:"backoff_policy,omitempty"`
	// Request timeout for RPCs excluding long-polling.
	RequestTimeout *durationpb.Duration `protobuf:"bytes,4,opt,name=request_timeout,json=requestTimeout,proto3,oneof" json:"request_timeout,omitempty"`
	// Types that are assignable to PubSub:
	//	*Settings_Publishing
	//	*Settings_Subscription
	PubSub isSettings_PubSub `protobuf_oneof:"pub_sub"`
	// User agent details
	UserAgent *UA     `protobuf:"bytes,7,opt,name=user_agent,json=userAgent,proto3" json:"user_agent,omitempty"`
	Metric    *Metric `protobuf:"bytes,8,opt,name=metric,proto3" json:"metric,omitempty"`
	// contains filtered or unexported fields
}

func (*Settings) Descriptor deprecated 

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

Deprecated: Use Settings.ProtoReflect.Descriptor instead.

func (*Settings) GetAccessPoint 

func (x *Settings) GetAccessPoint() *Endpoints

func (*Settings) GetBackoffPolicy 

func (x *Settings) GetBackoffPolicy() *RetryPolicy

func (*Settings) GetClientType 

func (x *Settings) GetClientType() ClientType

func (*Settings) GetMetric 

func (x *Settings) GetMetric() *Metric

func (*Settings) GetPubSub 

func (m *Settings) GetPubSub() isSettings_PubSub

func (*Settings) GetPublishing 

func (x *Settings) GetPublishing() *Publishing

func (*Settings) GetRequestTimeout 

func (x *Settings) GetRequestTimeout() *durationpb.Duration

func (*Settings) GetSubscription 

func (x *Settings) GetSubscription() *Subscription

func (*Settings) GetUserAgent 

func (x *Settings) GetUserAgent() *UA

func (*Settings) ProtoMessage 

func (*Settings) ProtoMessage()

func (*Settings) ProtoReflect 

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

func (*Settings) Reset 

func (x *Settings) Reset()

func (*Settings) String 

func (x *Settings) String() string

type Settings_Publishing 

type Settings_Publishing struct {
	Publishing *Publishing `protobuf:"bytes,5,opt,name=publishing,proto3,oneof"`
}

type Settings_Subscription 

type Settings_Subscription struct {
	Subscription *Subscription `protobuf:"bytes,6,opt,name=subscription,proto3,oneof"`
}

type Status 

type Status struct {
	Code    Code   `protobuf:"varint,1,opt,name=code,proto3,enum=apache.rocketmq.v2.Code" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetCode 

func (x *Status) GetCode() Code

func (*Status) GetMessage 

func (x *Status) GetMessage() string

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

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

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type Subscription 

type Subscription struct {

	// Subscription settings below here is appointed by client, thus it is
	// unnecessary for server to push at present.
	//
	// Consumer group.
	Group *Resource `protobuf:"bytes,1,opt,name=group,proto3,oneof" json:"group,omitempty"`
	// Subscription for consumer.
	Subscriptions []*SubscriptionEntry `protobuf:"bytes,2,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// Subscription settings below here are from server, it is essential for
	// server to push.
	//
	// When FIFO flag is `true`, messages of the same message group are processed
	// in first-in-first-out manner.
	//
	// Brokers will not deliver further messages of the same group until prior
	// ones are completely acknowledged.
	Fifo *bool `protobuf:"varint,3,opt,name=fifo,proto3,oneof" json:"fifo,omitempty"`
	// Message receive batch size here is essential for push consumer.
	ReceiveBatchSize *int32 `protobuf:"varint,4,opt,name=receive_batch_size,json=receiveBatchSize,proto3,oneof" json:"receive_batch_size,omitempty"`
	// Long-polling timeout for `ReceiveMessageRequest`, which is essential for
	// push consumer.
	LongPollingTimeout *durationpb.Duration `protobuf:"bytes,5,opt,name=long_polling_timeout,json=longPollingTimeout,proto3,oneof" json:"long_polling_timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*Subscription) Descriptor deprecated 

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

Deprecated: Use Subscription.ProtoReflect.Descriptor instead.

func (*Subscription) GetFifo 

func (x *Subscription) GetFifo() bool

func (*Subscription) GetGroup 

func (x *Subscription) GetGroup() *Resource

func (*Subscription) GetLongPollingTimeout 

func (x *Subscription) GetLongPollingTimeout() *durationpb.Duration

func (*Subscription) GetReceiveBatchSize 

func (x *Subscription) GetReceiveBatchSize() int32

func (*Subscription) GetSubscriptions 

func (x *Subscription) GetSubscriptions() []*SubscriptionEntry

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 SubscriptionEntry 

type SubscriptionEntry struct {
	Topic      *Resource         `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Expression *FilterExpression `protobuf:"bytes,2,opt,name=expression,proto3" json:"expression,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionEntry) Descriptor deprecated 

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

Deprecated: Use SubscriptionEntry.ProtoReflect.Descriptor instead.

func (*SubscriptionEntry) GetExpression 

func (x *SubscriptionEntry) GetExpression() *FilterExpression

func (*SubscriptionEntry) GetTopic 

func (x *SubscriptionEntry) GetTopic() *Resource

func (*SubscriptionEntry) ProtoMessage 

func (*SubscriptionEntry) ProtoMessage()

func (*SubscriptionEntry) ProtoReflect 

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

func (*SubscriptionEntry) Reset 

func (x *SubscriptionEntry) Reset()

func (*SubscriptionEntry) String 

func (x *SubscriptionEntry) String() string

type SystemProperties 

type SystemProperties struct {

	// Tag, which is optional.
	Tag *string `protobuf:"bytes,1,opt,name=tag,proto3,oneof" json:"tag,omitempty"`
	// Message keys
	Keys []string `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// Message identifier, client-side generated, remains unique.
	// if message_id is empty, the send message request will be aborted with
	// status `INVALID_ARGUMENT`
	MessageId string `protobuf:"bytes,3,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// Message body digest
	BodyDigest *Digest `protobuf:"bytes,4,opt,name=body_digest,json=bodyDigest,proto3" json:"body_digest,omitempty"`
	// Message body encoding. Candidate options are identity, gzip, snappy etc.
	BodyEncoding Encoding `` /* 131-byte string literal not displayed */
	// Message type, normal, FIFO or transactional.
	MessageType MessageType `` /* 131-byte string literal not displayed */
	// Message born time-point.
	BornTimestamp *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=born_timestamp,json=bornTimestamp,proto3" json:"born_timestamp,omitempty"`
	// Message born host. Valid options are IPv4, IPv6 or client host domain name.
	BornHost string `protobuf:"bytes,8,opt,name=born_host,json=bornHost,proto3" json:"born_host,omitempty"`
	// Time-point at which the message is stored in the broker, which is absent
	// for message publishing.
	StoreTimestamp *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=store_timestamp,json=storeTimestamp,proto3,oneof" json:"store_timestamp,omitempty"`
	// The broker that stores this message. It may be broker name, IP or arbitrary
	// identifier that uniquely identify the server.
	StoreHost string `protobuf:"bytes,10,opt,name=store_host,json=storeHost,proto3" json:"store_host,omitempty"`
	// Time-point at which broker delivers to clients, which is optional.
	DeliveryTimestamp *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=delivery_timestamp,json=deliveryTimestamp,proto3,oneof" json:"delivery_timestamp,omitempty"`
	// If a message is acquired by way of POP, this field holds the receipt,
	// which is absent for message publishing.
	// Clients use the receipt to acknowledge or negatively acknowledge the
	// message.
	ReceiptHandle *string `protobuf:"bytes,12,opt,name=receipt_handle,json=receiptHandle,proto3,oneof" json:"receipt_handle,omitempty"`
	// Message queue identifier in which a message is physically stored.
	QueueId int32 `protobuf:"varint,13,opt,name=queue_id,json=queueId,proto3" json:"queue_id,omitempty"`
	// Message-queue offset at which a message is stored, which is absent for
	// message publishing.
	QueueOffset *int64 `protobuf:"varint,14,opt,name=queue_offset,json=queueOffset,proto3,oneof" json:"queue_offset,omitempty"`
	// Period of time servers would remain invisible once a message is acquired.
	InvisibleDuration *durationpb.Duration `protobuf:"bytes,15,opt,name=invisible_duration,json=invisibleDuration,proto3,oneof" json:"invisible_duration,omitempty"`
	// Business code may failed to process messages for the moment. Hence, clients
	// may request servers to deliver them again using certain back-off strategy,
	// the attempt is 1 not 0 if message is delivered first time, and it is absent
	// for message publishing.
	DeliveryAttempt *int32 `protobuf:"varint,16,opt,name=delivery_attempt,json=deliveryAttempt,proto3,oneof" json:"delivery_attempt,omitempty"`
	// Define the group name of message in the same topic, which is optional.
	MessageGroup *string `protobuf:"bytes,17,opt,name=message_group,json=messageGroup,proto3,oneof" json:"message_group,omitempty"`
	// Trace context for each message, which is optional.
	TraceContext *string `protobuf:"bytes,18,opt,name=trace_context,json=traceContext,proto3,oneof" json:"trace_context,omitempty"`
	// If a transactional message stay unresolved for more than
	// `transaction_orphan_threshold`, it would be regarded as an
	// orphan. Servers that manages orphan messages would pick up
	// a capable publisher to resolve
	OrphanedTransactionRecoveryDuration *durationpb.Duration `` /* 177-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SystemProperties) Descriptor deprecated 

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

Deprecated: Use SystemProperties.ProtoReflect.Descriptor instead.

func (*SystemProperties) GetBodyDigest 

func (x *SystemProperties) GetBodyDigest() *Digest

func (*SystemProperties) GetBodyEncoding 

func (x *SystemProperties) GetBodyEncoding() Encoding

func (*SystemProperties) GetBornHost 

func (x *SystemProperties) GetBornHost() string

func (*SystemProperties) GetBornTimestamp 

func (x *SystemProperties) GetBornTimestamp() *timestamppb.Timestamp

func (*SystemProperties) GetDeliveryAttempt 

func (x *SystemProperties) GetDeliveryAttempt() int32

func (*SystemProperties) GetDeliveryTimestamp 

func (x *SystemProperties) GetDeliveryTimestamp() *timestamppb.Timestamp

func (*SystemProperties) GetInvisibleDuration 

func (x *SystemProperties) GetInvisibleDuration() *durationpb.Duration

func (*SystemProperties) GetKeys 

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

func (*SystemProperties) GetMessageGroup 

func (x *SystemProperties) GetMessageGroup() string

func (*SystemProperties) GetMessageId 

func (x *SystemProperties) GetMessageId() string

func (*SystemProperties) GetMessageType 

func (x *SystemProperties) GetMessageType() MessageType

func (*SystemProperties) GetOrphanedTransactionRecoveryDuration 

func (x *SystemProperties) GetOrphanedTransactionRecoveryDuration() *durationpb.Duration

func (*SystemProperties) GetQueueId 

func (x *SystemProperties) GetQueueId() int32

func (*SystemProperties) GetQueueOffset 

func (x *SystemProperties) GetQueueOffset() int64

func (*SystemProperties) GetReceiptHandle 

func (x *SystemProperties) GetReceiptHandle() string

func (*SystemProperties) GetStoreHost 

func (x *SystemProperties) GetStoreHost() string

func (*SystemProperties) GetStoreTimestamp 

func (x *SystemProperties) GetStoreTimestamp() *timestamppb.Timestamp

func (*SystemProperties) GetTag 

func (x *SystemProperties) GetTag() string

func (*SystemProperties) GetTraceContext 

func (x *SystemProperties) GetTraceContext() string

func (*SystemProperties) ProtoMessage 

func (*SystemProperties) ProtoMessage()

func (*SystemProperties) ProtoReflect 

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

func (*SystemProperties) Reset 

func (x *SystemProperties) Reset()

func (*SystemProperties) String 

func (x *SystemProperties) String() string

type TelemetryCommand 

type TelemetryCommand struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3,oneof" json:"status,omitempty"`
	// Types that are assignable to Command:
	//	*TelemetryCommand_Settings
	//	*TelemetryCommand_ThreadStackTrace
	//	*TelemetryCommand_VerifyMessageResult
	//	*TelemetryCommand_RecoverOrphanedTransactionCommand
	//	*TelemetryCommand_PrintThreadStackTraceCommand
	//	*TelemetryCommand_VerifyMessageCommand
	Command isTelemetryCommand_Command `protobuf_oneof:"command"`
	// contains filtered or unexported fields
}

func (*TelemetryCommand) Descriptor deprecated 

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

Deprecated: Use TelemetryCommand.ProtoReflect.Descriptor instead.

func (*TelemetryCommand) GetCommand 

func (m *TelemetryCommand) GetCommand() isTelemetryCommand_Command

func (*TelemetryCommand) GetPrintThreadStackTraceCommand 

func (x *TelemetryCommand) GetPrintThreadStackTraceCommand() *PrintThreadStackTraceCommand

func (*TelemetryCommand) GetRecoverOrphanedTransactionCommand 

func (x *TelemetryCommand) GetRecoverOrphanedTransactionCommand() *RecoverOrphanedTransactionCommand

func (*TelemetryCommand) GetSettings 

func (x *TelemetryCommand) GetSettings() *Settings

func (*TelemetryCommand) GetStatus 

func (x *TelemetryCommand) GetStatus() *Status

func (*TelemetryCommand) GetThreadStackTrace 

func (x *TelemetryCommand) GetThreadStackTrace() *ThreadStackTrace

func (*TelemetryCommand) GetVerifyMessageCommand 

func (x *TelemetryCommand) GetVerifyMessageCommand() *VerifyMessageCommand

func (*TelemetryCommand) GetVerifyMessageResult 

func (x *TelemetryCommand) GetVerifyMessageResult() *VerifyMessageResult

func (*TelemetryCommand) ProtoMessage 

func (*TelemetryCommand) ProtoMessage()

func (*TelemetryCommand) ProtoReflect 

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

func (*TelemetryCommand) Reset 

func (x *TelemetryCommand) Reset()

func (*TelemetryCommand) String 

func (x *TelemetryCommand) String() string

type TelemetryCommand_PrintThreadStackTraceCommand 

type TelemetryCommand_PrintThreadStackTraceCommand struct {
	// Request client to print thread stack trace.
	PrintThreadStackTraceCommand *PrintThreadStackTraceCommand `protobuf:"bytes,6,opt,name=print_thread_stack_trace_command,json=printThreadStackTraceCommand,proto3,oneof"`
}

type TelemetryCommand_RecoverOrphanedTransactionCommand 

type TelemetryCommand_RecoverOrphanedTransactionCommand struct {
	// There messages are from server.
	//
	// Request client to recover the orphaned transaction message.
	RecoverOrphanedTransactionCommand *RecoverOrphanedTransactionCommand `protobuf:"bytes,5,opt,name=recover_orphaned_transaction_command,json=recoverOrphanedTransactionCommand,proto3,oneof"`
}

type TelemetryCommand_Settings 

type TelemetryCommand_Settings struct {
	// Client settings
	Settings *Settings `protobuf:"bytes,2,opt,name=settings,proto3,oneof"`
}

type TelemetryCommand_ThreadStackTrace 

type TelemetryCommand_ThreadStackTrace struct {
	// These messages are from client.
	//
	// Report thread stack trace to server.
	ThreadStackTrace *ThreadStackTrace `protobuf:"bytes,3,opt,name=thread_stack_trace,json=threadStackTrace,proto3,oneof"`
}

type TelemetryCommand_VerifyMessageCommand 

type TelemetryCommand_VerifyMessageCommand struct {
	// Request client to verify the consumption of the appointed message.
	VerifyMessageCommand *VerifyMessageCommand `protobuf:"bytes,7,opt,name=verify_message_command,json=verifyMessageCommand,proto3,oneof"`
}

type TelemetryCommand_VerifyMessageResult 

type TelemetryCommand_VerifyMessageResult struct {
	// Report message verify result to server.
	VerifyMessageResult *VerifyMessageResult `protobuf:"bytes,4,opt,name=verify_message_result,json=verifyMessageResult,proto3,oneof"`
}

type ThreadStackTrace 

type ThreadStackTrace struct {
	Nonce            string  `protobuf:"bytes,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	ThreadStackTrace *string `protobuf:"bytes,2,opt,name=thread_stack_trace,json=threadStackTrace,proto3,oneof" json:"thread_stack_trace,omitempty"`
	// contains filtered or unexported fields
}

func (*ThreadStackTrace) Descriptor deprecated 

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

Deprecated: Use ThreadStackTrace.ProtoReflect.Descriptor instead.

func (*ThreadStackTrace) GetNonce 

func (x *ThreadStackTrace) GetNonce() string

func (*ThreadStackTrace) GetThreadStackTrace 

func (x *ThreadStackTrace) GetThreadStackTrace() string

func (*ThreadStackTrace) ProtoMessage 

func (*ThreadStackTrace) ProtoMessage()

func (*ThreadStackTrace) ProtoReflect 

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

func (*ThreadStackTrace) Reset 

func (x *ThreadStackTrace) Reset()

func (*ThreadStackTrace) String 

func (x *ThreadStackTrace) String() string

type TransactionResolution 

type TransactionResolution int32
const (
	TransactionResolution_TRANSACTION_RESOLUTION_UNSPECIFIED TransactionResolution = 0
	TransactionResolution_COMMIT                             TransactionResolution = 1
	TransactionResolution_ROLLBACK                           TransactionResolution = 2
)

func (TransactionResolution) Descriptor 

func (TransactionResolution) Descriptor() protoreflect.EnumDescriptor

func (TransactionResolution) Enum 

func (x TransactionResolution) Enum() *TransactionResolution

func (TransactionResolution) EnumDescriptor deprecated 

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

Deprecated: Use TransactionResolution.Descriptor instead.

func (TransactionResolution) Number 

func (x TransactionResolution) Number() protoreflect.EnumNumber

func (TransactionResolution) String 

func (x TransactionResolution) String() string

func (TransactionResolution) Type 

func (TransactionResolution) Type() protoreflect.EnumType

type TransactionSource 

type TransactionSource int32
const (
	TransactionSource_SOURCE_UNSPECIFIED  TransactionSource = 0
	TransactionSource_SOURCE_CLIENT       TransactionSource = 1
	TransactionSource_SOURCE_SERVER_CHECK TransactionSource = 2
)

func (TransactionSource) Descriptor 

func (TransactionSource) Descriptor() protoreflect.EnumDescriptor

func (TransactionSource) Enum 

func (x TransactionSource) Enum() *TransactionSource

func (TransactionSource) EnumDescriptor deprecated 

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

Deprecated: Use TransactionSource.Descriptor instead.

func (TransactionSource) Number 

func (x TransactionSource) Number() protoreflect.EnumNumber

func (TransactionSource) String 

func (x TransactionSource) String() string

func (TransactionSource) Type 

func (TransactionSource) Type() protoreflect.EnumType

type UA 

type UA struct {

	// SDK language
	Language Language `protobuf:"varint,1,opt,name=language,proto3,enum=apache.rocketmq.v2.Language" json:"language,omitempty"`
	// SDK version
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// Platform details, including OS name, version, arch etc.
	Platform string `protobuf:"bytes,3,opt,name=platform,proto3" json:"platform,omitempty"`
	// Hostname of the node
	Hostname string `protobuf:"bytes,4,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

User Agent

func (*UA) Descriptor deprecated 

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

Deprecated: Use UA.ProtoReflect.Descriptor instead.

func (*UA) GetHostname 

func (x *UA) GetHostname() string

func (*UA) GetLanguage 

func (x *UA) GetLanguage() Language

func (*UA) GetPlatform 

func (x *UA) GetPlatform() string

func (*UA) GetVersion 

func (x *UA) GetVersion() string

func (*UA) ProtoMessage 

func (*UA) ProtoMessage()

func (*UA) ProtoReflect 

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

func (*UA) Reset 

func (x *UA) Reset()

func (*UA) String 

func (x *UA) String() string

type UnimplementedAdminServer 

type UnimplementedAdminServer struct {
}

UnimplementedAdminServer must be embedded to have forward compatible implementations.

func (UnimplementedAdminServer) ChangeLogLevel 

func (UnimplementedAdminServer) ChangeLogLevel(context.Context, *ChangeLogLevelRequest) (*ChangeLogLevelResponse, error)

type UnimplementedMessagingServiceServer 

type UnimplementedMessagingServiceServer struct {
}

UnimplementedMessagingServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMessagingServiceServer) AckMessage 

func (UnimplementedMessagingServiceServer) AckMessage(context.Context, *AckMessageRequest) (*AckMessageResponse, error)

func (UnimplementedMessagingServiceServer) ChangeInvisibleDuration 

func (UnimplementedMessagingServiceServer) ChangeInvisibleDuration(context.Context, *ChangeInvisibleDurationRequest) (*ChangeInvisibleDurationResponse, error)

func (UnimplementedMessagingServiceServer) EndTransaction 

func (UnimplementedMessagingServiceServer) EndTransaction(context.Context, *EndTransactionRequest) (*EndTransactionResponse, error)

func (UnimplementedMessagingServiceServer) ForwardMessageToDeadLetterQueue 

func (UnimplementedMessagingServiceServer) ForwardMessageToDeadLetterQueue(context.Context, *ForwardMessageToDeadLetterQueueRequest) (*ForwardMessageToDeadLetterQueueResponse, error)

func (UnimplementedMessagingServiceServer) Heartbeat 

func (UnimplementedMessagingServiceServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)

func (UnimplementedMessagingServiceServer) NotifyClientTermination 

func (UnimplementedMessagingServiceServer) NotifyClientTermination(context.Context, *NotifyClientTerminationRequest) (*NotifyClientTerminationResponse, error)

func (UnimplementedMessagingServiceServer) QueryAssignment 

func (UnimplementedMessagingServiceServer) QueryAssignment(context.Context, *QueryAssignmentRequest) (*QueryAssignmentResponse, error)

func (UnimplementedMessagingServiceServer) QueryRoute 

func (UnimplementedMessagingServiceServer) QueryRoute(context.Context, *QueryRouteRequest) (*QueryRouteResponse, error)

func (UnimplementedMessagingServiceServer) ReceiveMessage 

func (UnimplementedMessagingServiceServer) ReceiveMessage(*ReceiveMessageRequest, MessagingService_ReceiveMessageServer) error

func (UnimplementedMessagingServiceServer) SendMessage 

func (UnimplementedMessagingServiceServer) SendMessage(context.Context, *SendMessageRequest) (*SendMessageResponse, error)

func (UnimplementedMessagingServiceServer) Telemetry 

func (UnimplementedMessagingServiceServer) Telemetry(MessagingService_TelemetryServer) error

type UnsafeAdminServer 

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

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

type UnsafeMessagingServiceServer 

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

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

type VerifyMessageCommand 

type VerifyMessageCommand struct {
	Nonce   string   `protobuf:"bytes,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	Message *Message `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifyMessageCommand) Descriptor deprecated 

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

Deprecated: Use VerifyMessageCommand.ProtoReflect.Descriptor instead.

func (*VerifyMessageCommand) GetMessage 

func (x *VerifyMessageCommand) GetMessage() *Message

func (*VerifyMessageCommand) GetNonce 

func (x *VerifyMessageCommand) GetNonce() string

func (*VerifyMessageCommand) ProtoMessage 

func (*VerifyMessageCommand) ProtoMessage()

func (*VerifyMessageCommand) ProtoReflect 

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

func (*VerifyMessageCommand) Reset 

func (x *VerifyMessageCommand) Reset()

func (*VerifyMessageCommand) String 

func (x *VerifyMessageCommand) String() string

type VerifyMessageResult 

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

func (*VerifyMessageResult) Descriptor deprecated 

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

Deprecated: Use VerifyMessageResult.ProtoReflect.Descriptor instead.

func (*VerifyMessageResult) GetNonce 

func (x *VerifyMessageResult) GetNonce() string

func (*VerifyMessageResult) ProtoMessage 

func (*VerifyMessageResult) ProtoMessage()

func (*VerifyMessageResult) ProtoReflect 

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

func (*VerifyMessageResult) Reset 

func (x *VerifyMessageResult) Reset()

func (*VerifyMessageResult) String 

func (x *VerifyMessageResult) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.