Documentation
¶
Index ¶
- Variables
- func RegisterV1Server(s *grpc.Server, srv V1Server)
- type AcquireRequest
- func (*AcquireRequest) Descriptor() ([]byte, []int)
- func (m *AcquireRequest) GetMetadata() map[string]string
- func (m *AcquireRequest) GetName() string
- func (m *AcquireRequest) GetNamespace() string
- func (m *AcquireRequest) GetOwner() string
- func (m *AcquireRequest) GetTtl() uint32
- func (*AcquireRequest) ProtoMessage()
- func (m *AcquireRequest) Reset()
- func (m *AcquireRequest) String() string
- func (m *AcquireRequest) XXX_DiscardUnknown()
- func (m *AcquireRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AcquireRequest) XXX_Merge(src proto.Message)
- func (m *AcquireRequest) XXX_Size() int
- func (m *AcquireRequest) XXX_Unmarshal(b []byte) error
- type AcquireResponse
- func (*AcquireResponse) Descriptor() ([]byte, []int)
- func (m *AcquireResponse) GetHandle() *Handle
- func (m *AcquireResponse) GetStatus() Status
- func (*AcquireResponse) ProtoMessage()
- func (m *AcquireResponse) Reset()
- func (m *AcquireResponse) String() string
- func (m *AcquireResponse) XXX_DiscardUnknown()
- func (m *AcquireResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AcquireResponse) XXX_Merge(src proto.Message)
- func (m *AcquireResponse) XXX_Size() int
- func (m *AcquireResponse) XXX_Unmarshal(b []byte) error
- type DoneRequest
- func (*DoneRequest) Descriptor() ([]byte, []int)
- func (m *DoneRequest) GetHandleId() []byte
- func (m *DoneRequest) GetMetadata() map[string]string
- func (m *DoneRequest) GetOwner() string
- func (*DoneRequest) ProtoMessage()
- func (m *DoneRequest) Reset()
- func (m *DoneRequest) String() string
- func (m *DoneRequest) XXX_DiscardUnknown()
- func (m *DoneRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DoneRequest) XXX_Merge(src proto.Message)
- func (m *DoneRequest) XXX_Size() int
- func (m *DoneRequest) XXX_Unmarshal(b []byte) error
- type DoneResponse
- func (*DoneResponse) Descriptor() ([]byte, []int)
- func (*DoneResponse) ProtoMessage()
- func (m *DoneResponse) Reset()
- func (m *DoneResponse) String() string
- func (m *DoneResponse) XXX_DiscardUnknown()
- func (m *DoneResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DoneResponse) XXX_Merge(src proto.Message)
- func (m *DoneResponse) XXX_Size() int
- func (m *DoneResponse) XXX_Unmarshal(b []byte) error
- type Handle
- func (*Handle) Descriptor() ([]byte, []int)
- func (m *Handle) GetDoneTime() int64
- func (m *Handle) GetExpTime() int64
- func (m *Handle) GetId() []byte
- func (m *Handle) GetMetadata() map[string]string
- func (m *Handle) GetName() string
- func (m *Handle) GetNamespace() string
- func (m *Handle) GetNumAcquired() uint32
- func (*Handle) ProtoMessage()
- func (m *Handle) Reset()
- func (m *Handle) String() string
- func (m *Handle) XXX_DiscardUnknown()
- func (m *Handle) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Handle) XXX_Merge(src proto.Message)
- func (m *Handle) XXX_Size() int
- func (m *Handle) XXX_Unmarshal(b []byte) error
- type ListRequest
- func (*ListRequest) Descriptor() ([]byte, []int)
- func (m *ListRequest) GetFilter() *ListRequest_Filter
- func (*ListRequest) ProtoMessage()
- func (m *ListRequest) Reset()
- func (m *ListRequest) String() string
- func (m *ListRequest) XXX_DiscardUnknown()
- func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListRequest) XXX_Merge(src proto.Message)
- func (m *ListRequest) XXX_Size() int
- func (m *ListRequest) XXX_Unmarshal(b []byte) error
- type ListRequest_Filter
- func (*ListRequest_Filter) Descriptor() ([]byte, []int)
- func (m *ListRequest_Filter) GetMetadata() map[string]string
- func (m *ListRequest_Filter) GetPrefix() string
- func (m *ListRequest_Filter) GetStatus() ListRequest_Filter_Status
- func (*ListRequest_Filter) ProtoMessage()
- func (m *ListRequest_Filter) Reset()
- func (m *ListRequest_Filter) String() string
- func (m *ListRequest_Filter) XXX_DiscardUnknown()
- func (m *ListRequest_Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListRequest_Filter) XXX_Merge(src proto.Message)
- func (m *ListRequest_Filter) XXX_Size() int
- func (m *ListRequest_Filter) XXX_Unmarshal(b []byte) error
- type ListRequest_Filter_Status
- type RenewRequest
- func (*RenewRequest) Descriptor() ([]byte, []int)
- func (m *RenewRequest) GetHandleId() []byte
- func (m *RenewRequest) GetMetadata() map[string]string
- func (m *RenewRequest) GetOwner() string
- func (m *RenewRequest) GetTtl() uint32
- func (*RenewRequest) ProtoMessage()
- func (m *RenewRequest) Reset()
- func (m *RenewRequest) String() string
- func (m *RenewRequest) XXX_DiscardUnknown()
- func (m *RenewRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RenewRequest) XXX_Merge(src proto.Message)
- func (m *RenewRequest) XXX_Size() int
- func (m *RenewRequest) XXX_Unmarshal(b []byte) error
- type RenewResponse
- func (*RenewResponse) Descriptor() ([]byte, []int)
- func (*RenewResponse) ProtoMessage()
- func (m *RenewResponse) Reset()
- func (m *RenewResponse) String() string
- func (m *RenewResponse) XXX_DiscardUnknown()
- func (m *RenewResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RenewResponse) XXX_Merge(src proto.Message)
- func (m *RenewResponse) XXX_Size() int
- func (m *RenewResponse) XXX_Unmarshal(b []byte) error
- type Status
- type UnimplementedV1Server
- func (*UnimplementedV1Server) Acquire(ctx context.Context, req *AcquireRequest) (*AcquireResponse, error)
- func (*UnimplementedV1Server) Done(ctx context.Context, req *DoneRequest) (*DoneResponse, error)
- func (*UnimplementedV1Server) List(req *ListRequest, srv V1_ListServer) error
- func (*UnimplementedV1Server) Renew(ctx context.Context, req *RenewRequest) (*RenewResponse, error)
- type V1Client
- type V1Server
- type V1_ListClient
- type V1_ListServer
Constants ¶
This section is empty.
Variables ¶
View Source
var ListRequest_Filter_Status_name = map[int32]string{
0: "ALL",
1: "DONE",
}
View Source
var ListRequest_Filter_Status_value = map[string]int32{
"ALL": 0,
"DONE": 1,
}
View Source
var Status_name = map[int32]string{
0: "OK",
1: "DONE",
2: "HELD",
}
View Source
var Status_value = map[string]int32{
"OK": 0,
"DONE": 1,
"HELD": 2,
}
Functions ¶
func RegisterV1Server ¶
Types ¶
type AcquireRequest ¶
type AcquireRequest struct {
// Owner identifier
Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
// Resource name/identifier.
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
// Custom namespace.
Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
// TTL the maximum life-span of the acquired resource (in seconds).
Ttl uint32 `protobuf:"varint,4,opt,name=ttl,proto3" json:"ttl,omitempty"`
// Custom, optional metadata.
Metadata map[string]string `` /* 157-byte string literal not displayed */
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*AcquireRequest) Descriptor ¶
func (*AcquireRequest) Descriptor() ([]byte, []int)
func (*AcquireRequest) GetMetadata ¶
func (m *AcquireRequest) GetMetadata() map[string]string
func (*AcquireRequest) GetName ¶
func (m *AcquireRequest) GetName() string
func (*AcquireRequest) GetNamespace ¶
func (m *AcquireRequest) GetNamespace() string
func (*AcquireRequest) GetOwner ¶
func (m *AcquireRequest) GetOwner() string
func (*AcquireRequest) GetTtl ¶
func (m *AcquireRequest) GetTtl() uint32
func (*AcquireRequest) ProtoMessage ¶
func (*AcquireRequest) ProtoMessage()
func (*AcquireRequest) Reset ¶
func (m *AcquireRequest) Reset()
func (*AcquireRequest) String ¶
func (m *AcquireRequest) String() string
func (*AcquireRequest) XXX_DiscardUnknown ¶
func (m *AcquireRequest) XXX_DiscardUnknown()
func (*AcquireRequest) XXX_Marshal ¶
func (m *AcquireRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AcquireRequest) XXX_Merge ¶
func (m *AcquireRequest) XXX_Merge(src proto.Message)
func (*AcquireRequest) XXX_Size ¶
func (m *AcquireRequest) XXX_Size() int
func (*AcquireRequest) XXX_Unmarshal ¶
func (m *AcquireRequest) XXX_Unmarshal(b []byte) error
type AcquireResponse ¶
type AcquireResponse struct {
Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=blacksquaremedia.accord.Status" json:"status,omitempty"`
Handle *Handle `protobuf:"bytes,2,opt,name=handle,proto3" json:"handle,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*AcquireResponse) Descriptor ¶
func (*AcquireResponse) Descriptor() ([]byte, []int)
func (*AcquireResponse) GetHandle ¶
func (m *AcquireResponse) GetHandle() *Handle
func (*AcquireResponse) GetStatus ¶
func (m *AcquireResponse) GetStatus() Status
func (*AcquireResponse) ProtoMessage ¶
func (*AcquireResponse) ProtoMessage()
func (*AcquireResponse) Reset ¶
func (m *AcquireResponse) Reset()
func (*AcquireResponse) String ¶
func (m *AcquireResponse) String() string
func (*AcquireResponse) XXX_DiscardUnknown ¶
func (m *AcquireResponse) XXX_DiscardUnknown()
func (*AcquireResponse) XXX_Marshal ¶
func (m *AcquireResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AcquireResponse) XXX_Merge ¶
func (m *AcquireResponse) XXX_Merge(src proto.Message)
func (*AcquireResponse) XXX_Size ¶
func (m *AcquireResponse) XXX_Size() int
func (*AcquireResponse) XXX_Unmarshal ¶
func (m *AcquireResponse) XXX_Unmarshal(b []byte) error
type DoneRequest ¶
type DoneRequest struct {
// Owner identifier.
Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
// Handle identifier.
HandleId []byte `protobuf:"bytes,2,opt,name=handle_id,json=handleId,proto3" json:"handle_id,omitempty"`
// Optional metadata.
Metadata map[string]string `` /* 157-byte string literal not displayed */
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*DoneRequest) Descriptor ¶
func (*DoneRequest) Descriptor() ([]byte, []int)
func (*DoneRequest) GetHandleId ¶
func (m *DoneRequest) GetHandleId() []byte
func (*DoneRequest) GetMetadata ¶
func (m *DoneRequest) GetMetadata() map[string]string
func (*DoneRequest) GetOwner ¶
func (m *DoneRequest) GetOwner() string
func (*DoneRequest) ProtoMessage ¶
func (*DoneRequest) ProtoMessage()
func (*DoneRequest) Reset ¶
func (m *DoneRequest) Reset()
func (*DoneRequest) String ¶
func (m *DoneRequest) String() string
func (*DoneRequest) XXX_DiscardUnknown ¶
func (m *DoneRequest) XXX_DiscardUnknown()
func (*DoneRequest) XXX_Marshal ¶
func (m *DoneRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DoneRequest) XXX_Merge ¶
func (m *DoneRequest) XXX_Merge(src proto.Message)
func (*DoneRequest) XXX_Size ¶
func (m *DoneRequest) XXX_Size() int
func (*DoneRequest) XXX_Unmarshal ¶
func (m *DoneRequest) XXX_Unmarshal(b []byte) error
type DoneResponse ¶
type DoneResponse struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*DoneResponse) Descriptor ¶
func (*DoneResponse) Descriptor() ([]byte, []int)
func (*DoneResponse) ProtoMessage ¶
func (*DoneResponse) ProtoMessage()
func (*DoneResponse) Reset ¶
func (m *DoneResponse) Reset()
func (*DoneResponse) String ¶
func (m *DoneResponse) String() string
func (*DoneResponse) XXX_DiscardUnknown ¶
func (m *DoneResponse) XXX_DiscardUnknown()
func (*DoneResponse) XXX_Marshal ¶
func (m *DoneResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DoneResponse) XXX_Merge ¶
func (m *DoneResponse) XXX_Merge(src proto.Message)
func (*DoneResponse) XXX_Size ¶
func (m *DoneResponse) XXX_Size() int
func (*DoneResponse) XXX_Unmarshal ¶
func (m *DoneResponse) XXX_Unmarshal(b []byte) error
type Handle ¶
type Handle struct {
// Handle ID
Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// Resource name/identifier, unique within namespace.
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
// Custom namespace.
Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
// Expiration UNIX timestamp (millisecond precision)
ExpTime int64 `protobuf:"varint,4,opt,name=exp_time,json=expTime,proto3" json:"exp_time,omitempty"`
// Done at UNIX timestamp (millisecond precision)
DoneTime int64 `protobuf:"varint,5,opt,name=done_time,json=doneTime,proto3" json:"done_time,omitempty"`
// Describes the number of times this handle has been acquired.
NumAcquired uint32 `protobuf:"varint,6,opt,name=num_acquired,json=numAcquired,proto3" json:"num_acquired,omitempty"`
// Metadata.
Metadata map[string]string `` /* 157-byte string literal not displayed */
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Handle
func (*Handle) Descriptor ¶
func (*Handle) GetDoneTime ¶
func (*Handle) GetExpTime ¶
func (*Handle) GetMetadata ¶
func (*Handle) GetNamespace ¶
func (*Handle) GetNumAcquired ¶
func (*Handle) ProtoMessage ¶
func (*Handle) ProtoMessage()
func (*Handle) XXX_DiscardUnknown ¶
func (m *Handle) XXX_DiscardUnknown()
func (*Handle) XXX_Marshal ¶
func (*Handle) XXX_Unmarshal ¶
type ListRequest ¶
type ListRequest struct {
// Filter object
Filter *ListRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ListRequest) Descriptor ¶
func (*ListRequest) Descriptor() ([]byte, []int)
func (*ListRequest) GetFilter ¶
func (m *ListRequest) GetFilter() *ListRequest_Filter
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) Reset ¶
func (m *ListRequest) Reset()
func (*ListRequest) String ¶
func (m *ListRequest) String() string
func (*ListRequest) XXX_DiscardUnknown ¶
func (m *ListRequest) XXX_DiscardUnknown()
func (*ListRequest) XXX_Marshal ¶
func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListRequest) XXX_Merge ¶
func (m *ListRequest) XXX_Merge(src proto.Message)
func (*ListRequest) XXX_Size ¶
func (m *ListRequest) XXX_Size() int
func (*ListRequest) XXX_Unmarshal ¶
func (m *ListRequest) XXX_Unmarshal(b []byte) error
type ListRequest_Filter ¶
type ListRequest_Filter struct {
// Namespace prefix.
Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
// Only certain status.
Status ListRequest_Filter_Status `protobuf:"varint,2,opt,name=status,proto3,enum=blacksquaremedia.accord.ListRequest_Filter_Status" json:"status,omitempty"`
// Filter by metadata.
Metadata map[string]string `` /* 157-byte string literal not displayed */
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ListRequest_Filter) Descriptor ¶
func (*ListRequest_Filter) Descriptor() ([]byte, []int)
func (*ListRequest_Filter) GetMetadata ¶
func (m *ListRequest_Filter) GetMetadata() map[string]string
func (*ListRequest_Filter) GetPrefix ¶
func (m *ListRequest_Filter) GetPrefix() string
func (*ListRequest_Filter) GetStatus ¶
func (m *ListRequest_Filter) GetStatus() ListRequest_Filter_Status
func (*ListRequest_Filter) ProtoMessage ¶
func (*ListRequest_Filter) ProtoMessage()
func (*ListRequest_Filter) Reset ¶
func (m *ListRequest_Filter) Reset()
func (*ListRequest_Filter) String ¶
func (m *ListRequest_Filter) String() string
func (*ListRequest_Filter) XXX_DiscardUnknown ¶
func (m *ListRequest_Filter) XXX_DiscardUnknown()
func (*ListRequest_Filter) XXX_Marshal ¶
func (m *ListRequest_Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListRequest_Filter) XXX_Merge ¶
func (m *ListRequest_Filter) XXX_Merge(src proto.Message)
func (*ListRequest_Filter) XXX_Size ¶
func (m *ListRequest_Filter) XXX_Size() int
func (*ListRequest_Filter) XXX_Unmarshal ¶
func (m *ListRequest_Filter) XXX_Unmarshal(b []byte) error
type ListRequest_Filter_Status ¶
type ListRequest_Filter_Status int32
const ( ListRequest_Filter_ALL ListRequest_Filter_Status = 0 ListRequest_Filter_DONE ListRequest_Filter_Status = 1 )
func (ListRequest_Filter_Status) EnumDescriptor ¶
func (ListRequest_Filter_Status) EnumDescriptor() ([]byte, []int)
func (ListRequest_Filter_Status) String ¶
func (x ListRequest_Filter_Status) String() string
type RenewRequest ¶
type RenewRequest struct {
// Owner identifier.
Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
// Handle identifier.
HandleId []byte `protobuf:"bytes,2,opt,name=handle_id,json=handleId,proto3" json:"handle_id,omitempty"`
// TTL the maximum life-span of the acquired resource (in seconds).
Ttl uint32 `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
// Optional metadata.
Metadata map[string]string `` /* 157-byte string literal not displayed */
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*RenewRequest) Descriptor ¶
func (*RenewRequest) Descriptor() ([]byte, []int)
func (*RenewRequest) GetHandleId ¶
func (m *RenewRequest) GetHandleId() []byte
func (*RenewRequest) GetMetadata ¶
func (m *RenewRequest) GetMetadata() map[string]string
func (*RenewRequest) GetOwner ¶
func (m *RenewRequest) GetOwner() string
func (*RenewRequest) GetTtl ¶
func (m *RenewRequest) GetTtl() uint32
func (*RenewRequest) ProtoMessage ¶
func (*RenewRequest) ProtoMessage()
func (*RenewRequest) Reset ¶
func (m *RenewRequest) Reset()
func (*RenewRequest) String ¶
func (m *RenewRequest) String() string
func (*RenewRequest) XXX_DiscardUnknown ¶
func (m *RenewRequest) XXX_DiscardUnknown()
func (*RenewRequest) XXX_Marshal ¶
func (m *RenewRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RenewRequest) XXX_Merge ¶
func (m *RenewRequest) XXX_Merge(src proto.Message)
func (*RenewRequest) XXX_Size ¶
func (m *RenewRequest) XXX_Size() int
func (*RenewRequest) XXX_Unmarshal ¶
func (m *RenewRequest) XXX_Unmarshal(b []byte) error
type RenewResponse ¶
type RenewResponse struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*RenewResponse) Descriptor ¶
func (*RenewResponse) Descriptor() ([]byte, []int)
func (*RenewResponse) ProtoMessage ¶
func (*RenewResponse) ProtoMessage()
func (*RenewResponse) Reset ¶
func (m *RenewResponse) Reset()
func (*RenewResponse) String ¶
func (m *RenewResponse) String() string
func (*RenewResponse) XXX_DiscardUnknown ¶
func (m *RenewResponse) XXX_DiscardUnknown()
func (*RenewResponse) XXX_Marshal ¶
func (m *RenewResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RenewResponse) XXX_Merge ¶
func (m *RenewResponse) XXX_Merge(src proto.Message)
func (*RenewResponse) XXX_Size ¶
func (m *RenewResponse) XXX_Size() int
func (*RenewResponse) XXX_Unmarshal ¶
func (m *RenewResponse) XXX_Unmarshal(b []byte) error
type UnimplementedV1Server ¶
type UnimplementedV1Server struct {
}
UnimplementedV1Server can be embedded to have forward compatible implementations.
func (*UnimplementedV1Server) Acquire ¶
func (*UnimplementedV1Server) Acquire(ctx context.Context, req *AcquireRequest) (*AcquireResponse, error)
func (*UnimplementedV1Server) Done ¶
func (*UnimplementedV1Server) Done(ctx context.Context, req *DoneRequest) (*DoneResponse, error)
func (*UnimplementedV1Server) List ¶
func (*UnimplementedV1Server) List(req *ListRequest, srv V1_ListServer) error
func (*UnimplementedV1Server) Renew ¶
func (*UnimplementedV1Server) Renew(ctx context.Context, req *RenewRequest) (*RenewResponse, error)
type V1Client ¶
type V1Client interface {
// Acquire requests resource handle.
Acquire(ctx context.Context, in *AcquireRequest, opts ...grpc.CallOption) (*AcquireResponse, error)
// Renew renews resource handle.
Renew(ctx context.Context, in *RenewRequest, opts ...grpc.CallOption) (*RenewResponse, error)
// Done marks an handle as completed.
Done(ctx context.Context, in *DoneRequest, opts ...grpc.CallOption) (*DoneResponse, error)
// List streams handles that are done.
List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (V1_ListClient, error)
}
V1Client is the client API for V1 service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewV1Client ¶
func NewV1Client(cc *grpc.ClientConn) V1Client
type V1Server ¶
type V1Server interface {
// Acquire requests resource handle.
Acquire(context.Context, *AcquireRequest) (*AcquireResponse, error)
// Renew renews resource handle.
Renew(context.Context, *RenewRequest) (*RenewResponse, error)
// Done marks an handle as completed.
Done(context.Context, *DoneRequest) (*DoneResponse, error)
// List streams handles that are done.
List(*ListRequest, V1_ListServer) error
}
V1Server is the server API for V1 service.
type V1_ListClient ¶
type V1_ListClient interface {
Recv() (*Handle, error)
grpc.ClientStream
}
type V1_ListServer ¶
type V1_ListServer interface {
Send(*Handle) error
grpc.ServerStream
}
Click to show internal directories.
Click to hide internal directories.