Versions in this module Expand all Collapse all v1 v1.0.1 Sep 30, 2020 Changes in this version + var ErrIntOverflowV3Lock = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthV3Lock = fmt.Errorf("proto: negative length found during unmarshaling") + 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 + 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) Reset() + func (m *LockRequest) Size() (n int) + func (m *LockRequest) String() string + func (m *LockRequest) Unmarshal(dAtA []byte) error + type LockResponse struct + Header *etcdserverpb.ResponseHeader + Key []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) Reset() + func (m *LockResponse) Size() (n int) + func (m *LockResponse) String() string + func (m *LockResponse) Unmarshal(dAtA []byte) error + type LockServer interface + Lock func(context.Context, *LockRequest) (*LockResponse, error) + Unlock func(context.Context, *UnlockRequest) (*UnlockResponse, error) + type UnlockRequest struct + Key []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) Reset() + func (m *UnlockRequest) Size() (n int) + func (m *UnlockRequest) String() string + func (m *UnlockRequest) Unmarshal(dAtA []byte) error + type UnlockResponse struct + Header *etcdserverpb.ResponseHeader + 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) Reset() + func (m *UnlockResponse) Size() (n int) + func (m *UnlockResponse) String() string + func (m *UnlockResponse) Unmarshal(dAtA []byte) error Incompatible versions in this module v3.3.16+incompatible Oct 10, 2019
Go to main page