Documentation
¶
Index ¶
- Variables
- func RegisterLockServiceServer(s *grpc.Server, srv LockServiceServer)
- type CloseRequest
- func (*CloseRequest) Descriptor() ([]byte, []int)
- func (m *CloseRequest) GetDelete() bool
- func (m *CloseRequest) GetHeader() *headers.RequestHeader
- func (m *CloseRequest) Marshal() (dAtA []byte, err error)
- func (m *CloseRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CloseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CloseRequest) ProtoMessage()
- func (m *CloseRequest) Reset()
- func (m *CloseRequest) Size() (n int)
- func (m *CloseRequest) String() string
- func (m *CloseRequest) Unmarshal(dAtA []byte) error
- func (m *CloseRequest) XXX_DiscardUnknown()
- func (m *CloseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloseRequest) XXX_Merge(src proto.Message)
- func (m *CloseRequest) XXX_Size() int
- func (m *CloseRequest) XXX_Unmarshal(b []byte) error
- type CloseResponse
- func (*CloseResponse) Descriptor() ([]byte, []int)
- func (m *CloseResponse) GetHeader() *headers.ResponseHeader
- func (m *CloseResponse) Marshal() (dAtA []byte, err error)
- func (m *CloseResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CloseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CloseResponse) ProtoMessage()
- func (m *CloseResponse) Reset()
- func (m *CloseResponse) Size() (n int)
- func (m *CloseResponse) String() string
- func (m *CloseResponse) Unmarshal(dAtA []byte) error
- func (m *CloseResponse) XXX_DiscardUnknown()
- func (m *CloseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloseResponse) XXX_Merge(src proto.Message)
- func (m *CloseResponse) XXX_Size() int
- func (m *CloseResponse) XXX_Unmarshal(b []byte) error
- type CreateRequest
- func (*CreateRequest) Descriptor() ([]byte, []int)
- func (m *CreateRequest) GetHeader() *headers.RequestHeader
- func (m *CreateRequest) GetTimeout() *time.Duration
- func (m *CreateRequest) Marshal() (dAtA []byte, err error)
- func (m *CreateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateRequest) ProtoMessage()
- func (m *CreateRequest) Reset()
- func (m *CreateRequest) Size() (n int)
- func (m *CreateRequest) String() string
- func (m *CreateRequest) Unmarshal(dAtA []byte) error
- func (m *CreateRequest) XXX_DiscardUnknown()
- func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateRequest) XXX_Merge(src proto.Message)
- func (m *CreateRequest) XXX_Size() int
- func (m *CreateRequest) XXX_Unmarshal(b []byte) error
- type CreateResponse
- func (*CreateResponse) Descriptor() ([]byte, []int)
- func (m *CreateResponse) GetHeader() *headers.ResponseHeader
- func (m *CreateResponse) Marshal() (dAtA []byte, err error)
- func (m *CreateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateResponse) ProtoMessage()
- func (m *CreateResponse) Reset()
- func (m *CreateResponse) Size() (n int)
- func (m *CreateResponse) String() string
- func (m *CreateResponse) Unmarshal(dAtA []byte) error
- func (m *CreateResponse) XXX_DiscardUnknown()
- func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateResponse) XXX_Merge(src proto.Message)
- func (m *CreateResponse) XXX_Size() int
- func (m *CreateResponse) XXX_Unmarshal(b []byte) error
- type IsLockedRequest
- func (*IsLockedRequest) Descriptor() ([]byte, []int)
- func (m *IsLockedRequest) GetHeader() *headers.RequestHeader
- func (m *IsLockedRequest) GetVersion() uint64
- func (m *IsLockedRequest) Marshal() (dAtA []byte, err error)
- func (m *IsLockedRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *IsLockedRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IsLockedRequest) ProtoMessage()
- func (m *IsLockedRequest) Reset()
- func (m *IsLockedRequest) Size() (n int)
- func (m *IsLockedRequest) String() string
- func (m *IsLockedRequest) Unmarshal(dAtA []byte) error
- func (m *IsLockedRequest) XXX_DiscardUnknown()
- func (m *IsLockedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IsLockedRequest) XXX_Merge(src proto.Message)
- func (m *IsLockedRequest) XXX_Size() int
- func (m *IsLockedRequest) XXX_Unmarshal(b []byte) error
- type IsLockedResponse
- func (*IsLockedResponse) Descriptor() ([]byte, []int)
- func (m *IsLockedResponse) GetHeader() *headers.ResponseHeader
- func (m *IsLockedResponse) GetIsLocked() bool
- func (m *IsLockedResponse) Marshal() (dAtA []byte, err error)
- func (m *IsLockedResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *IsLockedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IsLockedResponse) ProtoMessage()
- func (m *IsLockedResponse) Reset()
- func (m *IsLockedResponse) Size() (n int)
- func (m *IsLockedResponse) String() string
- func (m *IsLockedResponse) Unmarshal(dAtA []byte) error
- func (m *IsLockedResponse) XXX_DiscardUnknown()
- func (m *IsLockedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IsLockedResponse) XXX_Merge(src proto.Message)
- func (m *IsLockedResponse) XXX_Size() int
- func (m *IsLockedResponse) XXX_Unmarshal(b []byte) error
- type KeepAliveRequest
- func (*KeepAliveRequest) Descriptor() ([]byte, []int)
- func (m *KeepAliveRequest) GetHeader() *headers.RequestHeader
- func (m *KeepAliveRequest) Marshal() (dAtA []byte, err error)
- func (m *KeepAliveRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *KeepAliveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*KeepAliveRequest) ProtoMessage()
- func (m *KeepAliveRequest) Reset()
- func (m *KeepAliveRequest) Size() (n int)
- func (m *KeepAliveRequest) String() string
- func (m *KeepAliveRequest) Unmarshal(dAtA []byte) error
- func (m *KeepAliveRequest) XXX_DiscardUnknown()
- func (m *KeepAliveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KeepAliveRequest) XXX_Merge(src proto.Message)
- func (m *KeepAliveRequest) XXX_Size() int
- func (m *KeepAliveRequest) XXX_Unmarshal(b []byte) error
- type KeepAliveResponse
- func (*KeepAliveResponse) Descriptor() ([]byte, []int)
- func (m *KeepAliveResponse) GetHeader() *headers.ResponseHeader
- func (m *KeepAliveResponse) Marshal() (dAtA []byte, err error)
- func (m *KeepAliveResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *KeepAliveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*KeepAliveResponse) ProtoMessage()
- func (m *KeepAliveResponse) Reset()
- func (m *KeepAliveResponse) Size() (n int)
- func (m *KeepAliveResponse) String() string
- func (m *KeepAliveResponse) Unmarshal(dAtA []byte) error
- func (m *KeepAliveResponse) XXX_DiscardUnknown()
- func (m *KeepAliveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KeepAliveResponse) XXX_Merge(src proto.Message)
- func (m *KeepAliveResponse) XXX_Size() int
- func (m *KeepAliveResponse) XXX_Unmarshal(b []byte) error
- type LockRequest
- func (*LockRequest) Descriptor() ([]byte, []int)
- func (m *LockRequest) GetHeader() *headers.RequestHeader
- func (m *LockRequest) GetTimeout() *time.Duration
- func (m *LockRequest) Marshal() (dAtA []byte, err error)
- func (m *LockRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *LockRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LockRequest) ProtoMessage()
- func (m *LockRequest) Reset()
- func (m *LockRequest) Size() (n int)
- func (m *LockRequest) String() string
- func (m *LockRequest) Unmarshal(dAtA []byte) error
- func (m *LockRequest) XXX_DiscardUnknown()
- func (m *LockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LockRequest) XXX_Merge(src proto.Message)
- func (m *LockRequest) XXX_Size() int
- func (m *LockRequest) XXX_Unmarshal(b []byte) error
- type LockResponse
- func (*LockResponse) Descriptor() ([]byte, []int)
- func (m *LockResponse) GetHeader() *headers.ResponseHeader
- func (m *LockResponse) GetVersion() uint64
- func (m *LockResponse) Marshal() (dAtA []byte, err error)
- func (m *LockResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *LockResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LockResponse) ProtoMessage()
- func (m *LockResponse) Reset()
- func (m *LockResponse) Size() (n int)
- func (m *LockResponse) String() string
- func (m *LockResponse) Unmarshal(dAtA []byte) error
- func (m *LockResponse) XXX_DiscardUnknown()
- func (m *LockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LockResponse) XXX_Merge(src proto.Message)
- func (m *LockResponse) XXX_Size() int
- func (m *LockResponse) XXX_Unmarshal(b []byte) error
- type LockServiceClient
- type LockServiceServer
- type UnimplementedLockServiceServer
- func (*UnimplementedLockServiceServer) Close(ctx context.Context, req *CloseRequest) (*CloseResponse, error)
- func (*UnimplementedLockServiceServer) Create(ctx context.Context, req *CreateRequest) (*CreateResponse, error)
- func (*UnimplementedLockServiceServer) IsLocked(ctx context.Context, req *IsLockedRequest) (*IsLockedResponse, error)
- func (*UnimplementedLockServiceServer) KeepAlive(ctx context.Context, req *KeepAliveRequest) (*KeepAliveResponse, error)
- func (*UnimplementedLockServiceServer) Lock(ctx context.Context, req *LockRequest) (*LockResponse, error)
- func (*UnimplementedLockServiceServer) Unlock(ctx context.Context, req *UnlockRequest) (*UnlockResponse, error)
- type UnlockRequest
- func (*UnlockRequest) Descriptor() ([]byte, []int)
- func (m *UnlockRequest) GetHeader() *headers.RequestHeader
- func (m *UnlockRequest) GetVersion() uint64
- func (m *UnlockRequest) Marshal() (dAtA []byte, err error)
- func (m *UnlockRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *UnlockRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UnlockRequest) ProtoMessage()
- func (m *UnlockRequest) Reset()
- func (m *UnlockRequest) Size() (n int)
- func (m *UnlockRequest) String() string
- func (m *UnlockRequest) Unmarshal(dAtA []byte) error
- func (m *UnlockRequest) XXX_DiscardUnknown()
- func (m *UnlockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UnlockRequest) XXX_Merge(src proto.Message)
- func (m *UnlockRequest) XXX_Size() int
- func (m *UnlockRequest) XXX_Unmarshal(b []byte) error
- type UnlockResponse
- func (*UnlockResponse) Descriptor() ([]byte, []int)
- func (m *UnlockResponse) GetHeader() *headers.ResponseHeader
- func (m *UnlockResponse) GetUnlocked() bool
- func (m *UnlockResponse) Marshal() (dAtA []byte, err error)
- func (m *UnlockResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *UnlockResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UnlockResponse) ProtoMessage()
- func (m *UnlockResponse) Reset()
- func (m *UnlockResponse) Size() (n int)
- func (m *UnlockResponse) String() string
- func (m *UnlockResponse) Unmarshal(dAtA []byte) error
- func (m *UnlockResponse) XXX_DiscardUnknown()
- func (m *UnlockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UnlockResponse) XXX_Merge(src proto.Message)
- func (m *UnlockResponse) XXX_Size() int
- func (m *UnlockResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func RegisterLockServiceServer ¶
func RegisterLockServiceServer(s *grpc.Server, srv LockServiceServer)
Types ¶
type CloseRequest ¶
type CloseRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Delete bool `protobuf:"varint,2,opt,name=delete,proto3" json:"delete,omitempty"` }
func (*CloseRequest) Descriptor ¶
func (*CloseRequest) Descriptor() ([]byte, []int)
func (*CloseRequest) GetDelete ¶
func (m *CloseRequest) GetDelete() bool
func (*CloseRequest) GetHeader ¶
func (m *CloseRequest) GetHeader() *headers.RequestHeader
func (*CloseRequest) Marshal ¶
func (m *CloseRequest) Marshal() (dAtA []byte, err error)
func (*CloseRequest) MarshalToSizedBuffer ¶
func (m *CloseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CloseRequest) ProtoMessage ¶
func (*CloseRequest) ProtoMessage()
func (*CloseRequest) Reset ¶
func (m *CloseRequest) Reset()
func (*CloseRequest) Size ¶
func (m *CloseRequest) Size() (n int)
func (*CloseRequest) String ¶
func (m *CloseRequest) String() string
func (*CloseRequest) Unmarshal ¶
func (m *CloseRequest) Unmarshal(dAtA []byte) error
func (*CloseRequest) XXX_DiscardUnknown ¶
func (m *CloseRequest) XXX_DiscardUnknown()
func (*CloseRequest) XXX_Marshal ¶
func (m *CloseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CloseRequest) XXX_Merge ¶
func (m *CloseRequest) XXX_Merge(src proto.Message)
func (*CloseRequest) XXX_Size ¶
func (m *CloseRequest) XXX_Size() int
func (*CloseRequest) XXX_Unmarshal ¶
func (m *CloseRequest) XXX_Unmarshal(b []byte) error
type CloseResponse ¶
type CloseResponse struct {
Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*CloseResponse) Descriptor ¶
func (*CloseResponse) Descriptor() ([]byte, []int)
func (*CloseResponse) GetHeader ¶
func (m *CloseResponse) GetHeader() *headers.ResponseHeader
func (*CloseResponse) Marshal ¶
func (m *CloseResponse) Marshal() (dAtA []byte, err error)
func (*CloseResponse) MarshalToSizedBuffer ¶
func (m *CloseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CloseResponse) ProtoMessage ¶
func (*CloseResponse) ProtoMessage()
func (*CloseResponse) Reset ¶
func (m *CloseResponse) Reset()
func (*CloseResponse) Size ¶
func (m *CloseResponse) Size() (n int)
func (*CloseResponse) String ¶
func (m *CloseResponse) String() string
func (*CloseResponse) Unmarshal ¶
func (m *CloseResponse) Unmarshal(dAtA []byte) error
func (*CloseResponse) XXX_DiscardUnknown ¶
func (m *CloseResponse) XXX_DiscardUnknown()
func (*CloseResponse) XXX_Marshal ¶
func (m *CloseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CloseResponse) XXX_Merge ¶
func (m *CloseResponse) XXX_Merge(src proto.Message)
func (*CloseResponse) XXX_Size ¶
func (m *CloseResponse) XXX_Size() int
func (*CloseResponse) XXX_Unmarshal ¶
func (m *CloseResponse) XXX_Unmarshal(b []byte) error
type CreateRequest ¶
type CreateRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Timeout *time.Duration `protobuf:"bytes,2,opt,name=timeout,proto3,stdduration" json:"timeout,omitempty"` }
func (*CreateRequest) Descriptor ¶
func (*CreateRequest) Descriptor() ([]byte, []int)
func (*CreateRequest) GetHeader ¶
func (m *CreateRequest) GetHeader() *headers.RequestHeader
func (*CreateRequest) GetTimeout ¶
func (m *CreateRequest) GetTimeout() *time.Duration
func (*CreateRequest) Marshal ¶
func (m *CreateRequest) Marshal() (dAtA []byte, err error)
func (*CreateRequest) MarshalToSizedBuffer ¶
func (m *CreateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateRequest) ProtoMessage ¶
func (*CreateRequest) ProtoMessage()
func (*CreateRequest) Reset ¶
func (m *CreateRequest) Reset()
func (*CreateRequest) Size ¶
func (m *CreateRequest) Size() (n int)
func (*CreateRequest) String ¶
func (m *CreateRequest) String() string
func (*CreateRequest) Unmarshal ¶
func (m *CreateRequest) Unmarshal(dAtA []byte) error
func (*CreateRequest) XXX_DiscardUnknown ¶
func (m *CreateRequest) XXX_DiscardUnknown()
func (*CreateRequest) XXX_Marshal ¶
func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateRequest) XXX_Merge ¶
func (m *CreateRequest) XXX_Merge(src proto.Message)
func (*CreateRequest) XXX_Size ¶
func (m *CreateRequest) XXX_Size() int
func (*CreateRequest) XXX_Unmarshal ¶
func (m *CreateRequest) XXX_Unmarshal(b []byte) error
type CreateResponse ¶
type CreateResponse struct {
Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*CreateResponse) Descriptor ¶
func (*CreateResponse) Descriptor() ([]byte, []int)
func (*CreateResponse) GetHeader ¶
func (m *CreateResponse) GetHeader() *headers.ResponseHeader
func (*CreateResponse) Marshal ¶
func (m *CreateResponse) Marshal() (dAtA []byte, err error)
func (*CreateResponse) MarshalToSizedBuffer ¶
func (m *CreateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateResponse) ProtoMessage ¶
func (*CreateResponse) ProtoMessage()
func (*CreateResponse) Reset ¶
func (m *CreateResponse) Reset()
func (*CreateResponse) Size ¶
func (m *CreateResponse) Size() (n int)
func (*CreateResponse) String ¶
func (m *CreateResponse) String() string
func (*CreateResponse) Unmarshal ¶
func (m *CreateResponse) Unmarshal(dAtA []byte) error
func (*CreateResponse) XXX_DiscardUnknown ¶
func (m *CreateResponse) XXX_DiscardUnknown()
func (*CreateResponse) XXX_Marshal ¶
func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateResponse) XXX_Merge ¶
func (m *CreateResponse) XXX_Merge(src proto.Message)
func (*CreateResponse) XXX_Size ¶
func (m *CreateResponse) XXX_Size() int
func (*CreateResponse) XXX_Unmarshal ¶
func (m *CreateResponse) XXX_Unmarshal(b []byte) error
type IsLockedRequest ¶
type IsLockedRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` }
func (*IsLockedRequest) Descriptor ¶
func (*IsLockedRequest) Descriptor() ([]byte, []int)
func (*IsLockedRequest) GetHeader ¶
func (m *IsLockedRequest) GetHeader() *headers.RequestHeader
func (*IsLockedRequest) GetVersion ¶
func (m *IsLockedRequest) GetVersion() uint64
func (*IsLockedRequest) Marshal ¶
func (m *IsLockedRequest) Marshal() (dAtA []byte, err error)
func (*IsLockedRequest) MarshalToSizedBuffer ¶
func (m *IsLockedRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*IsLockedRequest) ProtoMessage ¶
func (*IsLockedRequest) ProtoMessage()
func (*IsLockedRequest) Reset ¶
func (m *IsLockedRequest) Reset()
func (*IsLockedRequest) Size ¶
func (m *IsLockedRequest) Size() (n int)
func (*IsLockedRequest) String ¶
func (m *IsLockedRequest) String() string
func (*IsLockedRequest) Unmarshal ¶
func (m *IsLockedRequest) Unmarshal(dAtA []byte) error
func (*IsLockedRequest) XXX_DiscardUnknown ¶
func (m *IsLockedRequest) XXX_DiscardUnknown()
func (*IsLockedRequest) XXX_Marshal ¶
func (m *IsLockedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IsLockedRequest) XXX_Merge ¶
func (m *IsLockedRequest) XXX_Merge(src proto.Message)
func (*IsLockedRequest) XXX_Size ¶
func (m *IsLockedRequest) XXX_Size() int
func (*IsLockedRequest) XXX_Unmarshal ¶
func (m *IsLockedRequest) XXX_Unmarshal(b []byte) error
type IsLockedResponse ¶
type IsLockedResponse struct { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` IsLocked bool `protobuf:"varint,2,opt,name=isLocked,proto3" json:"isLocked,omitempty"` }
func (*IsLockedResponse) Descriptor ¶
func (*IsLockedResponse) Descriptor() ([]byte, []int)
func (*IsLockedResponse) GetHeader ¶
func (m *IsLockedResponse) GetHeader() *headers.ResponseHeader
func (*IsLockedResponse) GetIsLocked ¶
func (m *IsLockedResponse) GetIsLocked() bool
func (*IsLockedResponse) Marshal ¶
func (m *IsLockedResponse) Marshal() (dAtA []byte, err error)
func (*IsLockedResponse) MarshalToSizedBuffer ¶
func (m *IsLockedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*IsLockedResponse) ProtoMessage ¶
func (*IsLockedResponse) ProtoMessage()
func (*IsLockedResponse) Reset ¶
func (m *IsLockedResponse) Reset()
func (*IsLockedResponse) Size ¶
func (m *IsLockedResponse) Size() (n int)
func (*IsLockedResponse) String ¶
func (m *IsLockedResponse) String() string
func (*IsLockedResponse) Unmarshal ¶
func (m *IsLockedResponse) Unmarshal(dAtA []byte) error
func (*IsLockedResponse) XXX_DiscardUnknown ¶
func (m *IsLockedResponse) XXX_DiscardUnknown()
func (*IsLockedResponse) XXX_Marshal ¶
func (m *IsLockedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IsLockedResponse) XXX_Merge ¶
func (m *IsLockedResponse) XXX_Merge(src proto.Message)
func (*IsLockedResponse) XXX_Size ¶
func (m *IsLockedResponse) XXX_Size() int
func (*IsLockedResponse) XXX_Unmarshal ¶
func (m *IsLockedResponse) XXX_Unmarshal(b []byte) error
type KeepAliveRequest ¶
type KeepAliveRequest struct {
Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*KeepAliveRequest) Descriptor ¶
func (*KeepAliveRequest) Descriptor() ([]byte, []int)
func (*KeepAliveRequest) GetHeader ¶
func (m *KeepAliveRequest) GetHeader() *headers.RequestHeader
func (*KeepAliveRequest) Marshal ¶
func (m *KeepAliveRequest) Marshal() (dAtA []byte, err error)
func (*KeepAliveRequest) MarshalToSizedBuffer ¶
func (m *KeepAliveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KeepAliveRequest) ProtoMessage ¶
func (*KeepAliveRequest) ProtoMessage()
func (*KeepAliveRequest) Reset ¶
func (m *KeepAliveRequest) Reset()
func (*KeepAliveRequest) Size ¶
func (m *KeepAliveRequest) Size() (n int)
func (*KeepAliveRequest) String ¶
func (m *KeepAliveRequest) String() string
func (*KeepAliveRequest) Unmarshal ¶
func (m *KeepAliveRequest) Unmarshal(dAtA []byte) error
func (*KeepAliveRequest) XXX_DiscardUnknown ¶
func (m *KeepAliveRequest) XXX_DiscardUnknown()
func (*KeepAliveRequest) XXX_Marshal ¶
func (m *KeepAliveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KeepAliveRequest) XXX_Merge ¶
func (m *KeepAliveRequest) XXX_Merge(src proto.Message)
func (*KeepAliveRequest) XXX_Size ¶
func (m *KeepAliveRequest) XXX_Size() int
func (*KeepAliveRequest) XXX_Unmarshal ¶
func (m *KeepAliveRequest) XXX_Unmarshal(b []byte) error
type KeepAliveResponse ¶
type KeepAliveResponse struct {
Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*KeepAliveResponse) Descriptor ¶
func (*KeepAliveResponse) Descriptor() ([]byte, []int)
func (*KeepAliveResponse) GetHeader ¶
func (m *KeepAliveResponse) GetHeader() *headers.ResponseHeader
func (*KeepAliveResponse) Marshal ¶
func (m *KeepAliveResponse) Marshal() (dAtA []byte, err error)
func (*KeepAliveResponse) MarshalTo ¶
func (m *KeepAliveResponse) MarshalTo(dAtA []byte) (int, error)
func (*KeepAliveResponse) MarshalToSizedBuffer ¶
func (m *KeepAliveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KeepAliveResponse) ProtoMessage ¶
func (*KeepAliveResponse) ProtoMessage()
func (*KeepAliveResponse) Reset ¶
func (m *KeepAliveResponse) Reset()
func (*KeepAliveResponse) Size ¶
func (m *KeepAliveResponse) Size() (n int)
func (*KeepAliveResponse) String ¶
func (m *KeepAliveResponse) String() string
func (*KeepAliveResponse) Unmarshal ¶
func (m *KeepAliveResponse) Unmarshal(dAtA []byte) error
func (*KeepAliveResponse) XXX_DiscardUnknown ¶
func (m *KeepAliveResponse) XXX_DiscardUnknown()
func (*KeepAliveResponse) XXX_Marshal ¶
func (m *KeepAliveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KeepAliveResponse) XXX_Merge ¶
func (m *KeepAliveResponse) XXX_Merge(src proto.Message)
func (*KeepAliveResponse) XXX_Size ¶
func (m *KeepAliveResponse) XXX_Size() int
func (*KeepAliveResponse) XXX_Unmarshal ¶
func (m *KeepAliveResponse) XXX_Unmarshal(b []byte) error
type LockRequest ¶
type LockRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Timeout *time.Duration `protobuf:"bytes,2,opt,name=timeout,proto3,stdduration" json:"timeout,omitempty"` }
func (*LockRequest) Descriptor ¶
func (*LockRequest) Descriptor() ([]byte, []int)
func (*LockRequest) GetHeader ¶
func (m *LockRequest) GetHeader() *headers.RequestHeader
func (*LockRequest) GetTimeout ¶
func (m *LockRequest) GetTimeout() *time.Duration
func (*LockRequest) Marshal ¶
func (m *LockRequest) Marshal() (dAtA []byte, err error)
func (*LockRequest) MarshalToSizedBuffer ¶
func (m *LockRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LockRequest) ProtoMessage ¶
func (*LockRequest) ProtoMessage()
func (*LockRequest) Reset ¶
func (m *LockRequest) Reset()
func (*LockRequest) Size ¶
func (m *LockRequest) Size() (n int)
func (*LockRequest) String ¶
func (m *LockRequest) String() string
func (*LockRequest) Unmarshal ¶
func (m *LockRequest) Unmarshal(dAtA []byte) error
func (*LockRequest) XXX_DiscardUnknown ¶
func (m *LockRequest) XXX_DiscardUnknown()
func (*LockRequest) XXX_Marshal ¶
func (m *LockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LockRequest) XXX_Merge ¶
func (m *LockRequest) XXX_Merge(src proto.Message)
func (*LockRequest) XXX_Size ¶
func (m *LockRequest) XXX_Size() int
func (*LockRequest) XXX_Unmarshal ¶
func (m *LockRequest) XXX_Unmarshal(b []byte) error
type LockResponse ¶
type LockResponse struct { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` }
func (*LockResponse) Descriptor ¶
func (*LockResponse) Descriptor() ([]byte, []int)
func (*LockResponse) GetHeader ¶
func (m *LockResponse) GetHeader() *headers.ResponseHeader
func (*LockResponse) GetVersion ¶
func (m *LockResponse) GetVersion() uint64
func (*LockResponse) Marshal ¶
func (m *LockResponse) Marshal() (dAtA []byte, err error)
func (*LockResponse) MarshalToSizedBuffer ¶
func (m *LockResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LockResponse) ProtoMessage ¶
func (*LockResponse) ProtoMessage()
func (*LockResponse) Reset ¶
func (m *LockResponse) Reset()
func (*LockResponse) Size ¶
func (m *LockResponse) Size() (n int)
func (*LockResponse) String ¶
func (m *LockResponse) String() string
func (*LockResponse) Unmarshal ¶
func (m *LockResponse) Unmarshal(dAtA []byte) error
func (*LockResponse) XXX_DiscardUnknown ¶
func (m *LockResponse) XXX_DiscardUnknown()
func (*LockResponse) XXX_Marshal ¶
func (m *LockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LockResponse) XXX_Merge ¶
func (m *LockResponse) XXX_Merge(src proto.Message)
func (*LockResponse) XXX_Size ¶
func (m *LockResponse) XXX_Size() int
func (*LockResponse) XXX_Unmarshal ¶
func (m *LockResponse) XXX_Unmarshal(b []byte) error
type LockServiceClient ¶
type LockServiceClient interface { Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) KeepAlive(ctx context.Context, in *KeepAliveRequest, opts ...grpc.CallOption) (*KeepAliveResponse, error) Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error) Lock(ctx context.Context, in *LockRequest, opts ...grpc.CallOption) (*LockResponse, error) Unlock(ctx context.Context, in *UnlockRequest, opts ...grpc.CallOption) (*UnlockResponse, error) IsLocked(ctx context.Context, in *IsLockedRequest, opts ...grpc.CallOption) (*IsLockedResponse, error) }
LockServiceClient is the client API for LockService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewLockServiceClient ¶
func NewLockServiceClient(cc *grpc.ClientConn) LockServiceClient
type LockServiceServer ¶
type LockServiceServer interface { Create(context.Context, *CreateRequest) (*CreateResponse, error) KeepAlive(context.Context, *KeepAliveRequest) (*KeepAliveResponse, error) Close(context.Context, *CloseRequest) (*CloseResponse, error) Lock(context.Context, *LockRequest) (*LockResponse, error) Unlock(context.Context, *UnlockRequest) (*UnlockResponse, error) IsLocked(context.Context, *IsLockedRequest) (*IsLockedResponse, error) }
LockServiceServer is the server API for LockService service.
type UnimplementedLockServiceServer ¶
type UnimplementedLockServiceServer struct { }
UnimplementedLockServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedLockServiceServer) Close ¶
func (*UnimplementedLockServiceServer) Close(ctx context.Context, req *CloseRequest) (*CloseResponse, error)
func (*UnimplementedLockServiceServer) Create ¶
func (*UnimplementedLockServiceServer) Create(ctx context.Context, req *CreateRequest) (*CreateResponse, error)
func (*UnimplementedLockServiceServer) IsLocked ¶
func (*UnimplementedLockServiceServer) IsLocked(ctx context.Context, req *IsLockedRequest) (*IsLockedResponse, error)
func (*UnimplementedLockServiceServer) KeepAlive ¶
func (*UnimplementedLockServiceServer) KeepAlive(ctx context.Context, req *KeepAliveRequest) (*KeepAliveResponse, error)
func (*UnimplementedLockServiceServer) Lock ¶
func (*UnimplementedLockServiceServer) Lock(ctx context.Context, req *LockRequest) (*LockResponse, error)
func (*UnimplementedLockServiceServer) Unlock ¶
func (*UnimplementedLockServiceServer) Unlock(ctx context.Context, req *UnlockRequest) (*UnlockResponse, error)
type UnlockRequest ¶
type UnlockRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` }
func (*UnlockRequest) Descriptor ¶
func (*UnlockRequest) Descriptor() ([]byte, []int)
func (*UnlockRequest) GetHeader ¶
func (m *UnlockRequest) GetHeader() *headers.RequestHeader
func (*UnlockRequest) GetVersion ¶
func (m *UnlockRequest) GetVersion() uint64
func (*UnlockRequest) Marshal ¶
func (m *UnlockRequest) Marshal() (dAtA []byte, err error)
func (*UnlockRequest) MarshalToSizedBuffer ¶
func (m *UnlockRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UnlockRequest) ProtoMessage ¶
func (*UnlockRequest) ProtoMessage()
func (*UnlockRequest) Reset ¶
func (m *UnlockRequest) Reset()
func (*UnlockRequest) Size ¶
func (m *UnlockRequest) Size() (n int)
func (*UnlockRequest) String ¶
func (m *UnlockRequest) String() string
func (*UnlockRequest) Unmarshal ¶
func (m *UnlockRequest) Unmarshal(dAtA []byte) error
func (*UnlockRequest) XXX_DiscardUnknown ¶
func (m *UnlockRequest) XXX_DiscardUnknown()
func (*UnlockRequest) XXX_Marshal ¶
func (m *UnlockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UnlockRequest) XXX_Merge ¶
func (m *UnlockRequest) XXX_Merge(src proto.Message)
func (*UnlockRequest) XXX_Size ¶
func (m *UnlockRequest) XXX_Size() int
func (*UnlockRequest) XXX_Unmarshal ¶
func (m *UnlockRequest) XXX_Unmarshal(b []byte) error
type UnlockResponse ¶
type UnlockResponse struct { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Unlocked bool `protobuf:"varint,2,opt,name=unlocked,proto3" json:"unlocked,omitempty"` }
func (*UnlockResponse) Descriptor ¶
func (*UnlockResponse) Descriptor() ([]byte, []int)
func (*UnlockResponse) GetHeader ¶
func (m *UnlockResponse) GetHeader() *headers.ResponseHeader
func (*UnlockResponse) GetUnlocked ¶
func (m *UnlockResponse) GetUnlocked() bool
func (*UnlockResponse) Marshal ¶
func (m *UnlockResponse) Marshal() (dAtA []byte, err error)
func (*UnlockResponse) MarshalToSizedBuffer ¶
func (m *UnlockResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UnlockResponse) ProtoMessage ¶
func (*UnlockResponse) ProtoMessage()
func (*UnlockResponse) Reset ¶
func (m *UnlockResponse) Reset()
func (*UnlockResponse) Size ¶
func (m *UnlockResponse) Size() (n int)
func (*UnlockResponse) String ¶
func (m *UnlockResponse) String() string
func (*UnlockResponse) Unmarshal ¶
func (m *UnlockResponse) Unmarshal(dAtA []byte) error
func (*UnlockResponse) XXX_DiscardUnknown ¶
func (m *UnlockResponse) XXX_DiscardUnknown()
func (*UnlockResponse) XXX_Marshal ¶
func (m *UnlockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UnlockResponse) XXX_Merge ¶
func (m *UnlockResponse) XXX_Merge(src proto.Message)
func (*UnlockResponse) XXX_Size ¶
func (m *UnlockResponse) XXX_Size() int
func (*UnlockResponse) XXX_Unmarshal ¶
func (m *UnlockResponse) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.