lock

package
v0.0.0-...-81cd5ce Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 29, 2020 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthLock        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLock          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLock = fmt.Errorf("proto: unexpected end of group")
)

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) MarshalTo 

func (m *CloseRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *CloseResponse) MarshalTo(dAtA []byte) (int, 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"`
}

func (*CreateRequest) Descriptor 

func (*CreateRequest) Descriptor() ([]byte, []int)

func (*CreateRequest) GetHeader 

func (m *CreateRequest) GetHeader() *headers.RequestHeader

func (*CreateRequest) Marshal 

func (m *CreateRequest) Marshal() (dAtA []byte, err error)

func (*CreateRequest) MarshalTo 

func (m *CreateRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *CreateResponse) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *IsLockedRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *IsLockedResponse) MarshalTo(dAtA []byte) (int, 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 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) MarshalTo 

func (m *LockRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *LockResponse) MarshalTo(dAtA []byte) (int, 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 creates a lock
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	// Close closes a lock
	Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error)
	// Lock attempts to acquire the lock
	Lock(ctx context.Context, in *LockRequest, opts ...grpc.CallOption) (*LockResponse, error)
	// Unlock releases the lock
	Unlock(ctx context.Context, in *UnlockRequest, opts ...grpc.CallOption) (*UnlockResponse, error)
	// IsLocked checks whether the lock is held
	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 creates a lock
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	// Close closes a lock
	Close(context.Context, *CloseRequest) (*CloseResponse, error)
	// Lock attempts to acquire the lock
	Lock(context.Context, *LockRequest) (*LockResponse, error)
	// Unlock releases the lock
	Unlock(context.Context, *UnlockRequest) (*UnlockResponse, error)
	// IsLocked checks whether the lock is held
	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) 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) MarshalTo 

func (m *UnlockRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *UnlockResponse) MarshalTo(dAtA []byte) (int, 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.