messaging

package
v0.15.0 Latest Latest
Warning

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

 Go to latest Published: Feb 12, 2026 License: MIT Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	AckMesssagesResponse_Result_name = map[int32]string{
		0: "OK",
	}
	AckMesssagesResponse_Result_value = map[string]int32{
		"OK": 0,
	}
)

Enum value maps for AckMesssagesResponse_Result.

View Source 
var (
	SendMessageResponse_Result_name = map[int32]string{
		0: "OK",
		1: "NO_ACTIVE_STREAM",
	}
	SendMessageResponse_Result_value = map[string]int32{
		"OK":               0,
		"NO_ACTIVE_STREAM": 1,
	}
)

Enum value maps for SendMessageResponse_Result.

View Source 
var File_messaging_v1_messaging_service_proto protoreflect.FileDescriptor
View Source 
var Messaging_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ocp.messaging.v1.Messaging",
	HandlerType: (*MessagingServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PollMessages",
			Handler:    _Messaging_PollMessages_Handler,
		},
		{
			MethodName: "AckMessages",
			Handler:    _Messaging_AckMessages_Handler,
		},
		{
			MethodName: "SendMessage",
			Handler:    _Messaging_SendMessage_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "OpenMessageStream",
			Handler:       _Messaging_OpenMessageStream_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "OpenMessageStreamWithKeepAlive",
			Handler:       _Messaging_OpenMessageStreamWithKeepAlive_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "messaging/v1/messaging_service.proto",
}

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

Functions

func RegisterMessagingServer 

func RegisterMessagingServer(s grpc.ServiceRegistrar, srv MessagingServer)

Types

type AckMessagesRequest 

type AckMessagesRequest struct {
	RendezvousKey *RendezvousKey `protobuf:"bytes,1,opt,name=rendezvous_key,json=rendezvousKey,proto3" json:"rendezvous_key,omitempty"`
	MessageIds    []*MessageId   `protobuf:"bytes,2,rep,name=message_ids,json=messageIds,proto3" json:"message_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*AckMessagesRequest) Descriptor deprecated 

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

Deprecated: Use AckMessagesRequest.ProtoReflect.Descriptor instead.

func (*AckMessagesRequest) GetMessageIds 

func (x *AckMessagesRequest) GetMessageIds() []*MessageId

func (*AckMessagesRequest) GetRendezvousKey 

func (x *AckMessagesRequest) GetRendezvousKey() *RendezvousKey

func (*AckMessagesRequest) ProtoMessage 

func (*AckMessagesRequest) ProtoMessage()

func (*AckMessagesRequest) ProtoReflect 

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

func (*AckMessagesRequest) Reset 

func (x *AckMessagesRequest) Reset()

func (*AckMessagesRequest) String 

func (x *AckMessagesRequest) String() string

func (*AckMessagesRequest) Validate 

func (m *AckMessagesRequest) Validate() error

Validate checks the field values on AckMessagesRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type AckMessagesRequestValidationError 

type AckMessagesRequestValidationError struct {
	// contains filtered or unexported fields
}

AckMessagesRequestValidationError is the validation error returned by AckMessagesRequest.Validate if the designated constraints aren't met.

func (AckMessagesRequestValidationError) Cause 

func (e AckMessagesRequestValidationError) Cause() error

Cause function returns cause value.

func (AckMessagesRequestValidationError) Error 

func (e AckMessagesRequestValidationError) Error() string

Error satisfies the builtin error interface

func (AckMessagesRequestValidationError) ErrorName 

func (e AckMessagesRequestValidationError) ErrorName() string

ErrorName returns error name.

func (AckMessagesRequestValidationError) Field 

func (e AckMessagesRequestValidationError) Field() string

Field function returns field value.

func (AckMessagesRequestValidationError) Key 

func (e AckMessagesRequestValidationError) Key() bool

Key function returns key value.

func (AckMessagesRequestValidationError) Reason 

func (e AckMessagesRequestValidationError) Reason() string

Reason function returns reason value.

type AckMesssagesResponse 

type AckMesssagesResponse struct {
	Result AckMesssagesResponse_Result `protobuf:"varint,1,opt,name=result,proto3,enum=ocp.messaging.v1.AckMesssagesResponse_Result" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*AckMesssagesResponse) Descriptor deprecated 

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

Deprecated: Use AckMesssagesResponse.ProtoReflect.Descriptor instead.

func (*AckMesssagesResponse) GetResult 

func (x *AckMesssagesResponse) GetResult() AckMesssagesResponse_Result

func (*AckMesssagesResponse) ProtoMessage 

func (*AckMesssagesResponse) ProtoMessage()

func (*AckMesssagesResponse) ProtoReflect 

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

func (*AckMesssagesResponse) Reset 

func (x *AckMesssagesResponse) Reset()

func (*AckMesssagesResponse) String 

func (x *AckMesssagesResponse) String() string

func (*AckMesssagesResponse) Validate 

func (m *AckMesssagesResponse) Validate() error

Validate checks the field values on AckMesssagesResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type AckMesssagesResponseValidationError 

type AckMesssagesResponseValidationError struct {
	// contains filtered or unexported fields
}

AckMesssagesResponseValidationError is the validation error returned by AckMesssagesResponse.Validate if the designated constraints aren't met.

func (AckMesssagesResponseValidationError) Cause 

func (e AckMesssagesResponseValidationError) Cause() error

Cause function returns cause value.

func (AckMesssagesResponseValidationError) Error 

func (e AckMesssagesResponseValidationError) Error() string

Error satisfies the builtin error interface

func (AckMesssagesResponseValidationError) ErrorName 

func (e AckMesssagesResponseValidationError) ErrorName() string

ErrorName returns error name.

func (AckMesssagesResponseValidationError) Field 

func (e AckMesssagesResponseValidationError) Field() string

Field function returns field value.

func (AckMesssagesResponseValidationError) Key 

func (e AckMesssagesResponseValidationError) Key() bool

Key function returns key value.

func (AckMesssagesResponseValidationError) Reason 

func (e AckMesssagesResponseValidationError) Reason() string

Reason function returns reason value.

type AckMesssagesResponse_Result 

type AckMesssagesResponse_Result int32
const (
	AckMesssagesResponse_OK AckMesssagesResponse_Result = 0
)

func (AckMesssagesResponse_Result) Descriptor 

func (AckMesssagesResponse_Result) Descriptor() protoreflect.EnumDescriptor

func (AckMesssagesResponse_Result) Enum 

func (x AckMesssagesResponse_Result) Enum() *AckMesssagesResponse_Result

func (AckMesssagesResponse_Result) EnumDescriptor deprecated 

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

Deprecated: Use AckMesssagesResponse_Result.Descriptor instead.

func (AckMesssagesResponse_Result) Number 

func (x AckMesssagesResponse_Result) Number() protoreflect.EnumNumber

func (AckMesssagesResponse_Result) String 

func (x AckMesssagesResponse_Result) String() string

func (AckMesssagesResponse_Result) Type 

func (AckMesssagesResponse_Result) Type() protoreflect.EnumType

type Message 

type Message struct {

	// MessageId is the Id of the message. This ID is generated by the
	// server, and will _always_ be set when receiving a message.
	//
	// Server generates the message to:
	//  1. Reserve the ability for any future ID changes
	//  2. Prevent clients attempting to collide message IDs.
	Id *MessageId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The signature sent from SendMessageRequest, which will be injected by server.
	// This enables clients to ensure no MITM attacks were performed to hijack contents
	// of the typed message. This is only applicable for messages not generated by server.
	SendMessageRequestSignature *v1.Signature `` /* 146-byte string literal not displayed */
	// Types that are assignable to Kind:
	//
	//	*Message_RequestToGrabBill
	//	*Message_RequestToGiveBill
	Kind isMessage_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetId 

func (x *Message) GetId() *MessageId

func (*Message) GetKind 

func (m *Message) GetKind() isMessage_Kind

func (*Message) GetRequestToGiveBill 

func (x *Message) GetRequestToGiveBill() *RequestToGiveBill

func (*Message) GetRequestToGrabBill 

func (x *Message) GetRequestToGrabBill() *RequestToGrabBill

func (*Message) GetSendMessageRequestSignature 

func (x *Message) GetSendMessageRequestSignature() *v1.Signature

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

func (*Message) Validate 

func (m *Message) Validate() error

Validate checks the field values on Message with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type MessageId 

type MessageId struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

MessageId identifies a message. It is only guaranteed to be unique when paired with a destination (i.e. the rendezvous public key).

func (*MessageId) Descriptor deprecated 

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

Deprecated: Use MessageId.ProtoReflect.Descriptor instead.

func (*MessageId) GetValue 

func (x *MessageId) GetValue() []byte

func (*MessageId) ProtoMessage 

func (*MessageId) ProtoMessage()

func (*MessageId) ProtoReflect 

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

func (*MessageId) Reset 

func (x *MessageId) Reset()

func (*MessageId) String 

func (x *MessageId) String() string

func (*MessageId) Validate 

func (m *MessageId) Validate() error

Validate checks the field values on MessageId with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type MessageIdValidationError 

type MessageIdValidationError struct {
	// contains filtered or unexported fields
}

MessageIdValidationError is the validation error returned by MessageId.Validate if the designated constraints aren't met.

func (MessageIdValidationError) Cause 

func (e MessageIdValidationError) Cause() error

Cause function returns cause value.

func (MessageIdValidationError) Error 

func (e MessageIdValidationError) Error() string

Error satisfies the builtin error interface

func (MessageIdValidationError) ErrorName 

func (e MessageIdValidationError) ErrorName() string

ErrorName returns error name.

func (MessageIdValidationError) Field 

func (e MessageIdValidationError) Field() string

Field function returns field value.

func (MessageIdValidationError) Key 

func (e MessageIdValidationError) Key() bool

Key function returns key value.

func (MessageIdValidationError) Reason 

func (e MessageIdValidationError) Reason() string

Reason function returns reason value.

type MessageValidationError 

type MessageValidationError struct {
	// contains filtered or unexported fields
}

MessageValidationError is the validation error returned by Message.Validate if the designated constraints aren't met.

func (MessageValidationError) Cause 

func (e MessageValidationError) Cause() error

Cause function returns cause value.

func (MessageValidationError) Error 

func (e MessageValidationError) Error() string

Error satisfies the builtin error interface

func (MessageValidationError) ErrorName 

func (e MessageValidationError) ErrorName() string

ErrorName returns error name.

func (MessageValidationError) Field 

func (e MessageValidationError) Field() string

Field function returns field value.

func (MessageValidationError) Key 

func (e MessageValidationError) Key() bool

Key function returns key value.

func (MessageValidationError) Reason 

func (e MessageValidationError) Reason() string

Reason function returns reason value.

type Message_RequestToGiveBill 

type Message_RequestToGiveBill struct {
	RequestToGiveBill *RequestToGiveBill `protobuf:"bytes,4,opt,name=request_to_give_bill,json=requestToGiveBill,proto3,oneof"`
}

type Message_RequestToGrabBill 

type Message_RequestToGrabBill struct {
	RequestToGrabBill *RequestToGrabBill `protobuf:"bytes,3,opt,name=request_to_grab_bill,json=requestToGrabBill,proto3,oneof"`
}

type MessagingClient 

type MessagingClient interface {
	// OpenMessageStream opens a stream of messages. Messages are routed using the
	// public key of a rendezvous keypair derived by both the sender and the
	// recipient of the messages. The sender may be a client or server.
	//
	// Messages are expected to be acked once they have been processed by the client.
	// Ack'd messages will no longer be delivered on future OpenMessageStream calls,
	// and are eligible for deletion from the service. Clients should, however, handle
	// duplicate delivery of messages.
	//
	// For giving/grabbing a bill, the expected flow is as follows:
	//  1. The payment sender creates a multi-mint cash scan code.
	//  2. The payment sender calls OpenMessageStream on the rendezvous public key.
	//  3. The payment sender uses SendMessage to send the mint in a RequestToGiveBill message.
	//  4. The payment sender shows the bill with the scan code containing the rendezvous public key.
	//  4. The payment recipient scans the code.
	//  5. The payment recipient uses PollMessages to get the RequestToGiveBill message from part 3.
	//  6. The payment recipient sends the destination address in a RequestToGrabBill message.
	//  7. The payment sender receives the RequestToGrabBill message in real time, submits the intent
	//     for the payment to the provided destination, and then closes the stream.
	OpenMessageStream(ctx context.Context, in *OpenMessageStreamRequest, opts ...grpc.CallOption) (Messaging_OpenMessageStreamClient, error)
	// OpenMessageStreamWithKeepAlive is like OpenMessageStream, but enables a ping/pong
	// keepalive to determine the health of the stream at both the client and server.
	//
	// The keepalive protocol is as follows:
	//  1. Client initiates a stream by sending an OpenMessageStreamRequest.
	//  2. Upon stream initialization, server begins the keepalive protocol.
	//  3. Server sends a ping to the client.
	//  4. Client responds with a pong as fast as possible, making note of
	//     the delay for when to expect the next ping.
	//  5. Steps 3 and 4 are repeated until the stream is explicitly terminated
	//     or is deemed to be unhealthy.
	//
	// Client notes:
	//   - Client should be careful to process messages async, so any responses to pings are
	//     not delayed.
	//   - Clients should implement a reasonable backoff strategy upon continued timeout failures.
	//   - Clients that abuse pong messages may have their streams terminated by server.
	//
	// At any point in the stream, server will respond with messages in real time as
	// they are observed. Messages sent over the stream should not affect the ping/pong
	// protocol timings. Individual protocols for payment flows remain the same, and are
	// documented in OpenMessageStream.
	//
	// Note: This API will enforce OpenMessageStreamRequest.signature is set as part of migration
	//
	//	to this newer protocol
	OpenMessageStreamWithKeepAlive(ctx context.Context, opts ...grpc.CallOption) (Messaging_OpenMessageStreamWithKeepAliveClient, error)
	// PollMessages is like OpenMessageStream, but uses a polling flow for receiving
	// messages. Updates are not real-time and depedent on the polling interval.
	// This RPC supports all message types.
	//
	// This is a temporary RPC until OpenMessageStream can be built out generically on
	// both client and server, while supporting things like multiple listeners.
	PollMessages(ctx context.Context, in *PollMessagesRequest, opts ...grpc.CallOption) (*PollMessagesResponse, error)
	// AckMessages acks one or more messages that have been successfully delivered to
	// the client.
	AckMessages(ctx context.Context, in *AckMessagesRequest, opts ...grpc.CallOption) (*AckMesssagesResponse, error)
	// SendMessage sends a message.
	SendMessage(ctx context.Context, in *SendMessageRequest, opts ...grpc.CallOption) (*SendMessageResponse, error)
}

MessagingClient is the client API for Messaging 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 NewMessagingClient 

func NewMessagingClient(cc grpc.ClientConnInterface) MessagingClient

type MessagingServer 

type MessagingServer interface {
	// OpenMessageStream opens a stream of messages. Messages are routed using the
	// public key of a rendezvous keypair derived by both the sender and the
	// recipient of the messages. The sender may be a client or server.
	//
	// Messages are expected to be acked once they have been processed by the client.
	// Ack'd messages will no longer be delivered on future OpenMessageStream calls,
	// and are eligible for deletion from the service. Clients should, however, handle
	// duplicate delivery of messages.
	//
	// For giving/grabbing a bill, the expected flow is as follows:
	//  1. The payment sender creates a multi-mint cash scan code.
	//  2. The payment sender calls OpenMessageStream on the rendezvous public key.
	//  3. The payment sender uses SendMessage to send the mint in a RequestToGiveBill message.
	//  4. The payment sender shows the bill with the scan code containing the rendezvous public key.
	//  4. The payment recipient scans the code.
	//  5. The payment recipient uses PollMessages to get the RequestToGiveBill message from part 3.
	//  6. The payment recipient sends the destination address in a RequestToGrabBill message.
	//  7. The payment sender receives the RequestToGrabBill message in real time, submits the intent
	//     for the payment to the provided destination, and then closes the stream.
	OpenMessageStream(*OpenMessageStreamRequest, Messaging_OpenMessageStreamServer) error
	// OpenMessageStreamWithKeepAlive is like OpenMessageStream, but enables a ping/pong
	// keepalive to determine the health of the stream at both the client and server.
	//
	// The keepalive protocol is as follows:
	//  1. Client initiates a stream by sending an OpenMessageStreamRequest.
	//  2. Upon stream initialization, server begins the keepalive protocol.
	//  3. Server sends a ping to the client.
	//  4. Client responds with a pong as fast as possible, making note of
	//     the delay for when to expect the next ping.
	//  5. Steps 3 and 4 are repeated until the stream is explicitly terminated
	//     or is deemed to be unhealthy.
	//
	// Client notes:
	//   - Client should be careful to process messages async, so any responses to pings are
	//     not delayed.
	//   - Clients should implement a reasonable backoff strategy upon continued timeout failures.
	//   - Clients that abuse pong messages may have their streams terminated by server.
	//
	// At any point in the stream, server will respond with messages in real time as
	// they are observed. Messages sent over the stream should not affect the ping/pong
	// protocol timings. Individual protocols for payment flows remain the same, and are
	// documented in OpenMessageStream.
	//
	// Note: This API will enforce OpenMessageStreamRequest.signature is set as part of migration
	//
	//	to this newer protocol
	OpenMessageStreamWithKeepAlive(Messaging_OpenMessageStreamWithKeepAliveServer) error
	// PollMessages is like OpenMessageStream, but uses a polling flow for receiving
	// messages. Updates are not real-time and depedent on the polling interval.
	// This RPC supports all message types.
	//
	// This is a temporary RPC until OpenMessageStream can be built out generically on
	// both client and server, while supporting things like multiple listeners.
	PollMessages(context.Context, *PollMessagesRequest) (*PollMessagesResponse, error)
	// AckMessages acks one or more messages that have been successfully delivered to
	// the client.
	AckMessages(context.Context, *AckMessagesRequest) (*AckMesssagesResponse, error)
	// SendMessage sends a message.
	SendMessage(context.Context, *SendMessageRequest) (*SendMessageResponse, error)
	// contains filtered or unexported methods
}

MessagingServer is the server API for Messaging service. All implementations must embed UnimplementedMessagingServer for forward compatibility

type Messaging_OpenMessageStreamClient 

type Messaging_OpenMessageStreamClient interface {
	Recv() (*OpenMessageStreamResponse, error)
	grpc.ClientStream
}

type Messaging_OpenMessageStreamServer 

type Messaging_OpenMessageStreamServer interface {
	Send(*OpenMessageStreamResponse) error
	grpc.ServerStream
}

type Messaging_OpenMessageStreamWithKeepAliveClient 

type Messaging_OpenMessageStreamWithKeepAliveClient interface {
	Send(*OpenMessageStreamWithKeepAliveRequest) error
	Recv() (*OpenMessageStreamWithKeepAliveResponse, error)
	grpc.ClientStream
}

type Messaging_OpenMessageStreamWithKeepAliveServer 

type Messaging_OpenMessageStreamWithKeepAliveServer interface {
	Send(*OpenMessageStreamWithKeepAliveResponse) error
	Recv() (*OpenMessageStreamWithKeepAliveRequest, error)
	grpc.ServerStream
}

type OpenMessageStreamRequest 

type OpenMessageStreamRequest struct {
	RendezvousKey *RendezvousKey `protobuf:"bytes,1,opt,name=rendezvous_key,json=rendezvousKey,proto3" json:"rendezvous_key,omitempty"`
	// The signature is of serialize(OpenMessageStreamRequest) using rendezvous_key.
	//
	// todo: Make required once clients migrate
	Signature *v1.Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*OpenMessageStreamRequest) Descriptor deprecated 

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

Deprecated: Use OpenMessageStreamRequest.ProtoReflect.Descriptor instead.

func (*OpenMessageStreamRequest) GetRendezvousKey 

func (x *OpenMessageStreamRequest) GetRendezvousKey() *RendezvousKey

func (*OpenMessageStreamRequest) GetSignature 

func (x *OpenMessageStreamRequest) GetSignature() *v1.Signature

func (*OpenMessageStreamRequest) ProtoMessage 

func (*OpenMessageStreamRequest) ProtoMessage()

func (*OpenMessageStreamRequest) ProtoReflect 

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

func (*OpenMessageStreamRequest) Reset 

func (x *OpenMessageStreamRequest) Reset()

func (*OpenMessageStreamRequest) String 

func (x *OpenMessageStreamRequest) String() string

func (*OpenMessageStreamRequest) Validate 

func (m *OpenMessageStreamRequest) Validate() error

Validate checks the field values on OpenMessageStreamRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type OpenMessageStreamRequestValidationError 

type OpenMessageStreamRequestValidationError struct {
	// contains filtered or unexported fields
}

OpenMessageStreamRequestValidationError is the validation error returned by OpenMessageStreamRequest.Validate if the designated constraints aren't met.

func (OpenMessageStreamRequestValidationError) Cause 

func (e OpenMessageStreamRequestValidationError) Cause() error

Cause function returns cause value.

func (OpenMessageStreamRequestValidationError) Error 

func (e OpenMessageStreamRequestValidationError) Error() string

Error satisfies the builtin error interface

func (OpenMessageStreamRequestValidationError) ErrorName 

func (e OpenMessageStreamRequestValidationError) ErrorName() string

ErrorName returns error name.

func (OpenMessageStreamRequestValidationError) Field 

func (e OpenMessageStreamRequestValidationError) Field() string

Field function returns field value.

func (OpenMessageStreamRequestValidationError) Key 

func (e OpenMessageStreamRequestValidationError) Key() bool

Key function returns key value.

func (OpenMessageStreamRequestValidationError) Reason 

func (e OpenMessageStreamRequestValidationError) Reason() string

Reason function returns reason value.

type OpenMessageStreamResponse 

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

func (*OpenMessageStreamResponse) Descriptor deprecated 

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

Deprecated: Use OpenMessageStreamResponse.ProtoReflect.Descriptor instead.

func (*OpenMessageStreamResponse) GetMessages 

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

func (*OpenMessageStreamResponse) ProtoMessage 

func (*OpenMessageStreamResponse) ProtoMessage()

func (*OpenMessageStreamResponse) ProtoReflect 

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

func (*OpenMessageStreamResponse) Reset 

func (x *OpenMessageStreamResponse) Reset()

func (*OpenMessageStreamResponse) String 

func (x *OpenMessageStreamResponse) String() string

func (*OpenMessageStreamResponse) Validate 

func (m *OpenMessageStreamResponse) Validate() error

Validate checks the field values on OpenMessageStreamResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type OpenMessageStreamResponseValidationError 

type OpenMessageStreamResponseValidationError struct {
	// contains filtered or unexported fields
}

OpenMessageStreamResponseValidationError is the validation error returned by OpenMessageStreamResponse.Validate if the designated constraints aren't met.

func (OpenMessageStreamResponseValidationError) Cause 

func (e OpenMessageStreamResponseValidationError) Cause() error

Cause function returns cause value.

func (OpenMessageStreamResponseValidationError) Error 

func (e OpenMessageStreamResponseValidationError) Error() string

Error satisfies the builtin error interface

func (OpenMessageStreamResponseValidationError) ErrorName 

func (e OpenMessageStreamResponseValidationError) ErrorName() string

ErrorName returns error name.

func (OpenMessageStreamResponseValidationError) Field 

func (e OpenMessageStreamResponseValidationError) Field() string

Field function returns field value.

func (OpenMessageStreamResponseValidationError) Key 

func (e OpenMessageStreamResponseValidationError) Key() bool

Key function returns key value.

func (OpenMessageStreamResponseValidationError) Reason 

func (e OpenMessageStreamResponseValidationError) Reason() string

Reason function returns reason value.

type OpenMessageStreamWithKeepAliveRequest 

type OpenMessageStreamWithKeepAliveRequest struct {

	// Types that are assignable to RequestOrPong:
	//
	//	*OpenMessageStreamWithKeepAliveRequest_Request
	//	*OpenMessageStreamWithKeepAliveRequest_Pong
	RequestOrPong isOpenMessageStreamWithKeepAliveRequest_RequestOrPong `protobuf_oneof:"request_or_pong"`
	// contains filtered or unexported fields
}

func (*OpenMessageStreamWithKeepAliveRequest) Descriptor deprecated 

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

Deprecated: Use OpenMessageStreamWithKeepAliveRequest.ProtoReflect.Descriptor instead.

func (*OpenMessageStreamWithKeepAliveRequest) GetPong 

func (x *OpenMessageStreamWithKeepAliveRequest) GetPong() *v1.ClientPong

func (*OpenMessageStreamWithKeepAliveRequest) GetRequest 

func (x *OpenMessageStreamWithKeepAliveRequest) GetRequest() *OpenMessageStreamRequest

func (*OpenMessageStreamWithKeepAliveRequest) GetRequestOrPong 

func (m *OpenMessageStreamWithKeepAliveRequest) GetRequestOrPong() isOpenMessageStreamWithKeepAliveRequest_RequestOrPong

func (*OpenMessageStreamWithKeepAliveRequest) ProtoMessage 

func (*OpenMessageStreamWithKeepAliveRequest) ProtoMessage()

func (*OpenMessageStreamWithKeepAliveRequest) ProtoReflect 

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

func (*OpenMessageStreamWithKeepAliveRequest) Reset 

func (x *OpenMessageStreamWithKeepAliveRequest) Reset()

func (*OpenMessageStreamWithKeepAliveRequest) String 

func (x *OpenMessageStreamWithKeepAliveRequest) String() string

func (*OpenMessageStreamWithKeepAliveRequest) Validate 

func (m *OpenMessageStreamWithKeepAliveRequest) Validate() error

Validate checks the field values on OpenMessageStreamWithKeepAliveRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type OpenMessageStreamWithKeepAliveRequestValidationError 

type OpenMessageStreamWithKeepAliveRequestValidationError struct {
	// contains filtered or unexported fields
}

OpenMessageStreamWithKeepAliveRequestValidationError is the validation error returned by OpenMessageStreamWithKeepAliveRequest.Validate if the designated constraints aren't met.

func (OpenMessageStreamWithKeepAliveRequestValidationError) Cause 

func (e OpenMessageStreamWithKeepAliveRequestValidationError) Cause() error

Cause function returns cause value.

func (OpenMessageStreamWithKeepAliveRequestValidationError) Error 

func (e OpenMessageStreamWithKeepAliveRequestValidationError) Error() string

Error satisfies the builtin error interface

func (OpenMessageStreamWithKeepAliveRequestValidationError) ErrorName 

func (e OpenMessageStreamWithKeepAliveRequestValidationError) ErrorName() string

ErrorName returns error name.

func (OpenMessageStreamWithKeepAliveRequestValidationError) Field 

func (e OpenMessageStreamWithKeepAliveRequestValidationError) Field() string

Field function returns field value.

func (OpenMessageStreamWithKeepAliveRequestValidationError) Key 

func (e OpenMessageStreamWithKeepAliveRequestValidationError) Key() bool

Key function returns key value.

func (OpenMessageStreamWithKeepAliveRequestValidationError) Reason 

func (e OpenMessageStreamWithKeepAliveRequestValidationError) Reason() string

Reason function returns reason value.

type OpenMessageStreamWithKeepAliveRequest_Pong 

type OpenMessageStreamWithKeepAliveRequest_Pong struct {
	Pong *v1.ClientPong `protobuf:"bytes,2,opt,name=pong,proto3,oneof"`
}

type OpenMessageStreamWithKeepAliveRequest_Request 

type OpenMessageStreamWithKeepAliveRequest_Request struct {
	Request *OpenMessageStreamRequest `protobuf:"bytes,1,opt,name=request,proto3,oneof"`
}

type OpenMessageStreamWithKeepAliveResponse 

type OpenMessageStreamWithKeepAliveResponse struct {

	// Types that are assignable to ResponseOrPing:
	//
	//	*OpenMessageStreamWithKeepAliveResponse_Response
	//	*OpenMessageStreamWithKeepAliveResponse_Ping
	ResponseOrPing isOpenMessageStreamWithKeepAliveResponse_ResponseOrPing `protobuf_oneof:"response_or_ping"`
	// contains filtered or unexported fields
}

func (*OpenMessageStreamWithKeepAliveResponse) Descriptor deprecated 

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

Deprecated: Use OpenMessageStreamWithKeepAliveResponse.ProtoReflect.Descriptor instead.

func (*OpenMessageStreamWithKeepAliveResponse) GetPing 

func (x *OpenMessageStreamWithKeepAliveResponse) GetPing() *v1.ServerPing

func (*OpenMessageStreamWithKeepAliveResponse) GetResponse 

func (x *OpenMessageStreamWithKeepAliveResponse) GetResponse() *OpenMessageStreamResponse

func (*OpenMessageStreamWithKeepAliveResponse) GetResponseOrPing 

func (m *OpenMessageStreamWithKeepAliveResponse) GetResponseOrPing() isOpenMessageStreamWithKeepAliveResponse_ResponseOrPing

func (*OpenMessageStreamWithKeepAliveResponse) ProtoMessage 

func (*OpenMessageStreamWithKeepAliveResponse) ProtoMessage()

func (*OpenMessageStreamWithKeepAliveResponse) ProtoReflect 

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

func (*OpenMessageStreamWithKeepAliveResponse) Reset 

func (x *OpenMessageStreamWithKeepAliveResponse) Reset()

func (*OpenMessageStreamWithKeepAliveResponse) String 

func (x *OpenMessageStreamWithKeepAliveResponse) String() string

func (*OpenMessageStreamWithKeepAliveResponse) Validate 

func (m *OpenMessageStreamWithKeepAliveResponse) Validate() error

Validate checks the field values on OpenMessageStreamWithKeepAliveResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type OpenMessageStreamWithKeepAliveResponseValidationError 

type OpenMessageStreamWithKeepAliveResponseValidationError struct {
	// contains filtered or unexported fields
}

OpenMessageStreamWithKeepAliveResponseValidationError is the validation error returned by OpenMessageStreamWithKeepAliveResponse.Validate if the designated constraints aren't met.

func (OpenMessageStreamWithKeepAliveResponseValidationError) Cause 

func (e OpenMessageStreamWithKeepAliveResponseValidationError) Cause() error

Cause function returns cause value.

func (OpenMessageStreamWithKeepAliveResponseValidationError) Error 

func (e OpenMessageStreamWithKeepAliveResponseValidationError) Error() string

Error satisfies the builtin error interface

func (OpenMessageStreamWithKeepAliveResponseValidationError) ErrorName 

func (e OpenMessageStreamWithKeepAliveResponseValidationError) ErrorName() string

ErrorName returns error name.

func (OpenMessageStreamWithKeepAliveResponseValidationError) Field 

func (e OpenMessageStreamWithKeepAliveResponseValidationError) Field() string

Field function returns field value.

func (OpenMessageStreamWithKeepAliveResponseValidationError) Key 

func (e OpenMessageStreamWithKeepAliveResponseValidationError) Key() bool

Key function returns key value.

func (OpenMessageStreamWithKeepAliveResponseValidationError) Reason 

func (e OpenMessageStreamWithKeepAliveResponseValidationError) Reason() string

Reason function returns reason value.

type OpenMessageStreamWithKeepAliveResponse_Ping 

type OpenMessageStreamWithKeepAliveResponse_Ping struct {
	Ping *v1.ServerPing `protobuf:"bytes,2,opt,name=ping,proto3,oneof"`
}

type OpenMessageStreamWithKeepAliveResponse_Response 

type OpenMessageStreamWithKeepAliveResponse_Response struct {
	Response *OpenMessageStreamResponse `protobuf:"bytes,1,opt,name=response,proto3,oneof"`
}

type PollMessagesRequest 

type PollMessagesRequest struct {
	RendezvousKey *RendezvousKey `protobuf:"bytes,1,opt,name=rendezvous_key,json=rendezvousKey,proto3" json:"rendezvous_key,omitempty"`
	// The signature is of serialize(PollMessagesRequest) using rendezvous_key.
	Signature *v1.Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*PollMessagesRequest) Descriptor deprecated 

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

Deprecated: Use PollMessagesRequest.ProtoReflect.Descriptor instead.

func (*PollMessagesRequest) GetRendezvousKey 

func (x *PollMessagesRequest) GetRendezvousKey() *RendezvousKey

func (*PollMessagesRequest) GetSignature 

func (x *PollMessagesRequest) GetSignature() *v1.Signature

func (*PollMessagesRequest) ProtoMessage 

func (*PollMessagesRequest) ProtoMessage()

func (*PollMessagesRequest) ProtoReflect 

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

func (*PollMessagesRequest) Reset 

func (x *PollMessagesRequest) Reset()

func (*PollMessagesRequest) String 

func (x *PollMessagesRequest) String() string

func (*PollMessagesRequest) Validate 

func (m *PollMessagesRequest) Validate() error

Validate checks the field values on PollMessagesRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type PollMessagesRequestValidationError 

type PollMessagesRequestValidationError struct {
	// contains filtered or unexported fields
}

PollMessagesRequestValidationError is the validation error returned by PollMessagesRequest.Validate if the designated constraints aren't met.

func (PollMessagesRequestValidationError) Cause 

func (e PollMessagesRequestValidationError) Cause() error

Cause function returns cause value.

func (PollMessagesRequestValidationError) Error 

func (e PollMessagesRequestValidationError) Error() string

Error satisfies the builtin error interface

func (PollMessagesRequestValidationError) ErrorName 

func (e PollMessagesRequestValidationError) ErrorName() string

ErrorName returns error name.

func (PollMessagesRequestValidationError) Field 

func (e PollMessagesRequestValidationError) Field() string

Field function returns field value.

func (PollMessagesRequestValidationError) Key 

func (e PollMessagesRequestValidationError) Key() bool

Key function returns key value.

func (PollMessagesRequestValidationError) Reason 

func (e PollMessagesRequestValidationError) Reason() string

Reason function returns reason value.

type PollMessagesResponse 

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

func (*PollMessagesResponse) Descriptor deprecated 

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

Deprecated: Use PollMessagesResponse.ProtoReflect.Descriptor instead.

func (*PollMessagesResponse) GetMessages 

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

func (*PollMessagesResponse) ProtoMessage 

func (*PollMessagesResponse) ProtoMessage()

func (*PollMessagesResponse) ProtoReflect 

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

func (*PollMessagesResponse) Reset 

func (x *PollMessagesResponse) Reset()

func (*PollMessagesResponse) String 

func (x *PollMessagesResponse) String() string

func (*PollMessagesResponse) Validate 

func (m *PollMessagesResponse) Validate() error

Validate checks the field values on PollMessagesResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type PollMessagesResponseValidationError 

type PollMessagesResponseValidationError struct {
	// contains filtered or unexported fields
}

PollMessagesResponseValidationError is the validation error returned by PollMessagesResponse.Validate if the designated constraints aren't met.

func (PollMessagesResponseValidationError) Cause 

func (e PollMessagesResponseValidationError) Cause() error

Cause function returns cause value.

func (PollMessagesResponseValidationError) Error 

func (e PollMessagesResponseValidationError) Error() string

Error satisfies the builtin error interface

func (PollMessagesResponseValidationError) ErrorName 

func (e PollMessagesResponseValidationError) ErrorName() string

ErrorName returns error name.

func (PollMessagesResponseValidationError) Field 

func (e PollMessagesResponseValidationError) Field() string

Field function returns field value.

func (PollMessagesResponseValidationError) Key 

func (e PollMessagesResponseValidationError) Key() bool

Key function returns key value.

func (PollMessagesResponseValidationError) Reason 

func (e PollMessagesResponseValidationError) Reason() string

Reason function returns reason value.

type RendezvousKey 

type RendezvousKey struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

RendezvousKey is a unique key pair, typically derived from a scan code payload, which is used to establish a secure communication channel anonymously to coordinate a flow using messages.

func (*RendezvousKey) Descriptor deprecated 

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

Deprecated: Use RendezvousKey.ProtoReflect.Descriptor instead.

func (*RendezvousKey) GetValue 

func (x *RendezvousKey) GetValue() []byte

func (*RendezvousKey) ProtoMessage 

func (*RendezvousKey) ProtoMessage()

func (*RendezvousKey) ProtoReflect 

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

func (*RendezvousKey) Reset 

func (x *RendezvousKey) Reset()

func (*RendezvousKey) String 

func (x *RendezvousKey) String() string

func (*RendezvousKey) Validate 

func (m *RendezvousKey) Validate() error

Validate checks the field values on RendezvousKey with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type RendezvousKeyValidationError 

type RendezvousKeyValidationError struct {
	// contains filtered or unexported fields
}

RendezvousKeyValidationError is the validation error returned by RendezvousKey.Validate if the designated constraints aren't met.

func (RendezvousKeyValidationError) Cause 

func (e RendezvousKeyValidationError) Cause() error

Cause function returns cause value.

func (RendezvousKeyValidationError) Error 

func (e RendezvousKeyValidationError) Error() string

Error satisfies the builtin error interface

func (RendezvousKeyValidationError) ErrorName 

func (e RendezvousKeyValidationError) ErrorName() string

ErrorName returns error name.

func (RendezvousKeyValidationError) Field 

func (e RendezvousKeyValidationError) Field() string

Field function returns field value.

func (RendezvousKeyValidationError) Key 

func (e RendezvousKeyValidationError) Key() bool

Key function returns key value.

func (RendezvousKeyValidationError) Reason 

func (e RendezvousKeyValidationError) Reason() string

Reason function returns reason value.

type RequestToGiveBill 

type RequestToGiveBill struct {

	// The mint that the bill will be received in
	Mint *v1.SolanaAccountId `protobuf:"bytes,1,opt,name=mint,proto3" json:"mint,omitempty"`
	// The validated exchange data that was used to compute the fiat value of the give
	// to support subsequent gives. Clients should be aware of timeouts and dismiss a
	// bill if the threshold is met.
	ExchangeData *v11.VerifiedExchangeData `protobuf:"bytes,2,opt,name=exchange_data,json=exchangeData,proto3" json:"exchange_data,omitempty"`
	// contains filtered or unexported fields
}

Request that a bill be given in the desired mint

This message type is only initiated by clients.

func (*RequestToGiveBill) Descriptor deprecated 

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

Deprecated: Use RequestToGiveBill.ProtoReflect.Descriptor instead.

func (*RequestToGiveBill) GetExchangeData added in v0.15.0 

func (x *RequestToGiveBill) GetExchangeData() *v11.VerifiedExchangeData

func (*RequestToGiveBill) GetMint 

func (x *RequestToGiveBill) GetMint() *v1.SolanaAccountId

func (*RequestToGiveBill) ProtoMessage 

func (*RequestToGiveBill) ProtoMessage()

func (*RequestToGiveBill) ProtoReflect 

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

func (*RequestToGiveBill) Reset 

func (x *RequestToGiveBill) Reset()

func (*RequestToGiveBill) String 

func (x *RequestToGiveBill) String() string

func (*RequestToGiveBill) Validate 

func (m *RequestToGiveBill) Validate() error

Validate checks the field values on RequestToGiveBill with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type RequestToGiveBillValidationError 

type RequestToGiveBillValidationError struct {
	// contains filtered or unexported fields
}

RequestToGiveBillValidationError is the validation error returned by RequestToGiveBill.Validate if the designated constraints aren't met.

func (RequestToGiveBillValidationError) Cause 

func (e RequestToGiveBillValidationError) Cause() error

Cause function returns cause value.

func (RequestToGiveBillValidationError) Error 

func (e RequestToGiveBillValidationError) Error() string

Error satisfies the builtin error interface

func (RequestToGiveBillValidationError) ErrorName 

func (e RequestToGiveBillValidationError) ErrorName() string

ErrorName returns error name.

func (RequestToGiveBillValidationError) Field 

func (e RequestToGiveBillValidationError) Field() string

Field function returns field value.

func (RequestToGiveBillValidationError) Key 

func (e RequestToGiveBillValidationError) Key() bool

Key function returns key value.

func (RequestToGiveBillValidationError) Reason 

func (e RequestToGiveBillValidationError) Reason() string

Reason function returns reason value.

type RequestToGrabBill 

type RequestToGrabBill struct {

	// Requestor is the virtual token account on the VM to which a payment
	// should be sent.
	RequestorAccount *v1.SolanaAccountId `protobuf:"bytes,1,opt,name=requestor_account,json=requestorAccount,proto3" json:"requestor_account,omitempty"`
	// contains filtered or unexported fields
}

Request that a pulled out bill be sent to the requested address.

This message type is only initiated by clients.

func (*RequestToGrabBill) Descriptor deprecated 

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

Deprecated: Use RequestToGrabBill.ProtoReflect.Descriptor instead.

func (*RequestToGrabBill) GetRequestorAccount 

func (x *RequestToGrabBill) GetRequestorAccount() *v1.SolanaAccountId

func (*RequestToGrabBill) ProtoMessage 

func (*RequestToGrabBill) ProtoMessage()

func (*RequestToGrabBill) ProtoReflect 

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

func (*RequestToGrabBill) Reset 

func (x *RequestToGrabBill) Reset()

func (*RequestToGrabBill) String 

func (x *RequestToGrabBill) String() string

func (*RequestToGrabBill) Validate 

func (m *RequestToGrabBill) Validate() error

Validate checks the field values on RequestToGrabBill with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type RequestToGrabBillValidationError 

type RequestToGrabBillValidationError struct {
	// contains filtered or unexported fields
}

RequestToGrabBillValidationError is the validation error returned by RequestToGrabBill.Validate if the designated constraints aren't met.

func (RequestToGrabBillValidationError) Cause 

func (e RequestToGrabBillValidationError) Cause() error

Cause function returns cause value.

func (RequestToGrabBillValidationError) Error 

func (e RequestToGrabBillValidationError) Error() string

Error satisfies the builtin error interface

func (RequestToGrabBillValidationError) ErrorName 

func (e RequestToGrabBillValidationError) ErrorName() string

ErrorName returns error name.

func (RequestToGrabBillValidationError) Field 

func (e RequestToGrabBillValidationError) Field() string

Field function returns field value.

func (RequestToGrabBillValidationError) Key 

func (e RequestToGrabBillValidationError) Key() bool

Key function returns key value.

func (RequestToGrabBillValidationError) Reason 

func (e RequestToGrabBillValidationError) Reason() string

Reason function returns reason value.

type SendMessageRequest 

type SendMessageRequest struct {

	// The message to send. Types of messages clients can send are restricted.
	Message *Message `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// The rendezvous key that the message should be routed to.
	RendezvousKey *RendezvousKey `protobuf:"bytes,2,opt,name=rendezvous_key,json=rendezvousKey,proto3" json:"rendezvous_key,omitempty"`
	// The signature is of serialize(Message) using the PrivateKey of the keypair.
	Signature *v1.Signature `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*SendMessageRequest) Descriptor deprecated 

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

Deprecated: Use SendMessageRequest.ProtoReflect.Descriptor instead.

func (*SendMessageRequest) GetMessage 

func (x *SendMessageRequest) GetMessage() *Message

func (*SendMessageRequest) GetRendezvousKey 

func (x *SendMessageRequest) GetRendezvousKey() *RendezvousKey

func (*SendMessageRequest) GetSignature 

func (x *SendMessageRequest) GetSignature() *v1.Signature

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

func (*SendMessageRequest) Validate 

func (m *SendMessageRequest) Validate() error

Validate checks the field values on SendMessageRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type SendMessageRequestValidationError 

type SendMessageRequestValidationError struct {
	// contains filtered or unexported fields
}

SendMessageRequestValidationError is the validation error returned by SendMessageRequest.Validate if the designated constraints aren't met.

func (SendMessageRequestValidationError) Cause 

func (e SendMessageRequestValidationError) Cause() error

Cause function returns cause value.

func (SendMessageRequestValidationError) Error 

func (e SendMessageRequestValidationError) Error() string

Error satisfies the builtin error interface

func (SendMessageRequestValidationError) ErrorName 

func (e SendMessageRequestValidationError) ErrorName() string

ErrorName returns error name.

func (SendMessageRequestValidationError) Field 

func (e SendMessageRequestValidationError) Field() string

Field function returns field value.

func (SendMessageRequestValidationError) Key 

func (e SendMessageRequestValidationError) Key() bool

Key function returns key value.

func (SendMessageRequestValidationError) Reason 

func (e SendMessageRequestValidationError) Reason() string

Reason function returns reason value.

type SendMessageResponse 

type SendMessageResponse struct {
	Result SendMessageResponse_Result `protobuf:"varint,1,opt,name=result,proto3,enum=ocp.messaging.v1.SendMessageResponse_Result" json:"result,omitempty"`
	// Set if result == OK.
	MessageId *MessageId `protobuf:"bytes,2,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SendMessageResponse) Descriptor deprecated 

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

Deprecated: Use SendMessageResponse.ProtoReflect.Descriptor instead.

func (*SendMessageResponse) GetMessageId 

func (x *SendMessageResponse) GetMessageId() *MessageId

func (*SendMessageResponse) GetResult 

func (x *SendMessageResponse) GetResult() SendMessageResponse_Result

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

func (*SendMessageResponse) Validate 

func (m *SendMessageResponse) Validate() error

Validate checks the field values on SendMessageResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type SendMessageResponseValidationError 

type SendMessageResponseValidationError struct {
	// contains filtered or unexported fields
}

SendMessageResponseValidationError is the validation error returned by SendMessageResponse.Validate if the designated constraints aren't met.

func (SendMessageResponseValidationError) Cause 

func (e SendMessageResponseValidationError) Cause() error

Cause function returns cause value.

func (SendMessageResponseValidationError) Error 

func (e SendMessageResponseValidationError) Error() string

Error satisfies the builtin error interface

func (SendMessageResponseValidationError) ErrorName 

func (e SendMessageResponseValidationError) ErrorName() string

ErrorName returns error name.

func (SendMessageResponseValidationError) Field 

func (e SendMessageResponseValidationError) Field() string

Field function returns field value.

func (SendMessageResponseValidationError) Key 

func (e SendMessageResponseValidationError) Key() bool

Key function returns key value.

func (SendMessageResponseValidationError) Reason 

func (e SendMessageResponseValidationError) Reason() string

Reason function returns reason value.

type SendMessageResponse_Result 

type SendMessageResponse_Result int32
const (
	SendMessageResponse_OK               SendMessageResponse_Result = 0
	SendMessageResponse_NO_ACTIVE_STREAM SendMessageResponse_Result = 1
)

func (SendMessageResponse_Result) Descriptor 

func (SendMessageResponse_Result) Descriptor() protoreflect.EnumDescriptor

func (SendMessageResponse_Result) Enum 

func (x SendMessageResponse_Result) Enum() *SendMessageResponse_Result

func (SendMessageResponse_Result) EnumDescriptor deprecated 

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

Deprecated: Use SendMessageResponse_Result.Descriptor instead.

func (SendMessageResponse_Result) Number 

func (x SendMessageResponse_Result) Number() protoreflect.EnumNumber

func (SendMessageResponse_Result) String 

func (x SendMessageResponse_Result) String() string

func (SendMessageResponse_Result) Type 

func (SendMessageResponse_Result) Type() protoreflect.EnumType

type UnimplementedMessagingServer 

type UnimplementedMessagingServer struct {
}

UnimplementedMessagingServer must be embedded to have forward compatible implementations.

func (UnimplementedMessagingServer) AckMessages 

func (UnimplementedMessagingServer) AckMessages(context.Context, *AckMessagesRequest) (*AckMesssagesResponse, error)

func (UnimplementedMessagingServer) OpenMessageStream 

func (UnimplementedMessagingServer) OpenMessageStream(*OpenMessageStreamRequest, Messaging_OpenMessageStreamServer) error

func (UnimplementedMessagingServer) OpenMessageStreamWithKeepAlive 

func (UnimplementedMessagingServer) OpenMessageStreamWithKeepAlive(Messaging_OpenMessageStreamWithKeepAliveServer) error

func (UnimplementedMessagingServer) PollMessages 

func (UnimplementedMessagingServer) PollMessages(context.Context, *PollMessagesRequest) (*PollMessagesResponse, error)

func (UnimplementedMessagingServer) SendMessage 

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

type UnsafeMessagingServer 

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

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

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.