locksv1alpha1

type HistoryRequest struct {

	// *
	// Name of the lock to get the history of. If empty, all locks will be
	// monitored.
	Name []string `protobuf:"bytes,1,rep,name=name,proto3" json:"name,omitempty"`
	// *
	// Maximum number of events to return. If empty, all events will be
	// returned.
	Limit *uint32 `protobuf:"varint,2,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	// *
	// If set, only events after this timestamp will be returned.
	After *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=after,proto3,oneof" json:"after,omitempty"`
	// contains filtered or unexported fields
}

type HistoryResponse struct {

	// *
	// Timestamp of the event.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Types that are assignable to Event:
	//
	//	*HistoryResponse_Acquired
	//	*HistoryResponse_Extended
	//	*HistoryResponse_Released
	Event isHistoryResponse_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

type HistoryResponse_Acquired struct {
	// *
	// A lock was acquired.
	Acquired *LockAcquiredEvent `protobuf:"bytes,2,opt,name=acquired,proto3,oneof"`
}

type HistoryResponse_Extended struct {
	// *
	// A lock was extended.
	Extended *LockExtendedEvent `protobuf:"bytes,3,opt,name=extended,proto3,oneof"`
}

type HistoryResponse_Released struct {
	// *
	// A lock was released.
	Released *LockReleasedEvent `protobuf:"bytes,4,opt,name=released,proto3,oneof"`
}

type LockAcquiredEvent struct {

	// *
	// Name of the lock that was acquired.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// *
	// Owner of the lock, intended to be human-readable to allow
	// distinguishing between different clients.
	Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
	// *
	// Expires is the timestamp at which the lock will expire on its own
	// if it is not extended or released.
	Expires *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=expires,proto3" json:"expires,omitempty"`
	// contains filtered or unexported fields
}

type LockExtendedEvent struct {

	// *
	// Name of the lock that was extended.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// *
	// Owner of the lock, intended to be human-readable to allow
	// distinguishing between different clients.
	Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
	// *
	// Expires is the timestamp at which the lock will expire on its own
	// if it is not extended or released.
	Expires *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=expires,proto3" json:"expires,omitempty"`
	// contains filtered or unexported fields
}

type LockReleasedEvent struct {

	// *
	// Name of the lock that was released.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// *
	// Owner of the lock, intended to be human-readable to allow
	// distinguishing between different clients.
	Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
	// contains filtered or unexported fields
}

type LockRequest struct {

	// * The type of lock request.
	// Types that are assignable to Lock:
	//
	//	*LockRequest_Acquire_
	//	*LockRequest_Extend_
	//	*LockRequest_Release_
	Lock isLockRequest_Lock `protobuf_oneof:"lock"`
	// contains filtered or unexported fields
}

type LockRequest_Acquire struct {

	// *
	// Name of the lock to acquire. Names are globally unique, and must
	// match the regex `[a-zA-Z0-9_-]+`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// *
	// Expires is the timestamp at which the lock will expire on its own
	// if it is not extended or released. It is recommended to keep this
	// value small, and extend the lock at an interval smaller than this
	// value.
	Expires *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expires,proto3" json:"expires,omitempty"`
	// *
	// Maximum time to wait before giving up on acquiring the lock. This
	// lets the client simplify its logic by not having to handle retries
	// itself. If the lock is not acquired before this timeout, the
	// request will fail with a `Rejected` response.
	Timeout *durationpb.Duration `protobuf:"bytes,3,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

type LockRequest_Acquire_ struct {
	// * Acquire a new lock.
	Acquire *LockRequest_Acquire `protobuf:"bytes,1,opt,name=acquire,proto3,oneof"`
}

type LockRequest_Extend struct {

	// *
	// Name of the lock to extend, must match the name of the lock you
	// already acquired with an `Acquire` request.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// *
	// Token is the token returned by the `Acquire` request. It is used
	// to verify that you are the owner of the lock you are trying to
	// extend.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// *
	// Expires is the new timestamp at which the lock will expire on its
	// own if it is not extended or released. See the `Acquire` request
	// for more information.
	Expires *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=expires,proto3" json:"expires,omitempty"`
	// contains filtered or unexported fields
}

type LockRequest_Extend_ struct {
	// * Extend the duration of a lock you already hold.
	Extend *LockRequest_Extend `protobuf:"bytes,2,opt,name=extend,proto3,oneof"`
}

type LockRequest_Release struct {

	// *
	// Name of the lock to release, must match the name of the lock you
	// already acquired with an `Acquire` request.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// *
	// Token is the token returned by the `Acquire` request. It is used
	// to verify that you are the owner of the lock you are trying to
	// release.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

type LockRequest_Release_ struct {
	// * Release a lock you already hold.
	Release *LockRequest_Release `protobuf:"bytes,3,opt,name=release,proto3,oneof"`
}

type LockResponse struct {

	// * The type of lock response.
	// Types that are assignable to Lock:
	//
	//	*LockResponse_Acquired_
	//	*LockResponse_Extended_
	//	*LockResponse_Released_
	//	*LockResponse_Rejected_
	Lock isLockResponse_Lock `protobuf_oneof:"lock"`
	// contains filtered or unexported fields
}

type LockResponse_Acquired struct {

	// *
	// Name of the lock that was acquired.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// *
	// Token is used to verify that you are the owner of the lock you are
	// trying to extend or release.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

type LockResponse_Acquired_ struct {
	// * A lock was acquired or extended.
	Acquired *LockResponse_Acquired `protobuf:"bytes,1,opt,name=acquired,proto3,oneof"`
}

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

type LockResponse_Extended_ struct {
	// * A lock was extended.
	Extended *LockResponse_Extended `protobuf:"bytes,2,opt,name=extended,proto3,oneof"`
}

type LockResponse_Rejected struct {

	// *
	// Name of the lock that was rejected.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// *
	// The time the lock will expire.
	Expires *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expires,proto3" json:"expires,omitempty"`
	// contains filtered or unexported fields
}

type LockResponse_Rejected_ struct {
	// * A lock was rejected.
	Rejected *LockResponse_Rejected `protobuf:"bytes,4,opt,name=rejected,proto3,oneof"`
}

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

type LockResponse_Released_ struct {
	// * A lock was released.
	Released *LockResponse_Released `protobuf:"bytes,3,opt,name=released,proto3,oneof"`
}

type LocksServiceClient interface {
	// *
	// Open a stream that will let you acquire locks, extend them or release
	// them.
	Lock(ctx context.Context, opts ...grpc.CallOption) (LocksService_LockClient, error)
	// *
	// Monitor the state of a lock. This will send a message every time the
	// lock is acquired, extended or released.
	Monitor(ctx context.Context, in *MonitorRequest, opts ...grpc.CallOption) (LocksService_MonitorClient, error)
	// *
	// Get the history of a lock. Similar to `Monitor`, but will send the
	// entire history of the lock, and then close the stream.
	History(ctx context.Context, in *HistoryRequest, opts ...grpc.CallOption) (LocksService_HistoryClient, error)
}

type LocksServiceServer interface {
	// *
	// Open a stream that will let you acquire locks, extend them or release
	// them.
	Lock(LocksService_LockServer) error
	// *
	// Monitor the state of a lock. This will send a message every time the
	// lock is acquired, extended or released.
	Monitor(*MonitorRequest, LocksService_MonitorServer) error
	// *
	// Get the history of a lock. Similar to `Monitor`, but will send the
	// entire history of the lock, and then close the stream.
	History(*HistoryRequest, LocksService_HistoryServer) error
	// contains filtered or unexported methods
}

type LocksService_HistoryClient interface {
	Recv() (*HistoryResponse, error)
	grpc.ClientStream
}

type LocksService_HistoryServer interface {
	Send(*HistoryResponse) error
	grpc.ServerStream
}

type LocksService_LockClient interface {
	Send(*LockRequest) error
	Recv() (*LockResponse, error)
	grpc.ClientStream
}

type LocksService_LockServer interface {
	Send(*LockResponse) error
	Recv() (*LockRequest, error)
	grpc.ServerStream
}

type LocksService_MonitorClient interface {
	Recv() (*MonitorResponse, error)
	grpc.ClientStream
}

type LocksService_MonitorServer interface {
	Send(*MonitorResponse) error
	grpc.ServerStream
}

type MonitorRequest struct {

	// *
	// Name of the lock to monitor. If empty, all locks will be monitored.
	Name []string `protobuf:"bytes,1,rep,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type MonitorResponse struct {

	// *
	// Timestamp of the event.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Types that are assignable to Event:
	//
	//	*MonitorResponse_Acquired
	//	*MonitorResponse_Extended
	//	*MonitorResponse_Released
	Event isMonitorResponse_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

type MonitorResponse_Acquired struct {
	// *
	// A lock was acquired.
	Acquired *LockAcquiredEvent `protobuf:"bytes,2,opt,name=acquired,proto3,oneof"`
}

type MonitorResponse_Extended struct {
	// *
	// A lock was extended.
	Extended *LockExtendedEvent `protobuf:"bytes,3,opt,name=extended,proto3,oneof"`
}

type MonitorResponse_Released struct {
	// *
	// A lock was released.
	Released *LockReleasedEvent `protobuf:"bytes,4,opt,name=released,proto3,oneof"`
}

type UnimplementedLocksServiceServer struct {
}

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