lockrpcpb

package
v0.6.2 Latest Latest
Warning

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

 Go to latest Published: Jun 18, 2018 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package lockrpcpb is a generated protocol buffer package.

It is generated from these files: 

lockpb.proto

It has these top-level messages: 

LockRequest
UnLockRequest
ForceUnLockRequest
LockHeartbeatRequest
UpdateConditionRequest
DLockResponse

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthLockpb = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLockpb   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterDLockServiceServer 

func RegisterDLockServiceServer(s *grpc.Server, srv DLockServiceServer)

Types

type DLockResponse 

type DLockResponse struct {
	Code       int64  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Error      string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Conditions []byte `protobuf:"bytes,3,opt,name=conditions,proto3" json:"conditions,omitempty"`
	UpdateTime int64  `protobuf:"varint,4,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
}

func (*DLockResponse) Descriptor 

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

func (*DLockResponse) GetCode 

func (m *DLockResponse) GetCode() int64

func (*DLockResponse) GetConditions 

func (m *DLockResponse) GetConditions() []byte

func (*DLockResponse) GetError 

func (m *DLockResponse) GetError() string

func (*DLockResponse) GetUpdateTime 

func (m *DLockResponse) GetUpdateTime() int64

func (*DLockResponse) Marshal 

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

func (*DLockResponse) MarshalTo 

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

func (*DLockResponse) ProtoMessage 

func (*DLockResponse) ProtoMessage()

func (*DLockResponse) Reset 

func (m *DLockResponse) Reset()

func (*DLockResponse) Size 

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

func (*DLockResponse) String 

func (m *DLockResponse) String() string

func (*DLockResponse) Unmarshal 

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

type DLockServiceClient 

type DLockServiceClient interface {
	Lock(ctx context.Context, in *LockRequest, opts ...grpc.CallOption) (*DLockResponse, error)
	UnLock(ctx context.Context, in *UnLockRequest, opts ...grpc.CallOption) (*DLockResponse, error)
	ForceUnLock(ctx context.Context, in *ForceUnLockRequest, opts ...grpc.CallOption) (*DLockResponse, error)
	DoHeartbeat(ctx context.Context, in *LockHeartbeatRequest, opts ...grpc.CallOption) (*DLockResponse, error)
	UpdateCondition(ctx context.Context, in *UpdateConditionRequest, opts ...grpc.CallOption) (*DLockResponse, error)
}

func NewDLockServiceClient 

func NewDLockServiceClient(cc *grpc.ClientConn) DLockServiceClient

type DLockServiceServer 

type DLockServiceServer interface {
	Lock(context.Context, *LockRequest) (*DLockResponse, error)
	UnLock(context.Context, *UnLockRequest) (*DLockResponse, error)
	ForceUnLock(context.Context, *ForceUnLockRequest) (*DLockResponse, error)
	DoHeartbeat(context.Context, *LockHeartbeatRequest) (*DLockResponse, error)
	UpdateCondition(context.Context, *UpdateConditionRequest) (*DLockResponse, error)
}

type ForceUnLockRequest 

type ForceUnLockRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	LockName  string `protobuf:"bytes,2,opt,name=lock_name,json=lockName,proto3" json:"lock_name,omitempty"`
}

func (*ForceUnLockRequest) Descriptor 

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

func (*ForceUnLockRequest) GetLockName 

func (m *ForceUnLockRequest) GetLockName() string

func (*ForceUnLockRequest) GetNamespace 

func (m *ForceUnLockRequest) GetNamespace() string

func (*ForceUnLockRequest) Marshal 

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

func (*ForceUnLockRequest) MarshalTo 

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

func (*ForceUnLockRequest) ProtoMessage 

func (*ForceUnLockRequest) ProtoMessage()

func (*ForceUnLockRequest) Reset 

func (m *ForceUnLockRequest) Reset()

func (*ForceUnLockRequest) Size 

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

func (*ForceUnLockRequest) String 

func (m *ForceUnLockRequest) String() string

func (*ForceUnLockRequest) Unmarshal 

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

type LockHeartbeatRequest 

type LockHeartbeatRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	LockName  string `protobuf:"bytes,2,opt,name=lock_name,json=lockName,proto3" json:"lock_name,omitempty"`
	LockId    string `protobuf:"bytes,3,opt,name=lock_id,json=lockId,proto3" json:"lock_id,omitempty"`
}

func (*LockHeartbeatRequest) Descriptor 

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

func (*LockHeartbeatRequest) GetLockId 

func (m *LockHeartbeatRequest) GetLockId() string

func (*LockHeartbeatRequest) GetLockName 

func (m *LockHeartbeatRequest) GetLockName() string

func (*LockHeartbeatRequest) GetNamespace 

func (m *LockHeartbeatRequest) GetNamespace() string

func (*LockHeartbeatRequest) Marshal 

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

func (*LockHeartbeatRequest) MarshalTo 

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

func (*LockHeartbeatRequest) ProtoMessage 

func (*LockHeartbeatRequest) ProtoMessage()

func (*LockHeartbeatRequest) Reset 

func (m *LockHeartbeatRequest) Reset()

func (*LockHeartbeatRequest) Size 

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

func (*LockHeartbeatRequest) String 

func (m *LockHeartbeatRequest) String() string

func (*LockHeartbeatRequest) Unmarshal 

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

type LockRequest 

type LockRequest struct {
	Namespace  string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	LockName   string `protobuf:"bytes,2,opt,name=lock_name,json=lockName,proto3" json:"lock_name,omitempty"`
	Conditions []byte `protobuf:"bytes,3,opt,name=conditions,proto3" json:"conditions,omitempty"`
	Timeout    int64  `protobuf:"varint,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	LockId     string `protobuf:"bytes,5,opt,name=lock_id,json=lockId,proto3" json:"lock_id,omitempty"`
}

func (*LockRequest) Descriptor 

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

func (*LockRequest) GetConditions 

func (m *LockRequest) GetConditions() []byte

func (*LockRequest) GetLockId 

func (m *LockRequest) GetLockId() string

func (*LockRequest) GetLockName 

func (m *LockRequest) GetLockName() string

func (*LockRequest) GetNamespace 

func (m *LockRequest) GetNamespace() string

func (*LockRequest) GetTimeout 

func (m *LockRequest) GetTimeout() int64

func (*LockRequest) Marshal 

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

func (*LockRequest) MarshalTo 

func (m *LockRequest) MarshalTo(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

type UnLockRequest 

type UnLockRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	LockName  string `protobuf:"bytes,2,opt,name=lock_name,json=lockName,proto3" json:"lock_name,omitempty"`
	LockId    string `protobuf:"bytes,3,opt,name=lock_id,json=lockId,proto3" json:"lock_id,omitempty"`
}

func (*UnLockRequest) Descriptor 

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

func (*UnLockRequest) GetLockId 

func (m *UnLockRequest) GetLockId() string

func (*UnLockRequest) GetLockName 

func (m *UnLockRequest) GetLockName() string

func (*UnLockRequest) GetNamespace 

func (m *UnLockRequest) GetNamespace() string

func (*UnLockRequest) Marshal 

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

func (*UnLockRequest) MarshalTo 

func (m *UnLockRequest) MarshalTo(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

type UpdateConditionRequest 

type UpdateConditionRequest struct {
	Namespace  string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	LockName   string `protobuf:"bytes,2,opt,name=lock_name,json=lockName,proto3" json:"lock_name,omitempty"`
	Conditions []byte `protobuf:"bytes,3,opt,name=conditions,proto3" json:"conditions,omitempty"`
}

func (*UpdateConditionRequest) Descriptor 

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

func (*UpdateConditionRequest) GetConditions 

func (m *UpdateConditionRequest) GetConditions() []byte

func (*UpdateConditionRequest) GetLockName 

func (m *UpdateConditionRequest) GetLockName() string

func (*UpdateConditionRequest) GetNamespace 

func (m *UpdateConditionRequest) GetNamespace() string

func (*UpdateConditionRequest) Marshal 

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

func (*UpdateConditionRequest) MarshalTo 

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

func (*UpdateConditionRequest) ProtoMessage 

func (*UpdateConditionRequest) ProtoMessage()

func (*UpdateConditionRequest) Reset 

func (m *UpdateConditionRequest) Reset()

func (*UpdateConditionRequest) Size 

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

func (*UpdateConditionRequest) String 

func (m *UpdateConditionRequest) String() string

func (*UpdateConditionRequest) Unmarshal 

func (m *UpdateConditionRequest) Unmarshal(dAtA []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.