Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterServiceServer(s grpc.ServiceRegistrar, srv ServiceServer)
- type CreateLeaseRequest
- func (x *CreateLeaseRequest) GetAlreadyRegisteredLocks() []*Lock
- func (x *CreateLeaseRequest) GetAlreadyRegisteredRlocks() []*Lock
- func (x *CreateLeaseRequest) GetApp() string
- func (x *CreateLeaseRequest) GetIp() string
- func (x *CreateLeaseRequest) GetLeaseId() string
- func (x *CreateLeaseRequest) GetTtl() int32
- func (*CreateLeaseRequest) ProtoMessage()
- func (x *CreateLeaseRequest) ProtoReflect() protoreflect.Message
- func (x *CreateLeaseRequest) Reset()
- func (x *CreateLeaseRequest) SetAlreadyRegisteredLocks(v []*Lock)
- func (x *CreateLeaseRequest) SetAlreadyRegisteredRlocks(v []*Lock)
- func (x *CreateLeaseRequest) SetApp(v string)
- func (x *CreateLeaseRequest) SetIp(v string)
- func (x *CreateLeaseRequest) SetLeaseId(v string)
- func (x *CreateLeaseRequest) SetTtl(v int32)
- func (x *CreateLeaseRequest) String() string
- type CreateLeaseRequest_builder
- type CreateLeaseResponse
- type CreateLeaseResponse_builder
- type DropLeaseRequest
- type DropLeaseRequest_builder
- type DropLeaseResponse
- type DropLeaseResponse_builder
- type GetPeerNodesRequest
- type GetPeerNodesRequest_builder
- type GetPeerNodesResponse
- func (x *GetPeerNodesResponse) GetPeerNodeIp() []string
- func (*GetPeerNodesResponse) ProtoMessage()
- func (x *GetPeerNodesResponse) ProtoReflect() protoreflect.Message
- func (x *GetPeerNodesResponse) Reset()
- func (x *GetPeerNodesResponse) SetPeerNodeIp(v []string)
- func (x *GetPeerNodesResponse) String() string
- type GetPeerNodesResponse_builder
- type KeepLeaseRequest
- func (x *KeepLeaseRequest) GetLeaseId() string
- func (x *KeepLeaseRequest) GetTtl() int32
- func (*KeepLeaseRequest) ProtoMessage()
- func (x *KeepLeaseRequest) ProtoReflect() protoreflect.Message
- func (x *KeepLeaseRequest) Reset()
- func (x *KeepLeaseRequest) SetLeaseId(v string)
- func (x *KeepLeaseRequest) SetTtl(v int32)
- func (x *KeepLeaseRequest) String() string
- type KeepLeaseRequest_builder
- type KeepLeaseResponse
- type KeepLeaseResponse_builder
- type Lock
- func (x *Lock) GetLeaseId() string
- func (x *Lock) GetResource() []string
- func (x *Lock) GetTenantId() string
- func (*Lock) ProtoMessage()
- func (x *Lock) ProtoReflect() protoreflect.Message
- func (x *Lock) Reset()
- func (x *Lock) SetLeaseId(v string)
- func (x *Lock) SetResource(v []string)
- func (x *Lock) SetTenantId(v string)
- func (x *Lock) String() string
- type LockRequest
- func (x *LockRequest) GetLeaseId() string
- func (x *LockRequest) GetResource() []string
- func (x *LockRequest) GetTenantId() string
- func (*LockRequest) ProtoMessage()
- func (x *LockRequest) ProtoReflect() protoreflect.Message
- func (x *LockRequest) Reset()
- func (x *LockRequest) SetLeaseId(v string)
- func (x *LockRequest) SetResource(v []string)
- func (x *LockRequest) SetTenantId(v string)
- func (x *LockRequest) String() string
- type LockRequest_builder
- type LockResponse
- type LockResponse_builder
- type Lock_builder
- type RLockRequest
- func (x *RLockRequest) GetLeaseId() string
- func (x *RLockRequest) GetResource() []string
- func (x *RLockRequest) GetTenantId() string
- func (*RLockRequest) ProtoMessage()
- func (x *RLockRequest) ProtoReflect() protoreflect.Message
- func (x *RLockRequest) Reset()
- func (x *RLockRequest) SetLeaseId(v string)
- func (x *RLockRequest) SetResource(v []string)
- func (x *RLockRequest) SetTenantId(v string)
- func (x *RLockRequest) String() string
- type RLockRequest_builder
- type RLockResponse
- type RLockResponse_builder
- type RUnlockRequest
- func (x *RUnlockRequest) GetLeaseId() string
- func (x *RUnlockRequest) GetResource() []string
- func (x *RUnlockRequest) GetTenantId() string
- func (*RUnlockRequest) ProtoMessage()
- func (x *RUnlockRequest) ProtoReflect() protoreflect.Message
- func (x *RUnlockRequest) Reset()
- func (x *RUnlockRequest) SetLeaseId(v string)
- func (x *RUnlockRequest) SetResource(v []string)
- func (x *RUnlockRequest) SetTenantId(v string)
- func (x *RUnlockRequest) String() string
- type RUnlockRequest_builder
- type RUnlockResponse
- type RUnlockResponse_builder
- type ServiceClient
- type ServiceServer
- type Service_GetPeerNodesClient
- type Service_GetPeerNodesServer
- type UnimplementedServiceServer
- func (UnimplementedServiceServer) CreateLease(context.Context, *CreateLeaseRequest) (*CreateLeaseResponse, error)
- func (UnimplementedServiceServer) DropLease(context.Context, *DropLeaseRequest) (*DropLeaseResponse, error)
- func (UnimplementedServiceServer) GetPeerNodes(*GetPeerNodesRequest, grpc.ServerStreamingServer[GetPeerNodesResponse]) error
- func (UnimplementedServiceServer) KeepLease(context.Context, *KeepLeaseRequest) (*KeepLeaseResponse, error)
- func (UnimplementedServiceServer) Lock(context.Context, *LockRequest) (*LockResponse, error)
- func (UnimplementedServiceServer) RLock(context.Context, *RLockRequest) (*RLockResponse, error)
- func (UnimplementedServiceServer) RUnlock(context.Context, *RUnlockRequest) (*RUnlockResponse, error)
- func (UnimplementedServiceServer) Unlock(context.Context, *UnlockRequest) (*UnlockResponse, error)
- type UnlockRequest
- func (x *UnlockRequest) GetLeaseId() string
- func (x *UnlockRequest) GetResource() []string
- func (x *UnlockRequest) GetTenantId() string
- func (*UnlockRequest) ProtoMessage()
- func (x *UnlockRequest) ProtoReflect() protoreflect.Message
- func (x *UnlockRequest) Reset()
- func (x *UnlockRequest) SetLeaseId(v string)
- func (x *UnlockRequest) SetResource(v []string)
- func (x *UnlockRequest) SetTenantId(v string)
- func (x *UnlockRequest) String() string
- type UnlockRequest_builder
- type UnlockResponse
- type UnlockResponse_builder
- type UnsafeServiceServer
Constants ¶
const ( Service_CreateLease_FullMethodName = "/freym.sync.management.Service/CreateLease" Service_KeepLease_FullMethodName = "/freym.sync.management.Service/KeepLease" Service_DropLease_FullMethodName = "/freym.sync.management.Service/DropLease" Service_GetPeerNodes_FullMethodName = "/freym.sync.management.Service/GetPeerNodes" Service_Lock_FullMethodName = "/freym.sync.management.Service/Lock" Service_Unlock_FullMethodName = "/freym.sync.management.Service/Unlock" Service_RLock_FullMethodName = "/freym.sync.management.Service/RLock" Service_RUnlock_FullMethodName = "/freym.sync.management.Service/RUnlock" )
Variables ¶
var File_sync_management_lease_proto protoreflect.FileDescriptor
var File_sync_management_lock_proto protoreflect.FileDescriptor
var File_sync_management_peer_nodes_proto protoreflect.FileDescriptor
var File_sync_management_service_proto protoreflect.FileDescriptor
var Service_ServiceDesc = grpc.ServiceDesc{ ServiceName: "freym.sync.management.Service", HandlerType: (*ServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateLease", Handler: _Service_CreateLease_Handler, }, { MethodName: "KeepLease", Handler: _Service_KeepLease_Handler, }, { MethodName: "DropLease", Handler: _Service_DropLease_Handler, }, { MethodName: "Lock", Handler: _Service_Lock_Handler, }, { MethodName: "Unlock", Handler: _Service_Unlock_Handler, }, { MethodName: "RLock", Handler: _Service_RLock_Handler, }, { MethodName: "RUnlock", Handler: _Service_RUnlock_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "GetPeerNodes", Handler: _Service_GetPeerNodes_Handler, ServerStreams: true, }, }, Metadata: "sync/management/service.proto", }
Service_ServiceDesc is the grpc.ServiceDesc for Service service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterServiceServer ¶
func RegisterServiceServer(s grpc.ServiceRegistrar, srv ServiceServer)
Types ¶
type CreateLeaseRequest ¶
type CreateLeaseRequest struct {
// contains filtered or unexported fields
}
func (*CreateLeaseRequest) GetAlreadyRegisteredLocks ¶
func (x *CreateLeaseRequest) GetAlreadyRegisteredLocks() []*Lock
func (*CreateLeaseRequest) GetAlreadyRegisteredRlocks ¶ added in v0.32.0
func (x *CreateLeaseRequest) GetAlreadyRegisteredRlocks() []*Lock
func (*CreateLeaseRequest) GetApp ¶
func (x *CreateLeaseRequest) GetApp() string
func (*CreateLeaseRequest) GetIp ¶
func (x *CreateLeaseRequest) GetIp() string
func (*CreateLeaseRequest) GetLeaseId ¶
func (x *CreateLeaseRequest) GetLeaseId() string
func (*CreateLeaseRequest) GetTtl ¶
func (x *CreateLeaseRequest) GetTtl() int32
func (*CreateLeaseRequest) ProtoMessage ¶
func (*CreateLeaseRequest) ProtoMessage()
func (*CreateLeaseRequest) ProtoReflect ¶
func (x *CreateLeaseRequest) ProtoReflect() protoreflect.Message
func (*CreateLeaseRequest) Reset ¶
func (x *CreateLeaseRequest) Reset()
func (*CreateLeaseRequest) SetAlreadyRegisteredLocks ¶
func (x *CreateLeaseRequest) SetAlreadyRegisteredLocks(v []*Lock)
func (*CreateLeaseRequest) SetAlreadyRegisteredRlocks ¶ added in v0.32.0
func (x *CreateLeaseRequest) SetAlreadyRegisteredRlocks(v []*Lock)
func (*CreateLeaseRequest) SetApp ¶
func (x *CreateLeaseRequest) SetApp(v string)
func (*CreateLeaseRequest) SetIp ¶
func (x *CreateLeaseRequest) SetIp(v string)
func (*CreateLeaseRequest) SetLeaseId ¶
func (x *CreateLeaseRequest) SetLeaseId(v string)
func (*CreateLeaseRequest) SetTtl ¶
func (x *CreateLeaseRequest) SetTtl(v int32)
func (*CreateLeaseRequest) String ¶
func (x *CreateLeaseRequest) String() string
type CreateLeaseRequest_builder ¶
type CreateLeaseRequest_builder struct {
Ip string
App string
Ttl int32
LeaseId string
AlreadyRegisteredLocks []*Lock
AlreadyRegisteredRlocks []*Lock
// contains filtered or unexported fields
}
func (CreateLeaseRequest_builder) Build ¶
func (b0 CreateLeaseRequest_builder) Build() *CreateLeaseRequest
type CreateLeaseResponse ¶
type CreateLeaseResponse struct {
// contains filtered or unexported fields
}
func (*CreateLeaseResponse) GetLeaseId ¶
func (x *CreateLeaseResponse) GetLeaseId() string
func (*CreateLeaseResponse) ProtoMessage ¶
func (*CreateLeaseResponse) ProtoMessage()
func (*CreateLeaseResponse) ProtoReflect ¶
func (x *CreateLeaseResponse) ProtoReflect() protoreflect.Message
func (*CreateLeaseResponse) Reset ¶
func (x *CreateLeaseResponse) Reset()
func (*CreateLeaseResponse) SetLeaseId ¶
func (x *CreateLeaseResponse) SetLeaseId(v string)
func (*CreateLeaseResponse) String ¶
func (x *CreateLeaseResponse) String() string
type CreateLeaseResponse_builder ¶
type CreateLeaseResponse_builder struct {
LeaseId string
// contains filtered or unexported fields
}
func (CreateLeaseResponse_builder) Build ¶
func (b0 CreateLeaseResponse_builder) Build() *CreateLeaseResponse
type DropLeaseRequest ¶
type DropLeaseRequest struct {
// contains filtered or unexported fields
}
func (*DropLeaseRequest) GetLeaseId ¶
func (x *DropLeaseRequest) GetLeaseId() string
func (*DropLeaseRequest) ProtoMessage ¶
func (*DropLeaseRequest) ProtoMessage()
func (*DropLeaseRequest) ProtoReflect ¶
func (x *DropLeaseRequest) ProtoReflect() protoreflect.Message
func (*DropLeaseRequest) Reset ¶
func (x *DropLeaseRequest) Reset()
func (*DropLeaseRequest) SetLeaseId ¶
func (x *DropLeaseRequest) SetLeaseId(v string)
func (*DropLeaseRequest) String ¶
func (x *DropLeaseRequest) String() string
type DropLeaseRequest_builder ¶
type DropLeaseRequest_builder struct {
LeaseId string
// contains filtered or unexported fields
}
func (DropLeaseRequest_builder) Build ¶
func (b0 DropLeaseRequest_builder) Build() *DropLeaseRequest
type DropLeaseResponse ¶
type DropLeaseResponse struct {
// contains filtered or unexported fields
}
func (*DropLeaseResponse) ProtoMessage ¶
func (*DropLeaseResponse) ProtoMessage()
func (*DropLeaseResponse) ProtoReflect ¶
func (x *DropLeaseResponse) ProtoReflect() protoreflect.Message
func (*DropLeaseResponse) Reset ¶
func (x *DropLeaseResponse) Reset()
func (*DropLeaseResponse) String ¶
func (x *DropLeaseResponse) String() string
type DropLeaseResponse_builder ¶
type DropLeaseResponse_builder struct {
// contains filtered or unexported fields
}
func (DropLeaseResponse_builder) Build ¶
func (b0 DropLeaseResponse_builder) Build() *DropLeaseResponse
type GetPeerNodesRequest ¶
type GetPeerNodesRequest struct {
// contains filtered or unexported fields
}
func (*GetPeerNodesRequest) GetApp ¶
func (x *GetPeerNodesRequest) GetApp() string
func (*GetPeerNodesRequest) ProtoMessage ¶
func (*GetPeerNodesRequest) ProtoMessage()
func (*GetPeerNodesRequest) ProtoReflect ¶
func (x *GetPeerNodesRequest) ProtoReflect() protoreflect.Message
func (*GetPeerNodesRequest) Reset ¶
func (x *GetPeerNodesRequest) Reset()
func (*GetPeerNodesRequest) SetApp ¶
func (x *GetPeerNodesRequest) SetApp(v string)
func (*GetPeerNodesRequest) String ¶
func (x *GetPeerNodesRequest) String() string
type GetPeerNodesRequest_builder ¶
type GetPeerNodesRequest_builder struct {
App string
// contains filtered or unexported fields
}
func (GetPeerNodesRequest_builder) Build ¶
func (b0 GetPeerNodesRequest_builder) Build() *GetPeerNodesRequest
type GetPeerNodesResponse ¶
type GetPeerNodesResponse struct {
// contains filtered or unexported fields
}
func (*GetPeerNodesResponse) GetPeerNodeIp ¶
func (x *GetPeerNodesResponse) GetPeerNodeIp() []string
func (*GetPeerNodesResponse) ProtoMessage ¶
func (*GetPeerNodesResponse) ProtoMessage()
func (*GetPeerNodesResponse) ProtoReflect ¶
func (x *GetPeerNodesResponse) ProtoReflect() protoreflect.Message
func (*GetPeerNodesResponse) Reset ¶
func (x *GetPeerNodesResponse) Reset()
func (*GetPeerNodesResponse) SetPeerNodeIp ¶
func (x *GetPeerNodesResponse) SetPeerNodeIp(v []string)
func (*GetPeerNodesResponse) String ¶
func (x *GetPeerNodesResponse) String() string
type GetPeerNodesResponse_builder ¶
type GetPeerNodesResponse_builder struct {
PeerNodeIp []string
// contains filtered or unexported fields
}
func (GetPeerNodesResponse_builder) Build ¶
func (b0 GetPeerNodesResponse_builder) Build() *GetPeerNodesResponse
type KeepLeaseRequest ¶
type KeepLeaseRequest struct {
// contains filtered or unexported fields
}
func (*KeepLeaseRequest) GetLeaseId ¶
func (x *KeepLeaseRequest) GetLeaseId() string
func (*KeepLeaseRequest) GetTtl ¶
func (x *KeepLeaseRequest) GetTtl() int32
func (*KeepLeaseRequest) ProtoMessage ¶
func (*KeepLeaseRequest) ProtoMessage()
func (*KeepLeaseRequest) ProtoReflect ¶
func (x *KeepLeaseRequest) ProtoReflect() protoreflect.Message
func (*KeepLeaseRequest) Reset ¶
func (x *KeepLeaseRequest) Reset()
func (*KeepLeaseRequest) SetLeaseId ¶
func (x *KeepLeaseRequest) SetLeaseId(v string)
func (*KeepLeaseRequest) SetTtl ¶
func (x *KeepLeaseRequest) SetTtl(v int32)
func (*KeepLeaseRequest) String ¶
func (x *KeepLeaseRequest) String() string
type KeepLeaseRequest_builder ¶
type KeepLeaseRequest_builder struct {
LeaseId string
Ttl int32
// contains filtered or unexported fields
}
func (KeepLeaseRequest_builder) Build ¶
func (b0 KeepLeaseRequest_builder) Build() *KeepLeaseRequest
type KeepLeaseResponse ¶
type KeepLeaseResponse struct {
// contains filtered or unexported fields
}
func (*KeepLeaseResponse) ProtoMessage ¶
func (*KeepLeaseResponse) ProtoMessage()
func (*KeepLeaseResponse) ProtoReflect ¶
func (x *KeepLeaseResponse) ProtoReflect() protoreflect.Message
func (*KeepLeaseResponse) Reset ¶
func (x *KeepLeaseResponse) Reset()
func (*KeepLeaseResponse) String ¶
func (x *KeepLeaseResponse) String() string
type KeepLeaseResponse_builder ¶
type KeepLeaseResponse_builder struct {
// contains filtered or unexported fields
}
func (KeepLeaseResponse_builder) Build ¶
func (b0 KeepLeaseResponse_builder) Build() *KeepLeaseResponse
type Lock ¶
type Lock struct {
// contains filtered or unexported fields
}
func (*Lock) GetLeaseId ¶
func (*Lock) GetResource ¶
func (*Lock) GetTenantId ¶
func (*Lock) ProtoMessage ¶
func (*Lock) ProtoMessage()
func (*Lock) ProtoReflect ¶
func (x *Lock) ProtoReflect() protoreflect.Message
func (*Lock) SetLeaseId ¶
func (*Lock) SetResource ¶
func (*Lock) SetTenantId ¶
type LockRequest ¶
type LockRequest struct {
// contains filtered or unexported fields
}
func (*LockRequest) GetLeaseId ¶
func (x *LockRequest) GetLeaseId() string
func (*LockRequest) GetResource ¶
func (x *LockRequest) GetResource() []string
func (*LockRequest) GetTenantId ¶
func (x *LockRequest) GetTenantId() string
func (*LockRequest) ProtoMessage ¶
func (*LockRequest) ProtoMessage()
func (*LockRequest) ProtoReflect ¶
func (x *LockRequest) ProtoReflect() protoreflect.Message
func (*LockRequest) Reset ¶
func (x *LockRequest) Reset()
func (*LockRequest) SetLeaseId ¶
func (x *LockRequest) SetLeaseId(v string)
func (*LockRequest) SetResource ¶
func (x *LockRequest) SetResource(v []string)
func (*LockRequest) SetTenantId ¶
func (x *LockRequest) SetTenantId(v string)
func (*LockRequest) String ¶
func (x *LockRequest) String() string
type LockRequest_builder ¶
type LockRequest_builder struct {
LeaseId string
TenantId string
Resource []string
// contains filtered or unexported fields
}
func (LockRequest_builder) Build ¶
func (b0 LockRequest_builder) Build() *LockRequest
type LockResponse ¶
type LockResponse struct {
// contains filtered or unexported fields
}
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 LockResponse_builder ¶
type LockResponse_builder struct {
// contains filtered or unexported fields
}
func (LockResponse_builder) Build ¶
func (b0 LockResponse_builder) Build() *LockResponse
type Lock_builder ¶
type Lock_builder struct {
LeaseId string
TenantId string
Resource []string
// contains filtered or unexported fields
}
func (Lock_builder) Build ¶
func (b0 Lock_builder) Build() *Lock
type RLockRequest ¶ added in v0.32.0
type RLockRequest struct {
// contains filtered or unexported fields
}
func (*RLockRequest) GetLeaseId ¶ added in v0.32.0
func (x *RLockRequest) GetLeaseId() string
func (*RLockRequest) GetResource ¶ added in v0.32.0
func (x *RLockRequest) GetResource() []string
func (*RLockRequest) GetTenantId ¶ added in v0.32.0
func (x *RLockRequest) GetTenantId() string
func (*RLockRequest) ProtoMessage ¶ added in v0.32.0
func (*RLockRequest) ProtoMessage()
func (*RLockRequest) ProtoReflect ¶ added in v0.32.0
func (x *RLockRequest) ProtoReflect() protoreflect.Message
func (*RLockRequest) Reset ¶ added in v0.32.0
func (x *RLockRequest) Reset()
func (*RLockRequest) SetLeaseId ¶ added in v0.32.0
func (x *RLockRequest) SetLeaseId(v string)
func (*RLockRequest) SetResource ¶ added in v0.32.0
func (x *RLockRequest) SetResource(v []string)
func (*RLockRequest) SetTenantId ¶ added in v0.32.0
func (x *RLockRequest) SetTenantId(v string)
func (*RLockRequest) String ¶ added in v0.32.0
func (x *RLockRequest) String() string
type RLockRequest_builder ¶ added in v0.32.0
type RLockRequest_builder struct {
LeaseId string
TenantId string
Resource []string
// contains filtered or unexported fields
}
func (RLockRequest_builder) Build ¶ added in v0.32.0
func (b0 RLockRequest_builder) Build() *RLockRequest
type RLockResponse ¶ added in v0.32.0
type RLockResponse struct {
// contains filtered or unexported fields
}
func (*RLockResponse) ProtoMessage ¶ added in v0.32.0
func (*RLockResponse) ProtoMessage()
func (*RLockResponse) ProtoReflect ¶ added in v0.32.0
func (x *RLockResponse) ProtoReflect() protoreflect.Message
func (*RLockResponse) Reset ¶ added in v0.32.0
func (x *RLockResponse) Reset()
func (*RLockResponse) String ¶ added in v0.32.0
func (x *RLockResponse) String() string
type RLockResponse_builder ¶ added in v0.32.0
type RLockResponse_builder struct {
// contains filtered or unexported fields
}
func (RLockResponse_builder) Build ¶ added in v0.32.0
func (b0 RLockResponse_builder) Build() *RLockResponse
type RUnlockRequest ¶ added in v0.32.0
type RUnlockRequest struct {
// contains filtered or unexported fields
}
func (*RUnlockRequest) GetLeaseId ¶ added in v0.32.0
func (x *RUnlockRequest) GetLeaseId() string
func (*RUnlockRequest) GetResource ¶ added in v0.32.0
func (x *RUnlockRequest) GetResource() []string
func (*RUnlockRequest) GetTenantId ¶ added in v0.32.0
func (x *RUnlockRequest) GetTenantId() string
func (*RUnlockRequest) ProtoMessage ¶ added in v0.32.0
func (*RUnlockRequest) ProtoMessage()
func (*RUnlockRequest) ProtoReflect ¶ added in v0.32.0
func (x *RUnlockRequest) ProtoReflect() protoreflect.Message
func (*RUnlockRequest) Reset ¶ added in v0.32.0
func (x *RUnlockRequest) Reset()
func (*RUnlockRequest) SetLeaseId ¶ added in v0.32.0
func (x *RUnlockRequest) SetLeaseId(v string)
func (*RUnlockRequest) SetResource ¶ added in v0.32.0
func (x *RUnlockRequest) SetResource(v []string)
func (*RUnlockRequest) SetTenantId ¶ added in v0.32.0
func (x *RUnlockRequest) SetTenantId(v string)
func (*RUnlockRequest) String ¶ added in v0.32.0
func (x *RUnlockRequest) String() string
type RUnlockRequest_builder ¶ added in v0.32.0
type RUnlockRequest_builder struct {
LeaseId string
TenantId string
Resource []string
// contains filtered or unexported fields
}
func (RUnlockRequest_builder) Build ¶ added in v0.32.0
func (b0 RUnlockRequest_builder) Build() *RUnlockRequest
type RUnlockResponse ¶ added in v0.32.0
type RUnlockResponse struct {
// contains filtered or unexported fields
}
func (*RUnlockResponse) ProtoMessage ¶ added in v0.32.0
func (*RUnlockResponse) ProtoMessage()
func (*RUnlockResponse) ProtoReflect ¶ added in v0.32.0
func (x *RUnlockResponse) ProtoReflect() protoreflect.Message
func (*RUnlockResponse) Reset ¶ added in v0.32.0
func (x *RUnlockResponse) Reset()
func (*RUnlockResponse) String ¶ added in v0.32.0
func (x *RUnlockResponse) String() string
type RUnlockResponse_builder ¶ added in v0.32.0
type RUnlockResponse_builder struct {
// contains filtered or unexported fields
}
func (RUnlockResponse_builder) Build ¶ added in v0.32.0
func (b0 RUnlockResponse_builder) Build() *RUnlockResponse
type ServiceClient ¶
type ServiceClient interface {
CreateLease(ctx context.Context, in *CreateLeaseRequest, opts ...grpc.CallOption) (*CreateLeaseResponse, error)
KeepLease(ctx context.Context, in *KeepLeaseRequest, opts ...grpc.CallOption) (*KeepLeaseResponse, error)
DropLease(ctx context.Context, in *DropLeaseRequest, opts ...grpc.CallOption) (*DropLeaseResponse, error)
GetPeerNodes(ctx context.Context, in *GetPeerNodesRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetPeerNodesResponse], error)
Lock(ctx context.Context, in *LockRequest, opts ...grpc.CallOption) (*LockResponse, error)
Unlock(ctx context.Context, in *UnlockRequest, opts ...grpc.CallOption) (*UnlockResponse, error)
RLock(ctx context.Context, in *RLockRequest, opts ...grpc.CallOption) (*RLockResponse, error)
RUnlock(ctx context.Context, in *RUnlockRequest, opts ...grpc.CallOption) (*RUnlockResponse, error)
}
ServiceClient is the client API for Service 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 NewServiceClient ¶
func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient
type ServiceServer ¶
type ServiceServer interface {
CreateLease(context.Context, *CreateLeaseRequest) (*CreateLeaseResponse, error)
KeepLease(context.Context, *KeepLeaseRequest) (*KeepLeaseResponse, error)
DropLease(context.Context, *DropLeaseRequest) (*DropLeaseResponse, error)
GetPeerNodes(*GetPeerNodesRequest, grpc.ServerStreamingServer[GetPeerNodesResponse]) error
Lock(context.Context, *LockRequest) (*LockResponse, error)
Unlock(context.Context, *UnlockRequest) (*UnlockResponse, error)
RLock(context.Context, *RLockRequest) (*RLockResponse, error)
RUnlock(context.Context, *RUnlockRequest) (*RUnlockResponse, error)
// contains filtered or unexported methods
}
ServiceServer is the server API for Service service. All implementations must embed UnimplementedServiceServer for forward compatibility.
type Service_GetPeerNodesClient ¶
type Service_GetPeerNodesClient = grpc.ServerStreamingClient[GetPeerNodesResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Service_GetPeerNodesServer ¶
type Service_GetPeerNodesServer = grpc.ServerStreamingServer[GetPeerNodesResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type UnimplementedServiceServer ¶
type UnimplementedServiceServer struct{}
UnimplementedServiceServer 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 (UnimplementedServiceServer) CreateLease ¶
func (UnimplementedServiceServer) CreateLease(context.Context, *CreateLeaseRequest) (*CreateLeaseResponse, error)
func (UnimplementedServiceServer) DropLease ¶
func (UnimplementedServiceServer) DropLease(context.Context, *DropLeaseRequest) (*DropLeaseResponse, error)
func (UnimplementedServiceServer) GetPeerNodes ¶
func (UnimplementedServiceServer) GetPeerNodes(*GetPeerNodesRequest, grpc.ServerStreamingServer[GetPeerNodesResponse]) error
func (UnimplementedServiceServer) KeepLease ¶
func (UnimplementedServiceServer) KeepLease(context.Context, *KeepLeaseRequest) (*KeepLeaseResponse, error)
func (UnimplementedServiceServer) Lock ¶
func (UnimplementedServiceServer) Lock(context.Context, *LockRequest) (*LockResponse, error)
func (UnimplementedServiceServer) RLock ¶ added in v0.32.0
func (UnimplementedServiceServer) RLock(context.Context, *RLockRequest) (*RLockResponse, error)
func (UnimplementedServiceServer) RUnlock ¶ added in v0.32.0
func (UnimplementedServiceServer) RUnlock(context.Context, *RUnlockRequest) (*RUnlockResponse, error)
func (UnimplementedServiceServer) Unlock ¶
func (UnimplementedServiceServer) Unlock(context.Context, *UnlockRequest) (*UnlockResponse, error)
type UnlockRequest ¶
type UnlockRequest struct {
// contains filtered or unexported fields
}
func (*UnlockRequest) GetLeaseId ¶
func (x *UnlockRequest) GetLeaseId() string
func (*UnlockRequest) GetResource ¶
func (x *UnlockRequest) GetResource() []string
func (*UnlockRequest) GetTenantId ¶
func (x *UnlockRequest) GetTenantId() string
func (*UnlockRequest) ProtoMessage ¶
func (*UnlockRequest) ProtoMessage()
func (*UnlockRequest) ProtoReflect ¶
func (x *UnlockRequest) ProtoReflect() protoreflect.Message
func (*UnlockRequest) Reset ¶
func (x *UnlockRequest) Reset()
func (*UnlockRequest) SetLeaseId ¶
func (x *UnlockRequest) SetLeaseId(v string)
func (*UnlockRequest) SetResource ¶
func (x *UnlockRequest) SetResource(v []string)
func (*UnlockRequest) SetTenantId ¶
func (x *UnlockRequest) SetTenantId(v string)
func (*UnlockRequest) String ¶
func (x *UnlockRequest) String() string
type UnlockRequest_builder ¶
type UnlockRequest_builder struct {
LeaseId string
TenantId string
Resource []string
// contains filtered or unexported fields
}
func (UnlockRequest_builder) Build ¶
func (b0 UnlockRequest_builder) Build() *UnlockRequest
type UnlockResponse ¶
type UnlockResponse struct {
// contains filtered or unexported fields
}
func (*UnlockResponse) ProtoMessage ¶
func (*UnlockResponse) ProtoMessage()
func (*UnlockResponse) ProtoReflect ¶
func (x *UnlockResponse) ProtoReflect() protoreflect.Message
func (*UnlockResponse) Reset ¶
func (x *UnlockResponse) Reset()
func (*UnlockResponse) String ¶
func (x *UnlockResponse) String() string
type UnlockResponse_builder ¶
type UnlockResponse_builder struct {
// contains filtered or unexported fields
}
func (UnlockResponse_builder) Build ¶
func (b0 UnlockResponse_builder) Build() *UnlockResponse
type UnsafeServiceServer ¶
type UnsafeServiceServer interface {
// contains filtered or unexported methods
}
UnsafeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ServiceServer will result in compilation errors.