lockV1

package
v6.0.0-beta.8 Latest Latest
Warning

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

 Go to latest Published: May 11, 2026 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	LockService_Lock_FullMethodName         = "/lock.v1.LockService/Lock"
	LockService_LockRead_FullMethodName     = "/lock.v1.LockService/LockRead"
	LockService_Release_FullMethodName      = "/lock.v1.LockService/Release"
	LockService_ForceRelease_FullMethodName = "/lock.v1.LockService/ForceRelease"
	LockService_Exists_FullMethodName       = "/lock.v1.LockService/Exists"
	LockService_UpdateTTL_FullMethodName    = "/lock.v1.LockService/UpdateTTL"
)

Variables

View Source 
var File_lock_v1_lock_proto protoreflect.FileDescriptor
View Source 
var File_lock_v1_service_proto protoreflect.FileDescriptor
View Source 
var LockService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "lock.v1.LockService",
	HandlerType: (*LockServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Lock",
			Handler:    _LockService_Lock_Handler,
		},
		{
			MethodName: "LockRead",
			Handler:    _LockService_LockRead_Handler,
		},
		{
			MethodName: "Release",
			Handler:    _LockService_Release_Handler,
		},
		{
			MethodName: "ForceRelease",
			Handler:    _LockService_ForceRelease_Handler,
		},
		{
			MethodName: "Exists",
			Handler:    _LockService_Exists_Handler,
		},
		{
			MethodName: "UpdateTTL",
			Handler:    _LockService_UpdateTTL_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "lock/v1/service.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 LockRequest 

type LockRequest struct {
	Resource string `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	Id       string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Ttl      *int64 `protobuf:"varint,3,opt,name=ttl,proto3,oneof" json:"ttl,omitempty"`
	Wait     *int64 `protobuf:"varint,4,opt,name=wait,proto3,oneof" json:"wait,omitempty"`
	// contains filtered or unexported fields
}

func (*LockRequest) Descriptor deprecated 

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

Deprecated: Use LockRequest.ProtoReflect.Descriptor instead.

func (*LockRequest) GetId 

func (x *LockRequest) GetId() string

func (*LockRequest) GetResource 

func (x *LockRequest) GetResource() string

func (*LockRequest) GetTtl 

func (x *LockRequest) GetTtl() int64

func (*LockRequest) GetWait 

func (x *LockRequest) GetWait() int64

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 {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*LockResponse) Descriptor deprecated 

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

Deprecated: Use LockResponse.ProtoReflect.Descriptor instead.

func (*LockResponse) GetOk 

func (x *LockResponse) GetOk() bool

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 {
	Lock(ctx context.Context, in *LockRequest, opts ...grpc.CallOption) (*LockResponse, error)
	LockRead(ctx context.Context, in *LockRequest, opts ...grpc.CallOption) (*LockResponse, error)
	Release(ctx context.Context, in *LockRequest, opts ...grpc.CallOption) (*LockResponse, error)
	ForceRelease(ctx context.Context, in *LockRequest, opts ...grpc.CallOption) (*LockResponse, error)
	Exists(ctx context.Context, in *LockRequest, opts ...grpc.CallOption) (*LockResponse, error)
	UpdateTTL(ctx context.Context, in *LockRequest, opts ...grpc.CallOption) (*LockResponse, 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 {
	Lock(context.Context, *LockRequest) (*LockResponse, error)
	LockRead(context.Context, *LockRequest) (*LockResponse, error)
	Release(context.Context, *LockRequest) (*LockResponse, error)
	ForceRelease(context.Context, *LockRequest) (*LockResponse, error)
	Exists(context.Context, *LockRequest) (*LockResponse, error)
	UpdateTTL(context.Context, *LockRequest) (*LockResponse, 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) Exists 

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

func (UnimplementedLockServiceServer) ForceRelease 

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

func (UnimplementedLockServiceServer) Lock 

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

func (UnimplementedLockServiceServer) LockRead 

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

func (UnimplementedLockServiceServer) Release 

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

func (UnimplementedLockServiceServer) UpdateTTL 

func (UnimplementedLockServiceServer) UpdateTTL(context.Context, *LockRequest) (*LockResponse, 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.

Source Files

View all Source files

Directories

Path Synopsis

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.