pb

Documentation

Index

• Constants
• Variables
• func RegisterLockServiceServer(s grpc.ServiceRegistrar, srv LockServiceServer)
• type ActionResponse
  • func (*ActionResponse) Descriptor() ([]byte, []int)
  • func (x *ActionResponse) GetStatus() string
  • func (*ActionResponse) ProtoMessage()
  • func (x *ActionResponse) ProtoReflect() protoreflect.Message
  • func (x *ActionResponse) Reset()
  • func (x *ActionResponse) String() string
• type LockRequest
  • func (*LockRequest) Descriptor() ([]byte, []int)
  • func (x *LockRequest) GetKey() string
  • func (x *LockRequest) GetToken() string
  • func (x *LockRequest) GetTtlSec() int32
  • func (*LockRequest) ProtoMessage()
  • func (x *LockRequest) ProtoReflect() protoreflect.Message
  • func (x *LockRequest) Reset()
  • func (x *LockRequest) String() string
• type LockResponse
  • func (*LockResponse) Descriptor() ([]byte, []int)
  • func (x *LockResponse) GetExpiredAt() int64
  • func (x *LockResponse) GetKey() string
  • func (x *LockResponse) GetToken() string
  • func (*LockResponse) ProtoMessage()
  • func (x *LockResponse) ProtoReflect() protoreflect.Message
  • func (x *LockResponse) Reset()
  • func (x *LockResponse) String() string
• type LockServiceClient
  • func NewLockServiceClient(cc grpc.ClientConnInterface) LockServiceClient
• type LockServiceServer
• type UnimplementedLockServiceServer
  • func (UnimplementedLockServiceServer) Acquire(context.Context, *LockRequest) (*LockResponse, error)
  • func (UnimplementedLockServiceServer) Extend(context.Context, *LockRequest) (*ActionResponse, error)
  • func (UnimplementedLockServiceServer) Release(context.Context, *LockRequest) (*ActionResponse, error)
• type UnsafeLockServiceServer

Constants

const (
	LockService_Acquire_FullMethodName = "/pb.LockService/Acquire"
	LockService_Release_FullMethodName = "/pb.LockService/Release"
	LockService_Extend_FullMethodName  = "/pb.LockService/Extend"
)

Variables

var File_lock_proto protoreflect.FileDescriptor

var LockService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.LockService",
	HandlerType: (*LockServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Acquire",
			Handler:    _LockService_Acquire_Handler,
		},
		{
			MethodName: "Release",
			Handler:    _LockService_Release_Handler,
		},
		{
			MethodName: "Extend",
			Handler:    _LockService_Extend_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "lock.proto",
}

LockService_ServiceDesc is the grpc.ServiceDesc for LockService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterLockServiceServer

func RegisterLockServiceServer(s grpc.ServiceRegistrar, srv LockServiceServer)

Types

type ActionResponse

type ActionResponse struct {
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

ActionResponse 代表單純的操作結果

func (*ActionResponse) Descriptor

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

Deprecated: Use ActionResponse.ProtoReflect.Descriptor instead.

func (*ActionResponse) GetStatus

func (x *ActionResponse) GetStatus() string

func (*ActionResponse) ProtoMessage

func (*ActionResponse) ProtoMessage()

func (*ActionResponse) ProtoReflect

func (x *ActionResponse) ProtoReflect() protoreflect.Message

func (*ActionResponse) Reset

func (x *ActionResponse) Reset()

func (*ActionResponse) String

func (x *ActionResponse) String() string

type LockRequest

type LockRequest struct {
	Key    string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Token  string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	TtlSec int32  `protobuf:"varint,3,opt,name=ttl_sec,json=ttlSec,proto3" json:"ttl_sec,omitempty"`
	// contains filtered or unexported fields
}

LockRequest 代表所有的請求輸入

func (*LockRequest) Descriptor

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

Deprecated: Use LockRequest.ProtoReflect.Descriptor instead.

func (*LockRequest) GetKey

func (x *LockRequest) GetKey() string

func (*LockRequest) GetToken

func (x *LockRequest) GetToken() string

func (*LockRequest) GetTtlSec

func (x *LockRequest) GetTtlSec() int32

func (*LockRequest) ProtoMessage

func (*LockRequest) ProtoMessage()

func (*LockRequest) ProtoReflect

func (x *LockRequest) ProtoReflect() protoreflect.Message

func (*LockRequest) Reset

func (x *LockRequest) Reset()

func (*LockRequest) String

func (x *LockRequest) String() string

type LockResponse

type LockResponse struct {
	Key       string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Token     string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	ExpiredAt int64  `protobuf:"varint,3,opt,name=expired_at,json=expiredAt,proto3" json:"expired_at,omitempty"` // Unix timestamp
	// contains filtered or unexported fields
}

LockResponse 代表鎖的資訊

func (*LockResponse) Descriptor

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

Deprecated: Use LockResponse.ProtoReflect.Descriptor instead.

func (*LockResponse) GetExpiredAt

func (x *LockResponse) GetExpiredAt() int64

func (*LockResponse) GetKey

func (x *LockResponse) GetKey() string

func (*LockResponse) GetToken

func (x *LockResponse) GetToken() string

func (*LockResponse) ProtoMessage

func (*LockResponse) ProtoMessage()

func (*LockResponse) ProtoReflect

func (x *LockResponse) ProtoReflect() protoreflect.Message

func (*LockResponse) Reset

func (x *LockResponse) Reset()

func (*LockResponse) String

func (x *LockResponse) String() string

type LockServiceClient

type LockServiceClient interface {
	Acquire(ctx context.Context, in *LockRequest, opts ...grpc.CallOption) (*LockResponse, error)
	Release(ctx context.Context, in *LockRequest, opts ...grpc.CallOption) (*ActionResponse, error)
	Extend(ctx context.Context, in *LockRequest, opts ...grpc.CallOption) (*ActionResponse, error)
}

LockServiceClient is the client API for LockService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewLockServiceClient

func NewLockServiceClient(cc grpc.ClientConnInterface) LockServiceClient

type LockServiceServer

type LockServiceServer interface {
	Acquire(context.Context, *LockRequest) (*LockResponse, error)
	Release(context.Context, *LockRequest) (*ActionResponse, error)
	Extend(context.Context, *LockRequest) (*ActionResponse, error)
	// contains filtered or unexported methods
}

LockServiceServer is the server API for LockService service. All implementations must embed UnimplementedLockServiceServer for forward compatibility.

type UnimplementedLockServiceServer

type UnimplementedLockServiceServer struct{}

UnimplementedLockServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedLockServiceServer) Acquire

func (UnimplementedLockServiceServer) Acquire(context.Context, *LockRequest) (*LockResponse, error)

func (UnimplementedLockServiceServer) Extend

func (UnimplementedLockServiceServer) Extend(context.Context, *LockRequest) (*ActionResponse, error)

func (UnimplementedLockServiceServer) Release

func (UnimplementedLockServiceServer) Release(context.Context, *LockRequest) (*ActionResponse, error)

type UnsafeLockServiceServer

type UnsafeLockServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeLockServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LockServiceServer will result in compilation errors.