gateway

Documentation

Index

• type LocalQueueIdStreamClient
  • func (l *LocalQueueIdStreamClient) CloseSend() error
  • func (l *LocalQueueIdStreamClient) Context() context.Context
  • func (l *LocalQueueIdStreamClient) Header() (metadata.MD, error)
  • func (l *LocalQueueIdStreamClient) Recv() (*rpc.ListQueuesResponse, error)
  • func (l *LocalQueueIdStreamClient) RecvMsg(m interface{}) error
  • func (l *LocalQueueIdStreamClient) Send(r *rpc.ListQueuesResponse) error
  • func (l *LocalQueueIdStreamClient) SendHeader(metadata.MD) error
  • func (l *LocalQueueIdStreamClient) SendMsg(m interface{}) error
  • func (l *LocalQueueIdStreamClient) SetHeader(metadata.MD) error
  • func (l *LocalQueueIdStreamClient) SetTrailer(metadata.MD)
  • func (l *LocalQueueIdStreamClient) Trailer() metadata.MD
• type QProxyDirectClient
  • func (m *QProxyDirectClient) AckMessages(ctx context.Context, in *rpc.AckMessagesRequest, opts ...grpc.CallOption) (*rpc.AckMessagesResponse, error)
  • func (m *QProxyDirectClient) CreateQueue(ctx context.Context, in *rpc.CreateQueueRequest, opts ...grpc.CallOption) (*rpc.CreateQueueResponse, error)
  • func (m *QProxyDirectClient) DeleteQueue(ctx context.Context, in *rpc.DeleteQueueRequest, opts ...grpc.CallOption) (*rpc.DeleteQueueResponse, error)
  • func (m *QProxyDirectClient) GetMessages(ctx context.Context, in *rpc.GetMessagesRequest, opts ...grpc.CallOption) (*rpc.GetMessagesResponse, error)
  • func (m *QProxyDirectClient) GetQueue(ctx context.Context, in *rpc.GetQueueRequest, opts ...grpc.CallOption) (*rpc.GetQueueResponse, error)
  • func (m *QProxyDirectClient) Healthcheck(ctx context.Context, in *rpc.HealthcheckRequest, opts ...grpc.CallOption) (*rpc.HealthcheckResponse, error)
  • func (m *QProxyDirectClient) ListQueues(ctx context.Context, in *rpc.ListQueuesRequest, opts ...grpc.CallOption) (rpc.QProxy_ListQueuesClient, error)
  • func (m *QProxyDirectClient) ModifyAckDeadline(ctx context.Context, in *rpc.ModifyAckDeadlineRequest, opts ...grpc.CallOption) (*rpc.ModifyAckDeadlineResponse, error)
  • func (m *QProxyDirectClient) ModifyQueue(ctx context.Context, in *rpc.ModifyQueueRequest, opts ...grpc.CallOption) (*rpc.ModifyQueueResponse, error)
  • func (m *QProxyDirectClient) PublishMessages(ctx context.Context, in *rpc.PublishMessagesRequest, opts ...grpc.CallOption) (*rpc.PublishMessagesResponse, error)
  • func (m *QProxyDirectClient) PurgeQueue(ctx context.Context, in *rpc.PurgeQueueRequest, opts ...grpc.CallOption) (*rpc.PurgeQueueResponse, error)

Types

type LocalQueueIdStreamClient

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

ListQueues local stream client

func (*LocalQueueIdStreamClient) CloseSend

func (l *LocalQueueIdStreamClient) CloseSend() error

func (*LocalQueueIdStreamClient) Context

func (l *LocalQueueIdStreamClient) Context() context.Context

func (*LocalQueueIdStreamClient) Header

func (l *LocalQueueIdStreamClient) Header() (metadata.MD, error)

ClientStream

func (*LocalQueueIdStreamClient) Recv

func (l *LocalQueueIdStreamClient) Recv() (*rpc.ListQueuesResponse, error)

func (*LocalQueueIdStreamClient) RecvMsg

func (l *LocalQueueIdStreamClient) RecvMsg(m interface{}) error

func (*LocalQueueIdStreamClient) Send

func (l *LocalQueueIdStreamClient) Send(r *rpc.ListQueuesResponse) error

func (*LocalQueueIdStreamClient) SendHeader

func (l *LocalQueueIdStreamClient) SendHeader(metadata.MD) error

func (*LocalQueueIdStreamClient) SendMsg

func (l *LocalQueueIdStreamClient) SendMsg(m interface{}) error

func (*LocalQueueIdStreamClient) SetHeader

func (l *LocalQueueIdStreamClient) SetHeader(metadata.MD) error

func (*LocalQueueIdStreamClient) SetTrailer

func (l *LocalQueueIdStreamClient) SetTrailer(metadata.MD)

func (*LocalQueueIdStreamClient) Trailer

func (l *LocalQueueIdStreamClient) Trailer() metadata.MD

type QProxyDirectClient

type QProxyDirectClient struct{ S rpc.QProxyServer }

func (*QProxyDirectClient) AckMessages

func (m *QProxyDirectClient) AckMessages(ctx context.Context, in *rpc.AckMessagesRequest, opts ...grpc.CallOption) (*rpc.AckMessagesResponse, error)

func (*QProxyDirectClient) CreateQueue

func (m *QProxyDirectClient) CreateQueue(ctx context.Context, in *rpc.CreateQueueRequest, opts ...grpc.CallOption) (*rpc.CreateQueueResponse, error)

func (*QProxyDirectClient) DeleteQueue

func (m *QProxyDirectClient) DeleteQueue(ctx context.Context, in *rpc.DeleteQueueRequest, opts ...grpc.CallOption) (*rpc.DeleteQueueResponse, error)

func (*QProxyDirectClient) GetMessages

func (m *QProxyDirectClient) GetMessages(ctx context.Context, in *rpc.GetMessagesRequest, opts ...grpc.CallOption) (*rpc.GetMessagesResponse, error)

func (*QProxyDirectClient) GetQueue

func (m *QProxyDirectClient) GetQueue(ctx context.Context, in *rpc.GetQueueRequest, opts ...grpc.CallOption) (*rpc.GetQueueResponse, error)

func (*QProxyDirectClient) Healthcheck

func (m *QProxyDirectClient) Healthcheck(ctx context.Context, in *rpc.HealthcheckRequest, opts ...grpc.CallOption) (*rpc.HealthcheckResponse, error)

Control flow

func (*QProxyDirectClient) ListQueues

func (m *QProxyDirectClient) ListQueues(ctx context.Context, in *rpc.ListQueuesRequest, opts ...grpc.CallOption) (rpc.QProxy_ListQueuesClient, error)

func (*QProxyDirectClient) ModifyAckDeadline

func (m *QProxyDirectClient) ModifyAckDeadline(ctx context.Context, in *rpc.ModifyAckDeadlineRequest, opts ...grpc.CallOption) (*rpc.ModifyAckDeadlineResponse, error)

func (*QProxyDirectClient) ModifyQueue

func (m *QProxyDirectClient) ModifyQueue(ctx context.Context, in *rpc.ModifyQueueRequest, opts ...grpc.CallOption) (*rpc.ModifyQueueResponse, error)

func (*QProxyDirectClient) PublishMessages

func (m *QProxyDirectClient) PublishMessages(ctx context.Context, in *rpc.PublishMessagesRequest, opts ...grpc.CallOption) (*rpc.PublishMessagesResponse, error)

func (*QProxyDirectClient) PurgeQueue

func (m *QProxyDirectClient) PurgeQueue(ctx context.Context, in *rpc.PurgeQueueRequest, opts ...grpc.CallOption) (*rpc.PurgeQueueResponse, error)