lock

package
v0.8.0 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2021 License: Apache-2.0 Imports: 18 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthManager        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowManager          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupManager = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthPrimitive        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPrimitive          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPrimitive = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var LockInstance_State_name = map[int32]string{
	0: "UNLOCKED",
	1: "LOCKED",
}
View Source 
var LockInstance_State_value = map[string]int32{
	"UNLOCKED": 0,
	"LOCKED":   1,
}

Functions

func RegisterLockManagerServer added in v0.7.0 

func RegisterLockManagerServer(s *grpc.Server, srv LockManagerServer)

func RegisterLockServer 

func RegisterLockServer(s *grpc.Server, srv LockServer)

Types

type CloseSessionRequest 

type CloseSessionRequest struct {
	SessionID github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID `` /* 160-byte string literal not displayed */
}

func (*CloseSessionRequest) Descriptor 

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

func (*CloseSessionRequest) GetSessionID 

func (m *CloseSessionRequest) GetSessionID() github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID

func (*CloseSessionRequest) Marshal 

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

func (*CloseSessionRequest) MarshalTo 

func (m *CloseSessionRequest) MarshalTo(dAtA []byte) (int, error)

func (*CloseSessionRequest) MarshalToSizedBuffer 

func (m *CloseSessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CloseSessionRequest) ProtoMessage 

func (*CloseSessionRequest) ProtoMessage()

func (*CloseSessionRequest) Reset 

func (m *CloseSessionRequest) Reset()

func (*CloseSessionRequest) Size 

func (m *CloseSessionRequest) Size() (n int)

func (*CloseSessionRequest) String 

func (m *CloseSessionRequest) String() string

func (*CloseSessionRequest) Unmarshal 

func (m *CloseSessionRequest) Unmarshal(dAtA []byte) error

func (*CloseSessionRequest) XXX_DiscardUnknown 

func (m *CloseSessionRequest) XXX_DiscardUnknown()

func (*CloseSessionRequest) XXX_Marshal 

func (m *CloseSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CloseSessionRequest) XXX_Merge 

func (m *CloseSessionRequest) XXX_Merge(src proto.Message)

func (*CloseSessionRequest) XXX_Size 

func (m *CloseSessionRequest) XXX_Size() int

func (*CloseSessionRequest) XXX_Unmarshal 

func (m *CloseSessionRequest) XXX_Unmarshal(b []byte) error

type CloseSessionResponse 

type CloseSessionResponse struct {
}

func (*CloseSessionResponse) Descriptor 

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

func (*CloseSessionResponse) Marshal 

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

func (*CloseSessionResponse) MarshalTo 

func (m *CloseSessionResponse) MarshalTo(dAtA []byte) (int, error)

func (*CloseSessionResponse) MarshalToSizedBuffer 

func (m *CloseSessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CloseSessionResponse) ProtoMessage 

func (*CloseSessionResponse) ProtoMessage()

func (*CloseSessionResponse) Reset 

func (m *CloseSessionResponse) Reset()

func (*CloseSessionResponse) Size 

func (m *CloseSessionResponse) Size() (n int)

func (*CloseSessionResponse) String 

func (m *CloseSessionResponse) String() string

func (*CloseSessionResponse) Unmarshal 

func (m *CloseSessionResponse) Unmarshal(dAtA []byte) error

func (*CloseSessionResponse) XXX_DiscardUnknown 

func (m *CloseSessionResponse) XXX_DiscardUnknown()

func (*CloseSessionResponse) XXX_Marshal 

func (m *CloseSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CloseSessionResponse) XXX_Merge 

func (m *CloseSessionResponse) XXX_Merge(src proto.Message)

func (*CloseSessionResponse) XXX_Size 

func (m *CloseSessionResponse) XXX_Size() int

func (*CloseSessionResponse) XXX_Unmarshal 

func (m *CloseSessionResponse) XXX_Unmarshal(b []byte) error

type GetLockRequest 

type GetLockRequest struct {
	Lock LockInstance `protobuf:"bytes,2,opt,name=lock,proto3" json:"lock"`
}

func (*GetLockRequest) Descriptor 

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

func (*GetLockRequest) GetLock 

func (m *GetLockRequest) GetLock() LockInstance

func (*GetLockRequest) Marshal 

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

func (*GetLockRequest) MarshalTo 

func (m *GetLockRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetLockRequest) MarshalToSizedBuffer 

func (m *GetLockRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetLockRequest) ProtoMessage 

func (*GetLockRequest) ProtoMessage()

func (*GetLockRequest) Reset 

func (m *GetLockRequest) Reset()

func (*GetLockRequest) Size 

func (m *GetLockRequest) Size() (n int)

func (*GetLockRequest) String 

func (m *GetLockRequest) String() string

func (*GetLockRequest) Unmarshal 

func (m *GetLockRequest) Unmarshal(dAtA []byte) error

func (*GetLockRequest) XXX_DiscardUnknown 

func (m *GetLockRequest) XXX_DiscardUnknown()

func (*GetLockRequest) XXX_Marshal 

func (m *GetLockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetLockRequest) XXX_Merge 

func (m *GetLockRequest) XXX_Merge(src proto.Message)

func (*GetLockRequest) XXX_Size 

func (m *GetLockRequest) XXX_Size() int

func (*GetLockRequest) XXX_Unmarshal 

func (m *GetLockRequest) XXX_Unmarshal(b []byte) error

type GetLockResponse 

type GetLockResponse struct {
	Lock LockInstance `protobuf:"bytes,2,opt,name=lock,proto3" json:"lock"`
}

func (*GetLockResponse) Descriptor 

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

func (*GetLockResponse) GetLock 

func (m *GetLockResponse) GetLock() LockInstance

func (*GetLockResponse) Marshal 

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

func (*GetLockResponse) MarshalTo 

func (m *GetLockResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetLockResponse) MarshalToSizedBuffer 

func (m *GetLockResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetLockResponse) ProtoMessage 

func (*GetLockResponse) ProtoMessage()

func (*GetLockResponse) Reset 

func (m *GetLockResponse) Reset()

func (*GetLockResponse) Size 

func (m *GetLockResponse) Size() (n int)

func (*GetLockResponse) String 

func (m *GetLockResponse) String() string

func (*GetLockResponse) Unmarshal 

func (m *GetLockResponse) Unmarshal(dAtA []byte) error

func (*GetLockResponse) XXX_DiscardUnknown 

func (m *GetLockResponse) XXX_DiscardUnknown()

func (*GetLockResponse) XXX_Marshal 

func (m *GetLockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetLockResponse) XXX_Merge 

func (m *GetLockResponse) XXX_Merge(src proto.Message)

func (*GetLockResponse) XXX_Size 

func (m *GetLockResponse) XXX_Size() int

func (*GetLockResponse) XXX_Unmarshal 

func (m *GetLockResponse) XXX_Unmarshal(b []byte) error

type LockClient 

type LockClient interface {
	// 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)
	// GetLock gets the lock state
	GetLock(ctx context.Context, in *GetLockRequest, opts ...grpc.CallOption) (*GetLockResponse, error)
}

LockClient is the client API for Lock service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewLockClient 

func NewLockClient(cc *grpc.ClientConn) LockClient

type LockInstance 

type LockInstance struct {
	v1.ObjectMeta `protobuf:"bytes,1,opt,name=meta,proto3,embedded=meta" json:"meta"`
	State         LockInstance_State `protobuf:"varint,2,opt,name=state,proto3,enum=atomix.primitive.lock.v1.LockInstance_State" json:"state,omitempty"`
}

func (*LockInstance) Descriptor 

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

func (*LockInstance) GetState 

func (m *LockInstance) GetState() LockInstance_State

func (*LockInstance) Marshal 

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

func (*LockInstance) MarshalTo 

func (m *LockInstance) MarshalTo(dAtA []byte) (int, error)

func (*LockInstance) MarshalToSizedBuffer 

func (m *LockInstance) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LockInstance) ProtoMessage 

func (*LockInstance) ProtoMessage()

func (*LockInstance) Reset 

func (m *LockInstance) Reset()

func (*LockInstance) Size 

func (m *LockInstance) Size() (n int)

func (*LockInstance) String 

func (m *LockInstance) String() string

func (*LockInstance) Unmarshal 

func (m *LockInstance) Unmarshal(dAtA []byte) error

func (*LockInstance) XXX_DiscardUnknown 

func (m *LockInstance) XXX_DiscardUnknown()

func (*LockInstance) XXX_Marshal 

func (m *LockInstance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LockInstance) XXX_Merge 

func (m *LockInstance) XXX_Merge(src proto.Message)

func (*LockInstance) XXX_Size 

func (m *LockInstance) XXX_Size() int

func (*LockInstance) XXX_Unmarshal 

func (m *LockInstance) XXX_Unmarshal(b []byte) error

type LockInstance_State 

type LockInstance_State int32
const (
	LockInstance_UNLOCKED LockInstance_State = 0
	LockInstance_LOCKED   LockInstance_State = 1
)

func (LockInstance_State) EnumDescriptor 

func (LockInstance_State) EnumDescriptor() ([]byte, []int)

func (LockInstance_State) String 

func (x LockInstance_State) String() string

type LockManagerClient added in v0.7.0 

type LockManagerClient interface {
	OpenSession(ctx context.Context, in *OpenSessionRequest, opts ...grpc.CallOption) (*OpenSessionResponse, error)
	CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error)
}

LockManagerClient is the client API for LockManager service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewLockManagerClient added in v0.7.0 

func NewLockManagerClient(cc *grpc.ClientConn) LockManagerClient

type LockManagerServer added in v0.7.0 

type LockManagerServer interface {
	OpenSession(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error)
	CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)
}

LockManagerServer is the server API for LockManager service.

type LockRequest 

type LockRequest struct {
	Timeout *time.Duration `protobuf:"bytes,2,opt,name=timeout,proto3,stdduration" json:"timeout,omitempty"`
}

func (*LockRequest) Descriptor 

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

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 {
	Lock LockInstance `protobuf:"bytes,2,opt,name=lock,proto3" json:"lock"`
}

func (*LockResponse) Descriptor 

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

func (*LockResponse) GetLock 

func (m *LockResponse) GetLock() LockInstance

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 LockServer 

type LockServer interface {
	// Lock attempts to acquire the lock
	Lock(context.Context, *LockRequest) (*LockResponse, error)
	// Unlock releases the lock
	Unlock(context.Context, *UnlockRequest) (*UnlockResponse, error)
	// GetLock gets the lock state
	GetLock(context.Context, *GetLockRequest) (*GetLockResponse, error)
}

LockServer is the server API for Lock service.

type LockSessionOptions 

type LockSessionOptions struct {
}

func (*LockSessionOptions) Descriptor 

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

func (*LockSessionOptions) Marshal 

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

func (*LockSessionOptions) MarshalTo 

func (m *LockSessionOptions) MarshalTo(dAtA []byte) (int, error)

func (*LockSessionOptions) MarshalToSizedBuffer 

func (m *LockSessionOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LockSessionOptions) ProtoMessage 

func (*LockSessionOptions) ProtoMessage()

func (*LockSessionOptions) Reset 

func (m *LockSessionOptions) Reset()

func (*LockSessionOptions) Size 

func (m *LockSessionOptions) Size() (n int)

func (*LockSessionOptions) String 

func (m *LockSessionOptions) String() string

func (*LockSessionOptions) Unmarshal 

func (m *LockSessionOptions) Unmarshal(dAtA []byte) error

func (*LockSessionOptions) XXX_DiscardUnknown 

func (m *LockSessionOptions) XXX_DiscardUnknown()

func (*LockSessionOptions) XXX_Marshal 

func (m *LockSessionOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LockSessionOptions) XXX_Merge 

func (m *LockSessionOptions) XXX_Merge(src proto.Message)

func (*LockSessionOptions) XXX_Size 

func (m *LockSessionOptions) XXX_Size() int

func (*LockSessionOptions) XXX_Unmarshal 

func (m *LockSessionOptions) XXX_Unmarshal(b []byte) error

type OpenSessionRequest 

type OpenSessionRequest struct {
	PrimitiveID github_com_atomix_atomix_api_go_atomix_primitive_v1.ID `` /* 158-byte string literal not displayed */
	Options     LockSessionOptions                                     `protobuf:"bytes,2,opt,name=options,proto3" json:"options"`
}

func (*OpenSessionRequest) Descriptor 

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

func (*OpenSessionRequest) GetOptions 

func (m *OpenSessionRequest) GetOptions() LockSessionOptions

func (*OpenSessionRequest) GetPrimitiveID 

func (m *OpenSessionRequest) GetPrimitiveID() github_com_atomix_atomix_api_go_atomix_primitive_v1.ID

func (*OpenSessionRequest) Marshal 

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

func (*OpenSessionRequest) MarshalTo 

func (m *OpenSessionRequest) MarshalTo(dAtA []byte) (int, error)

func (*OpenSessionRequest) MarshalToSizedBuffer 

func (m *OpenSessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OpenSessionRequest) ProtoMessage 

func (*OpenSessionRequest) ProtoMessage()

func (*OpenSessionRequest) Reset 

func (m *OpenSessionRequest) Reset()

func (*OpenSessionRequest) Size 

func (m *OpenSessionRequest) Size() (n int)

func (*OpenSessionRequest) String 

func (m *OpenSessionRequest) String() string

func (*OpenSessionRequest) Unmarshal 

func (m *OpenSessionRequest) Unmarshal(dAtA []byte) error

func (*OpenSessionRequest) XXX_DiscardUnknown 

func (m *OpenSessionRequest) XXX_DiscardUnknown()

func (*OpenSessionRequest) XXX_Marshal 

func (m *OpenSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OpenSessionRequest) XXX_Merge 

func (m *OpenSessionRequest) XXX_Merge(src proto.Message)

func (*OpenSessionRequest) XXX_Size 

func (m *OpenSessionRequest) XXX_Size() int

func (*OpenSessionRequest) XXX_Unmarshal 

func (m *OpenSessionRequest) XXX_Unmarshal(b []byte) error

type OpenSessionResponse 

type OpenSessionResponse struct {
	SessionID github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID `` /* 160-byte string literal not displayed */
}

func (*OpenSessionResponse) Descriptor 

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

func (*OpenSessionResponse) GetSessionID 

func (m *OpenSessionResponse) GetSessionID() github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID

func (*OpenSessionResponse) Marshal 

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

func (*OpenSessionResponse) MarshalTo 

func (m *OpenSessionResponse) MarshalTo(dAtA []byte) (int, error)

func (*OpenSessionResponse) MarshalToSizedBuffer 

func (m *OpenSessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OpenSessionResponse) ProtoMessage 

func (*OpenSessionResponse) ProtoMessage()

func (*OpenSessionResponse) Reset 

func (m *OpenSessionResponse) Reset()

func (*OpenSessionResponse) Size 

func (m *OpenSessionResponse) Size() (n int)

func (*OpenSessionResponse) String 

func (m *OpenSessionResponse) String() string

func (*OpenSessionResponse) Unmarshal 

func (m *OpenSessionResponse) Unmarshal(dAtA []byte) error

func (*OpenSessionResponse) XXX_DiscardUnknown 

func (m *OpenSessionResponse) XXX_DiscardUnknown()

func (*OpenSessionResponse) XXX_Marshal 

func (m *OpenSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OpenSessionResponse) XXX_Merge 

func (m *OpenSessionResponse) XXX_Merge(src proto.Message)

func (*OpenSessionResponse) XXX_Size 

func (m *OpenSessionResponse) XXX_Size() int

func (*OpenSessionResponse) XXX_Unmarshal 

func (m *OpenSessionResponse) XXX_Unmarshal(b []byte) error

type UnimplementedLockManagerServer added in v0.7.0 

type UnimplementedLockManagerServer struct {
}

UnimplementedLockManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedLockManagerServer) CloseSession added in v0.7.0 

func (*UnimplementedLockManagerServer) CloseSession(ctx context.Context, req *CloseSessionRequest) (*CloseSessionResponse, error)

func (*UnimplementedLockManagerServer) OpenSession added in v0.7.0 

func (*UnimplementedLockManagerServer) OpenSession(ctx context.Context, req *OpenSessionRequest) (*OpenSessionResponse, error)

type UnimplementedLockServer 

type UnimplementedLockServer struct {
}

UnimplementedLockServer can be embedded to have forward compatible implementations.

func (*UnimplementedLockServer) GetLock 

func (*UnimplementedLockServer) GetLock(ctx context.Context, req *GetLockRequest) (*GetLockResponse, error)

func (*UnimplementedLockServer) Lock 

func (*UnimplementedLockServer) Lock(ctx context.Context, req *LockRequest) (*LockResponse, error)

func (*UnimplementedLockServer) Unlock 

func (*UnimplementedLockServer) Unlock(ctx context.Context, req *UnlockRequest) (*UnlockResponse, error)

type UnlockRequest 

type UnlockRequest struct {
	Lock LockInstance `protobuf:"bytes,2,opt,name=lock,proto3" json:"lock"`
}

func (*UnlockRequest) Descriptor 

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

func (*UnlockRequest) GetLock 

func (m *UnlockRequest) GetLock() LockInstance

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 {
	Lock LockInstance `protobuf:"bytes,2,opt,name=lock,proto3" json:"lock"`
}

func (*UnlockResponse) Descriptor 

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

func (*UnlockResponse) GetLock 

func (m *UnlockResponse) GetLock() LockInstance

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.