Versions in this module Expand all Collapse all v0 v0.3.0 Dec 22, 2020 Changes in this version + var SetStateRequest_State_name = map[int32]string + var SetStateRequest_State_value = map[string]int32 + func RegisterAdminServer(s *grpc.Server, srv AdminServer) + type AdminClient interface + Queue func(ctx context.Context, in *QueueRequest, opts ...grpc.CallOption) (*VoidResponse, error) + SetRateLimit func(ctx context.Context, in *SetRateLimitRequest, opts ...grpc.CallOption) (*VoidResponse, error) + SetState func(ctx context.Context, in *SetStateRequest, opts ...grpc.CallOption) (*VoidResponse, error) + func NewAdminClient(cc *grpc.ClientConn) AdminClient + type AdminServer interface + Queue func(context.Context, *QueueRequest) (*VoidResponse, error) + SetRateLimit func(context.Context, *SetRateLimitRequest) (*VoidResponse, error) + SetState func(context.Context, *SetStateRequest) (*VoidResponse, error) + type QueueRequest struct + Items []*QueueRequest_QueueItem + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*QueueRequest) Descriptor() ([]byte, []int) + func (*QueueRequest) ProtoMessage() + func (m *QueueRequest) GetItems() []*QueueRequest_QueueItem + func (m *QueueRequest) Reset() + func (m *QueueRequest) String() string + func (m *QueueRequest) Validate() error + func (m *QueueRequest) XXX_DiscardUnknown() + func (m *QueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueueRequest) XXX_Merge(src proto.Message) + func (m *QueueRequest) XXX_Size() int + func (m *QueueRequest) XXX_Unmarshal(b []byte) error + type QueueRequestValidationError struct + func (e QueueRequestValidationError) Cause() error + func (e QueueRequestValidationError) Error() string + func (e QueueRequestValidationError) ErrorName() string + func (e QueueRequestValidationError) Field() string + func (e QueueRequestValidationError) Key() bool + func (e QueueRequestValidationError) Reason() string + type QueueRequest_QueueItem struct + IgnoreZeroBalance bool + Key []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*QueueRequest_QueueItem) Descriptor() ([]byte, []int) + func (*QueueRequest_QueueItem) ProtoMessage() + func (m *QueueRequest_QueueItem) GetIgnoreZeroBalance() bool + func (m *QueueRequest_QueueItem) GetKey() []byte + func (m *QueueRequest_QueueItem) Reset() + func (m *QueueRequest_QueueItem) String() string + func (m *QueueRequest_QueueItem) Validate() error + func (m *QueueRequest_QueueItem) XXX_DiscardUnknown() + func (m *QueueRequest_QueueItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueueRequest_QueueItem) XXX_Merge(src proto.Message) + func (m *QueueRequest_QueueItem) XXX_Size() int + func (m *QueueRequest_QueueItem) XXX_Unmarshal(b []byte) error + type QueueRequest_QueueItemValidationError struct + func (e QueueRequest_QueueItemValidationError) Cause() error + func (e QueueRequest_QueueItemValidationError) Error() string + func (e QueueRequest_QueueItemValidationError) ErrorName() string + func (e QueueRequest_QueueItemValidationError) Field() string + func (e QueueRequest_QueueItemValidationError) Key() bool + func (e QueueRequest_QueueItemValidationError) Reason() string + type SetRateLimitRequest struct + Rate uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SetRateLimitRequest) Descriptor() ([]byte, []int) + func (*SetRateLimitRequest) ProtoMessage() + func (m *SetRateLimitRequest) GetRate() uint32 + func (m *SetRateLimitRequest) Reset() + func (m *SetRateLimitRequest) String() string + func (m *SetRateLimitRequest) Validate() error + func (m *SetRateLimitRequest) XXX_DiscardUnknown() + func (m *SetRateLimitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SetRateLimitRequest) XXX_Merge(src proto.Message) + func (m *SetRateLimitRequest) XXX_Size() int + func (m *SetRateLimitRequest) XXX_Unmarshal(b []byte) error + type SetRateLimitRequestValidationError struct + func (e SetRateLimitRequestValidationError) Cause() error + func (e SetRateLimitRequestValidationError) Error() string + func (e SetRateLimitRequestValidationError) ErrorName() string + func (e SetRateLimitRequestValidationError) Field() string + func (e SetRateLimitRequestValidationError) Key() bool + func (e SetRateLimitRequestValidationError) Reason() string + type SetStateRequest struct + State SetStateRequest_State + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SetStateRequest) Descriptor() ([]byte, []int) + func (*SetStateRequest) ProtoMessage() + func (m *SetStateRequest) GetState() SetStateRequest_State + func (m *SetStateRequest) Reset() + func (m *SetStateRequest) String() string + func (m *SetStateRequest) Validate() error + func (m *SetStateRequest) XXX_DiscardUnknown() + func (m *SetStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SetStateRequest) XXX_Merge(src proto.Message) + func (m *SetStateRequest) XXX_Size() int + func (m *SetStateRequest) XXX_Unmarshal(b []byte) error + type SetStateRequestValidationError struct + func (e SetStateRequestValidationError) Cause() error + func (e SetStateRequestValidationError) Error() string + func (e SetStateRequestValidationError) ErrorName() string + func (e SetStateRequestValidationError) Field() string + func (e SetStateRequestValidationError) Key() bool + func (e SetStateRequestValidationError) Reason() string + type SetStateRequest_State int32 + const SetStateRequest_RUNNING + const SetStateRequest_STOPPED + func (SetStateRequest_State) EnumDescriptor() ([]byte, []int) + func (x SetStateRequest_State) String() string + type UnimplementedAdminServer struct + func (*UnimplementedAdminServer) Queue(ctx context.Context, req *QueueRequest) (*VoidResponse, error) + func (*UnimplementedAdminServer) SetRateLimit(ctx context.Context, req *SetRateLimitRequest) (*VoidResponse, error) + func (*UnimplementedAdminServer) SetState(ctx context.Context, req *SetStateRequest) (*VoidResponse, error) + type VoidResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*VoidResponse) Descriptor() ([]byte, []int) + func (*VoidResponse) ProtoMessage() + func (m *VoidResponse) Reset() + func (m *VoidResponse) String() string + func (m *VoidResponse) Validate() error + func (m *VoidResponse) XXX_DiscardUnknown() + func (m *VoidResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *VoidResponse) XXX_Merge(src proto.Message) + func (m *VoidResponse) XXX_Size() int + func (m *VoidResponse) XXX_Unmarshal(b []byte) error + type VoidResponseValidationError struct + func (e VoidResponseValidationError) Cause() error + func (e VoidResponseValidationError) Error() string + func (e VoidResponseValidationError) ErrorName() string + func (e VoidResponseValidationError) Field() string + func (e VoidResponseValidationError) Key() bool + func (e VoidResponseValidationError) Reason() string