queue

Documentation

Index

• func RegisterQueueServer(s *grpc.Server, srv QueueServer)
• type AcknowledgePullRequest
  • func (*AcknowledgePullRequest) Descriptor() ([]byte, []int)
  • func (m *AcknowledgePullRequest) GetKey() string
  • func (*AcknowledgePullRequest) ProtoMessage()
  • func (m *AcknowledgePullRequest) Reset()
  • func (m *AcknowledgePullRequest) String() string
  • func (m *AcknowledgePullRequest) XXX_DiscardUnknown()
  • func (m *AcknowledgePullRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *AcknowledgePullRequest) XXX_Merge(src proto.Message)
  • func (m *AcknowledgePullRequest) XXX_Size() int
  • func (m *AcknowledgePullRequest) XXX_Unmarshal(b []byte) error
• type PullResponse
  • func (*PullResponse) Descriptor() ([]byte, []int)
  • func (m *PullResponse) GetKey() string
  • func (m *PullResponse) GetValue() []byte
  • func (*PullResponse) ProtoMessage()
  • func (m *PullResponse) Reset()
  • func (m *PullResponse) String() string
  • func (m *PullResponse) XXX_DiscardUnknown()
  • func (m *PullResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PullResponse) XXX_Merge(src proto.Message)
  • func (m *PullResponse) XXX_Size() int
  • func (m *PullResponse) XXX_Unmarshal(b []byte) error
• type PushRequest
  • func (*PushRequest) Descriptor() ([]byte, []int)
  • func (m *PushRequest) GetKey() string
  • func (m *PushRequest) GetValue() []byte
  • func (*PushRequest) ProtoMessage()
  • func (m *PushRequest) Reset()
  • func (m *PushRequest) String() string
  • func (m *PushRequest) XXX_DiscardUnknown()
  • func (m *PushRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PushRequest) XXX_Merge(src proto.Message)
  • func (m *PushRequest) XXX_Size() int
  • func (m *PushRequest) XXX_Unmarshal(b []byte) error
• type QueueClient
  • func NewQueueClient(cc grpc.ClientConnInterface) QueueClient
• type QueueServer
• type UnimplementedQueueServer
  • func (*UnimplementedQueueServer) AcknowledgePull(ctx context.Context, req *AcknowledgePullRequest) (*empty.Empty, error)
  • func (*UnimplementedQueueServer) Pull(ctx context.Context, req *empty.Empty) (*PullResponse, error)
  • func (*UnimplementedQueueServer) Push(ctx context.Context, req *PushRequest) (*empty.Empty, error)

Functions

func RegisterQueueServer

func RegisterQueueServer(s *grpc.Server, srv QueueServer)

Types

type AcknowledgePullRequest

type AcknowledgePullRequest struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AcknowledgePullRequest) Descriptor

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

func (*AcknowledgePullRequest) GetKey

func (m *AcknowledgePullRequest) GetKey() string

func (*AcknowledgePullRequest) ProtoMessage

func (*AcknowledgePullRequest) ProtoMessage()

func (*AcknowledgePullRequest) Reset

func (m *AcknowledgePullRequest) Reset()

func (*AcknowledgePullRequest) String

func (m *AcknowledgePullRequest) String() string

func (*AcknowledgePullRequest) XXX_DiscardUnknown

func (m *AcknowledgePullRequest) XXX_DiscardUnknown()

func (*AcknowledgePullRequest) XXX_Marshal

func (m *AcknowledgePullRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AcknowledgePullRequest) XXX_Merge

func (m *AcknowledgePullRequest) XXX_Merge(src proto.Message)

func (*AcknowledgePullRequest) XXX_Size

func (m *AcknowledgePullRequest) XXX_Size() int

func (*AcknowledgePullRequest) XXX_Unmarshal

func (m *AcknowledgePullRequest) XXX_Unmarshal(b []byte) error

type PullResponse

type PullResponse struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PullResponse) Descriptor

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

func (*PullResponse) GetKey

func (m *PullResponse) GetKey() string

func (*PullResponse) GetValue

func (m *PullResponse) GetValue() []byte

func (*PullResponse) ProtoMessage

func (*PullResponse) ProtoMessage()

func (*PullResponse) Reset

func (m *PullResponse) Reset()

func (*PullResponse) String

func (m *PullResponse) String() string

func (*PullResponse) XXX_DiscardUnknown

func (m *PullResponse) XXX_DiscardUnknown()

func (*PullResponse) XXX_Marshal

func (m *PullResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PullResponse) XXX_Merge

func (m *PullResponse) XXX_Merge(src proto.Message)

func (*PullResponse) XXX_Size

func (m *PullResponse) XXX_Size() int

func (*PullResponse) XXX_Unmarshal

func (m *PullResponse) XXX_Unmarshal(b []byte) error

type PushRequest

type PushRequest struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PushRequest) Descriptor

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

func (*PushRequest) GetKey

func (m *PushRequest) GetKey() string

func (*PushRequest) GetValue

func (m *PushRequest) GetValue() []byte

func (*PushRequest) ProtoMessage

func (*PushRequest) ProtoMessage()

func (*PushRequest) Reset

func (m *PushRequest) Reset()

func (*PushRequest) String

func (m *PushRequest) String() string

func (*PushRequest) XXX_DiscardUnknown

func (m *PushRequest) XXX_DiscardUnknown()

func (*PushRequest) XXX_Marshal

func (m *PushRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PushRequest) XXX_Merge

func (m *PushRequest) XXX_Merge(src proto.Message)

func (*PushRequest) XXX_Size

func (m *PushRequest) XXX_Size() int

func (*PushRequest) XXX_Unmarshal

func (m *PushRequest) XXX_Unmarshal(b []byte) error

type QueueClient

type QueueClient interface {
	Push(ctx context.Context, in *PushRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	Pull(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*PullResponse, error)
	AcknowledgePull(ctx context.Context, in *AcknowledgePullRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

QueueClient is the client API for Queue service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueueClient

func NewQueueClient(cc grpc.ClientConnInterface) QueueClient

type QueueServer

type QueueServer interface {
	Push(context.Context, *PushRequest) (*empty.Empty, error)
	Pull(context.Context, *empty.Empty) (*PullResponse, error)
	AcknowledgePull(context.Context, *AcknowledgePullRequest) (*empty.Empty, error)
}

QueueServer is the server API for Queue service.

type UnimplementedQueueServer

type UnimplementedQueueServer struct {
}

UnimplementedQueueServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueueServer) AcknowledgePull

func (*UnimplementedQueueServer) AcknowledgePull(ctx context.Context, req *AcknowledgePullRequest) (*empty.Empty, error)

func (*UnimplementedQueueServer) Pull

func (*UnimplementedQueueServer) Pull(ctx context.Context, req *empty.Empty) (*PullResponse, error)

func (*UnimplementedQueueServer) Push

func (*UnimplementedQueueServer) Push(ctx context.Context, req *PushRequest) (*empty.Empty, error)