Versions in this module Expand all Collapse all v3 v3.4.15 Feb 24, 2021 Changes in this version + var ErrIntOverflowV3Lock = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthV3Lock = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupV3Lock = fmt.Errorf("proto: unexpected end of group") + func RegisterLockServer(s *grpc.Server, srv LockServer) + type LockClient interface + Lock func(ctx context.Context, in *LockRequest, opts ...grpc.CallOption) (*LockResponse, error) + Unlock func(ctx context.Context, in *UnlockRequest, opts ...grpc.CallOption) (*UnlockResponse, error) + func NewLockClient(cc *grpc.ClientConn) LockClient + type LockRequest struct + Lease int64 + Name []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LockRequest) Descriptor() ([]byte, []int) + func (*LockRequest) ProtoMessage() + func (m *LockRequest) GetLease() int64 + func (m *LockRequest) GetName() []byte + 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 (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 struct + Header *etcdserverpb.ResponseHeader + Key []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LockResponse) Descriptor() ([]byte, []int) + func (*LockResponse) ProtoMessage() + func (m *LockResponse) GetHeader() *etcdserverpb.ResponseHeader + func (m *LockResponse) GetKey() []byte + 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 (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 LockServer interface + Lock func(context.Context, *LockRequest) (*LockResponse, error) + Unlock func(context.Context, *UnlockRequest) (*UnlockResponse, error) + type UnimplementedLockServer struct + func (*UnimplementedLockServer) Lock(ctx context.Context, req *LockRequest) (*LockResponse, error) + func (*UnimplementedLockServer) Unlock(ctx context.Context, req *UnlockRequest) (*UnlockResponse, error) + type UnlockRequest struct + Key []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UnlockRequest) Descriptor() ([]byte, []int) + func (*UnlockRequest) ProtoMessage() + func (m *UnlockRequest) GetKey() []byte + 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 (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 struct + Header *etcdserverpb.ResponseHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UnlockResponse) Descriptor() ([]byte, []int) + func (*UnlockResponse) ProtoMessage() + func (m *UnlockResponse) GetHeader() *etcdserverpb.ResponseHeader + 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 (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
Go to main page