Documentation ¶
Index ¶
- Variables
- func RegisterLockManagerServer(s *grpc.Server, srv LockManagerServer)
- func RegisterLockServer(s *grpc.Server, srv LockServer)
- type CloseSessionRequest
- func (*CloseSessionRequest) Descriptor() ([]byte, []int)
- func (m *CloseSessionRequest) GetSessionID() github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID
- func (m *CloseSessionRequest) Marshal() (dAtA []byte, err error)
- func (m *CloseSessionRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CloseSessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CloseSessionRequest) ProtoMessage()
- func (m *CloseSessionRequest) Reset()
- func (m *CloseSessionRequest) Size() (n int)
- func (m *CloseSessionRequest) String() string
- func (m *CloseSessionRequest) Unmarshal(dAtA []byte) error
- func (m *CloseSessionRequest) XXX_DiscardUnknown()
- func (m *CloseSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloseSessionRequest) XXX_Merge(src proto.Message)
- func (m *CloseSessionRequest) XXX_Size() int
- func (m *CloseSessionRequest) XXX_Unmarshal(b []byte) error
- type CloseSessionResponse
- func (*CloseSessionResponse) Descriptor() ([]byte, []int)
- func (m *CloseSessionResponse) Marshal() (dAtA []byte, err error)
- func (m *CloseSessionResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CloseSessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CloseSessionResponse) ProtoMessage()
- func (m *CloseSessionResponse) Reset()
- func (m *CloseSessionResponse) Size() (n int)
- func (m *CloseSessionResponse) String() string
- func (m *CloseSessionResponse) Unmarshal(dAtA []byte) error
- func (m *CloseSessionResponse) XXX_DiscardUnknown()
- func (m *CloseSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloseSessionResponse) XXX_Merge(src proto.Message)
- func (m *CloseSessionResponse) XXX_Size() int
- func (m *CloseSessionResponse) XXX_Unmarshal(b []byte) error
- type GetLockRequest
- func (*GetLockRequest) Descriptor() ([]byte, []int)
- func (m *GetLockRequest) GetLock() LockInstance
- func (m *GetLockRequest) Marshal() (dAtA []byte, err error)
- func (m *GetLockRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetLockRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetLockRequest) ProtoMessage()
- func (m *GetLockRequest) Reset()
- func (m *GetLockRequest) Size() (n int)
- func (m *GetLockRequest) String() string
- func (m *GetLockRequest) Unmarshal(dAtA []byte) error
- func (m *GetLockRequest) XXX_DiscardUnknown()
- func (m *GetLockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetLockRequest) XXX_Merge(src proto.Message)
- func (m *GetLockRequest) XXX_Size() int
- func (m *GetLockRequest) XXX_Unmarshal(b []byte) error
- type GetLockResponse
- func (*GetLockResponse) Descriptor() ([]byte, []int)
- func (m *GetLockResponse) GetLock() LockInstance
- func (m *GetLockResponse) Marshal() (dAtA []byte, err error)
- func (m *GetLockResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetLockResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetLockResponse) ProtoMessage()
- func (m *GetLockResponse) Reset()
- func (m *GetLockResponse) Size() (n int)
- func (m *GetLockResponse) String() string
- func (m *GetLockResponse) Unmarshal(dAtA []byte) error
- func (m *GetLockResponse) XXX_DiscardUnknown()
- func (m *GetLockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetLockResponse) XXX_Merge(src proto.Message)
- func (m *GetLockResponse) XXX_Size() int
- func (m *GetLockResponse) XXX_Unmarshal(b []byte) error
- type LockClient
- type LockInstance
- func (*LockInstance) Descriptor() ([]byte, []int)
- func (m *LockInstance) GetState() LockInstance_State
- func (m *LockInstance) Marshal() (dAtA []byte, err error)
- func (m *LockInstance) MarshalTo(dAtA []byte) (int, error)
- func (m *LockInstance) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LockInstance) ProtoMessage()
- func (m *LockInstance) Reset()
- func (m *LockInstance) Size() (n int)
- func (m *LockInstance) String() string
- func (m *LockInstance) Unmarshal(dAtA []byte) error
- func (m *LockInstance) XXX_DiscardUnknown()
- func (m *LockInstance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LockInstance) XXX_Merge(src proto.Message)
- func (m *LockInstance) XXX_Size() int
- func (m *LockInstance) XXX_Unmarshal(b []byte) error
- type LockInstance_State
- type LockManagerClient
- type LockManagerServer
- type LockRequest
- func (*LockRequest) Descriptor() ([]byte, []int)
- 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) GetLock() LockInstance
- 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 LockServer
- type LockSessionOptions
- func (*LockSessionOptions) Descriptor() ([]byte, []int)
- func (m *LockSessionOptions) Marshal() (dAtA []byte, err error)
- func (m *LockSessionOptions) MarshalTo(dAtA []byte) (int, error)
- func (m *LockSessionOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LockSessionOptions) ProtoMessage()
- func (m *LockSessionOptions) Reset()
- func (m *LockSessionOptions) Size() (n int)
- func (m *LockSessionOptions) String() string
- func (m *LockSessionOptions) Unmarshal(dAtA []byte) error
- func (m *LockSessionOptions) XXX_DiscardUnknown()
- func (m *LockSessionOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LockSessionOptions) XXX_Merge(src proto.Message)
- func (m *LockSessionOptions) XXX_Size() int
- func (m *LockSessionOptions) XXX_Unmarshal(b []byte) error
- type OpenSessionRequest
- func (*OpenSessionRequest) Descriptor() ([]byte, []int)
- func (m *OpenSessionRequest) GetOptions() LockSessionOptions
- func (m *OpenSessionRequest) GetPrimitiveID() github_com_atomix_atomix_api_go_atomix_primitive_v1.ID
- func (m *OpenSessionRequest) Marshal() (dAtA []byte, err error)
- func (m *OpenSessionRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *OpenSessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OpenSessionRequest) ProtoMessage()
- func (m *OpenSessionRequest) Reset()
- func (m *OpenSessionRequest) Size() (n int)
- func (m *OpenSessionRequest) String() string
- func (m *OpenSessionRequest) Unmarshal(dAtA []byte) error
- func (m *OpenSessionRequest) XXX_DiscardUnknown()
- func (m *OpenSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OpenSessionRequest) XXX_Merge(src proto.Message)
- func (m *OpenSessionRequest) XXX_Size() int
- func (m *OpenSessionRequest) XXX_Unmarshal(b []byte) error
- type OpenSessionResponse
- func (*OpenSessionResponse) Descriptor() ([]byte, []int)
- func (m *OpenSessionResponse) GetSessionID() github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID
- func (m *OpenSessionResponse) Marshal() (dAtA []byte, err error)
- func (m *OpenSessionResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *OpenSessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OpenSessionResponse) ProtoMessage()
- func (m *OpenSessionResponse) Reset()
- func (m *OpenSessionResponse) Size() (n int)
- func (m *OpenSessionResponse) String() string
- func (m *OpenSessionResponse) Unmarshal(dAtA []byte) error
- func (m *OpenSessionResponse) XXX_DiscardUnknown()
- func (m *OpenSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OpenSessionResponse) XXX_Merge(src proto.Message)
- func (m *OpenSessionResponse) XXX_Size() int
- func (m *OpenSessionResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedLockManagerServer
- type UnimplementedLockServer
- func (*UnimplementedLockServer) GetLock(ctx context.Context, req *GetLockRequest) (*GetLockResponse, error)
- func (*UnimplementedLockServer) Lock(ctx context.Context, req *LockRequest) (*LockResponse, error)
- func (*UnimplementedLockServer) Unlock(ctx context.Context, req *UnlockRequest) (*UnlockResponse, error)
- type UnlockRequest
- func (*UnlockRequest) Descriptor() ([]byte, []int)
- func (m *UnlockRequest) GetLock() LockInstance
- 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) GetLock() LockInstance
- 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 ¶
var ( ErrInvalidLengthManager = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowManager = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupManager = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthPrimitive = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPrimitive = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupPrimitive = fmt.Errorf("proto: unexpected end of group") )
var LockInstance_State_name = map[int32]string{
0: "UNLOCKED",
1: "LOCKED",
}
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) 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) 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) 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) 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) 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) 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) 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