command_queue

package
v0.0.4 Latest Latest
Warning

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

 Go to latest Published: Nov 19, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CommandQueueService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "heatpump.command_queue.CommandQueueService",
	HandlerType: (*CommandQueueServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListTopics",
			Handler:    _CommandQueueService_ListTopics_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Listen",
			Handler:       _CommandQueueService_Listen_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "command_queue.proto",
}

CommandQueueService_ServiceDesc is the grpc.ServiceDesc for CommandQueueService 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_command_queue_proto protoreflect.FileDescriptor

Functions

func RegisterCommandQueueServiceServer 

func RegisterCommandQueueServiceServer(s grpc.ServiceRegistrar, srv CommandQueueServiceServer)

Types

type CommandQueueServiceClient 

type CommandQueueServiceClient interface {
	// Listens for events
	Listen(ctx context.Context, opts ...grpc.CallOption) (CommandQueueService_ListenClient, error)
	// Lists the topics the client is eligible to subscribe to.
	ListTopics(ctx context.Context, in *ListTopicsRequest, opts ...grpc.CallOption) (*ListTopicsResponse, error)
}

CommandQueueServiceClient is the client API for CommandQueueService 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 NewCommandQueueServiceClient 

func NewCommandQueueServiceClient(cc grpc.ClientConnInterface) CommandQueueServiceClient

type CommandQueueServiceServer 

type CommandQueueServiceServer interface {
	// Listens for events
	Listen(CommandQueueService_ListenServer) error
	// Lists the topics the client is eligible to subscribe to.
	ListTopics(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error)
	// contains filtered or unexported methods
}

CommandQueueServiceServer is the server API for CommandQueueService service. All implementations must embed UnimplementedCommandQueueServiceServer for forward compatibility

type CommandQueueService_ListenClient 

type CommandQueueService_ListenClient interface {
	Send(*ListenRequest) error
	Recv() (*ListenResponse, error)
	grpc.ClientStream
}

type CommandQueueService_ListenServer 

type CommandQueueService_ListenServer interface {
	Send(*ListenResponse) error
	Recv() (*ListenRequest, error)
	grpc.ServerStream
}

type ListTopicsRequest 

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

func (*ListTopicsRequest) Descriptor deprecated 

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

Deprecated: Use ListTopicsRequest.ProtoReflect.Descriptor instead.

func (*ListTopicsRequest) ProtoMessage 

func (*ListTopicsRequest) ProtoMessage()

func (*ListTopicsRequest) ProtoReflect 

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

func (*ListTopicsRequest) Reset 

func (x *ListTopicsRequest) Reset()

func (*ListTopicsRequest) String 

func (x *ListTopicsRequest) String() string

type ListTopicsResponse 

type ListTopicsResponse struct {

	// The names of the topics the client is allowed to stream.
	Topics []string `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTopicsResponse) Descriptor deprecated 

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

Deprecated: Use ListTopicsResponse.ProtoReflect.Descriptor instead.

func (*ListTopicsResponse) GetTopics 

func (x *ListTopicsResponse) GetTopics() []string

func (*ListTopicsResponse) ProtoMessage 

func (*ListTopicsResponse) ProtoMessage()

func (*ListTopicsResponse) ProtoReflect 

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

func (*ListTopicsResponse) Reset 

func (x *ListTopicsResponse) Reset()

func (*ListTopicsResponse) String 

func (x *ListTopicsResponse) String() string

type ListenRequest 

type ListenRequest struct {

	// Uniquely identifies the request within this stream.
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Types that are assignable to Request:
	//	*ListenRequest_SubscribeRequest_
	//	*ListenRequest_AckRequest_
	Request isListenRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

func (*ListenRequest) Descriptor deprecated 

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

Deprecated: Use ListenRequest.ProtoReflect.Descriptor instead.

func (*ListenRequest) GetAckRequest 

func (x *ListenRequest) GetAckRequest() *ListenRequest_AckRequest

func (*ListenRequest) GetRequest 

func (m *ListenRequest) GetRequest() isListenRequest_Request

func (*ListenRequest) GetRequestId 

func (x *ListenRequest) GetRequestId() string

func (*ListenRequest) GetSubscribeRequest 

func (x *ListenRequest) GetSubscribeRequest() *ListenRequest_SubscribeRequest

func (*ListenRequest) ProtoMessage 

func (*ListenRequest) ProtoMessage()

func (*ListenRequest) ProtoReflect 

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

func (*ListenRequest) Reset 

func (x *ListenRequest) Reset()

func (*ListenRequest) String 

func (x *ListenRequest) String() string

type ListenRequest_AckRequest 

type ListenRequest_AckRequest struct {

	// ID of the MessageResponse to ack.
	MessageId string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// If true, nacks the message rather than acks it.
	Nack bool `protobuf:"varint,2,opt,name=nack,proto3" json:"nack,omitempty"`
	// contains filtered or unexported fields
}

Acknowledgement of a message.

func (*ListenRequest_AckRequest) Descriptor deprecated 

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

Deprecated: Use ListenRequest_AckRequest.ProtoReflect.Descriptor instead.

func (*ListenRequest_AckRequest) GetMessageId 

func (x *ListenRequest_AckRequest) GetMessageId() string

func (*ListenRequest_AckRequest) GetNack 

func (x *ListenRequest_AckRequest) GetNack() bool

func (*ListenRequest_AckRequest) ProtoMessage 

func (*ListenRequest_AckRequest) ProtoMessage()

func (*ListenRequest_AckRequest) ProtoReflect 

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

func (*ListenRequest_AckRequest) Reset 

func (x *ListenRequest_AckRequest) Reset()

func (*ListenRequest_AckRequest) String 

func (x *ListenRequest_AckRequest) String() string

type ListenRequest_AckRequest_ 

type ListenRequest_AckRequest_ struct {
	AckRequest *ListenRequest_AckRequest `protobuf:"bytes,3,opt,name=ack_request,json=ackRequest,proto3,oneof"`
}

type ListenRequest_SubscribeRequest 

type ListenRequest_SubscribeRequest struct {

	// Names of topics the client wishes to subscribe to.
	Topics []string `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

func (*ListenRequest_SubscribeRequest) Descriptor deprecated 

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

Deprecated: Use ListenRequest_SubscribeRequest.ProtoReflect.Descriptor instead.

func (*ListenRequest_SubscribeRequest) GetTopics 

func (x *ListenRequest_SubscribeRequest) GetTopics() []string

func (*ListenRequest_SubscribeRequest) ProtoMessage 

func (*ListenRequest_SubscribeRequest) ProtoMessage()

func (*ListenRequest_SubscribeRequest) ProtoReflect 

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

func (*ListenRequest_SubscribeRequest) Reset 

func (x *ListenRequest_SubscribeRequest) Reset()

func (*ListenRequest_SubscribeRequest) String 

func (x *ListenRequest_SubscribeRequest) String() string

type ListenRequest_SubscribeRequest_ 

type ListenRequest_SubscribeRequest_ struct {
	SubscribeRequest *ListenRequest_SubscribeRequest `protobuf:"bytes,2,opt,name=subscribe_request,json=subscribeRequest,proto3,oneof"`
}

type ListenResponse 

type ListenResponse struct {

	// Identifies the request_id associated with the response.
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Types that are assignable to Response:
	//	*ListenResponse_MessageResponse
	//	*ListenResponse_AckResponse_
	Response isListenResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*ListenResponse) Descriptor deprecated 

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

Deprecated: Use ListenResponse.ProtoReflect.Descriptor instead.

func (*ListenResponse) GetAckResponse 

func (x *ListenResponse) GetAckResponse() *ListenResponse_AckResponse

func (*ListenResponse) GetMessageResponse 

func (x *ListenResponse) GetMessageResponse() *MessageResponse

func (*ListenResponse) GetRequestId 

func (x *ListenResponse) GetRequestId() string

func (*ListenResponse) GetResponse 

func (m *ListenResponse) GetResponse() isListenResponse_Response

func (*ListenResponse) ProtoMessage 

func (*ListenResponse) ProtoMessage()

func (*ListenResponse) ProtoReflect 

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

func (*ListenResponse) Reset 

func (x *ListenResponse) Reset()

func (*ListenResponse) String 

func (x *ListenResponse) String() string

type ListenResponse_AckResponse 

type ListenResponse_AckResponse struct {

	// Unique id of the the message that was acked.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

Confirmation that an AckRequest was processed.

func (*ListenResponse_AckResponse) Descriptor deprecated 

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

Deprecated: Use ListenResponse_AckResponse.ProtoReflect.Descriptor instead.

func (*ListenResponse_AckResponse) GetId 

func (x *ListenResponse_AckResponse) GetId() string

func (*ListenResponse_AckResponse) ProtoMessage 

func (*ListenResponse_AckResponse) ProtoMessage()

func (*ListenResponse_AckResponse) ProtoReflect 

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

func (*ListenResponse_AckResponse) Reset 

func (x *ListenResponse_AckResponse) Reset()

func (*ListenResponse_AckResponse) String 

func (x *ListenResponse_AckResponse) String() string

type ListenResponse_AckResponse_ 

type ListenResponse_AckResponse_ struct {
	AckResponse *ListenResponse_AckResponse `protobuf:"bytes,3,opt,name=ack_response,json=ackResponse,proto3,oneof"`
}

type ListenResponse_MessageResponse 

type ListenResponse_MessageResponse struct {
	// A topic message.
	MessageResponse *MessageResponse `protobuf:"bytes,2,opt,name=message_response,json=messageResponse,proto3,oneof"`
}

type MessageResponse 

type MessageResponse struct {

	// Unique id of the the message.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Contents of the message.
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

MessageResponse contains a single message on the topic.

func (*MessageResponse) Descriptor deprecated 

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

Deprecated: Use MessageResponse.ProtoReflect.Descriptor instead.

func (*MessageResponse) GetId 

func (x *MessageResponse) GetId() string

func (*MessageResponse) GetPayload 

func (x *MessageResponse) GetPayload() []byte

func (*MessageResponse) ProtoMessage 

func (*MessageResponse) ProtoMessage()

func (*MessageResponse) ProtoReflect 

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

func (*MessageResponse) Reset 

func (x *MessageResponse) Reset()

func (*MessageResponse) String 

func (x *MessageResponse) String() string

type UnimplementedCommandQueueServiceServer 

type UnimplementedCommandQueueServiceServer struct {
}

UnimplementedCommandQueueServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCommandQueueServiceServer) ListTopics 

func (UnimplementedCommandQueueServiceServer) ListTopics(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error)

func (UnimplementedCommandQueueServiceServer) Listen 

func (UnimplementedCommandQueueServiceServer) Listen(CommandQueueService_ListenServer) error

type UnsafeCommandQueueServiceServer 

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

UnsafeCommandQueueServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CommandQueueServiceServer 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.