v1beta

package
v0.0.0-...-0d278ef Latest Latest
Warning

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

 Go to latest Published: Aug 11, 2026 License: AGPL-3.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterMetrics 

func RegisterMetrics()

func ValidateAcquireLockRequest 

func ValidateAcquireLockRequest(req *gracklepb.AcquireLockRequest) error

func ValidateAcquireSemaphoreRequest 

func ValidateAcquireSemaphoreRequest(req *gracklepb.AcquireSemaphoreRequest) error

func ValidateArriveAtBarrierRequest 

func ValidateArriveAtBarrierRequest(req *gracklepb.ArriveAtBarrierRequest) error

func ValidateCompleteJobsFromWaitGroupRequest 

func ValidateCompleteJobsFromWaitGroupRequest(req *gracklepb.CompleteJobsFromWaitGroupRequest) error

func ValidateCreateBarrierRequest 

func ValidateCreateBarrierRequest(req *gracklepb.CreateBarrierRequest) error

func ValidateCreateLockLeaseRequest 

func ValidateCreateLockLeaseRequest(req *gracklepb.CreateLockLeaseRequest) error

func ValidateCreateNamespaceRequest 

func ValidateCreateNamespaceRequest(req *gracklepb.CreateNamespaceRequest) error

func ValidateCreateSemaphoreLeaseRequest 

func ValidateCreateSemaphoreLeaseRequest(req *gracklepb.CreateSemaphoreLeaseRequest) error

func ValidateCreateSemaphoreRequest 

func ValidateCreateSemaphoreRequest(req *gracklepb.CreateSemaphoreRequest) error

func ValidateCreateWaitGroupRequest 

func ValidateCreateWaitGroupRequest(req *gracklepb.CreateWaitGroupRequest) error

func ValidateDeleteBarrierRequest 

func ValidateDeleteBarrierRequest(req *gracklepb.DeleteBarrierRequest) error

func ValidateDeleteLockRequest 

func ValidateDeleteLockRequest(req *gracklepb.DeleteLockRequest) error

func ValidateDeleteNamespaceRequest 

func ValidateDeleteNamespaceRequest(req *gracklepb.DeleteNamespaceRequest) error

func ValidateDeleteSemaphoreRequest 

func ValidateDeleteSemaphoreRequest(req *gracklepb.DeleteSemaphoreRequest) error

func ValidateDeleteWaitGroupRequest 

func ValidateDeleteWaitGroupRequest(req *gracklepb.DeleteWaitGroupRequest) error

func ValidateGetBarrierRequest 

func ValidateGetBarrierRequest(req *gracklepb.GetBarrierRequest) error

func ValidateGetLockLeaseRequest 

func ValidateGetLockLeaseRequest(req *gracklepb.GetLockLeaseRequest) error

func ValidateGetLockRequest 

func ValidateGetLockRequest(req *gracklepb.GetLockRequest) error

func ValidateGetNamespaceRequest 

func ValidateGetNamespaceRequest(req *gracklepb.GetNamespaceRequest) error

func ValidateGetSemaphoreLeaseRequest 

func ValidateGetSemaphoreLeaseRequest(req *gracklepb.GetSemaphoreLeaseRequest) error

func ValidateGetSemaphoreRequest 

func ValidateGetSemaphoreRequest(req *gracklepb.GetSemaphoreRequest) error

func ValidateGetWaitGroupRequest 

func ValidateGetWaitGroupRequest(req *gracklepb.GetWaitGroupRequest) error

func ValidateListBarrierParticipantsRequest 

func ValidateListBarrierParticipantsRequest(req *gracklepb.ListBarrierParticipantsRequest) error

func ValidateListBarriersRequest 

func ValidateListBarriersRequest(req *gracklepb.ListBarriersRequest) error

func ValidateListLockLeasesRequest 

func ValidateListLockLeasesRequest(req *gracklepb.ListLockLeasesRequest) error

func ValidateListLocksRequest 

func ValidateListLocksRequest(req *gracklepb.ListLocksRequest) error

func ValidateListNamespacesRequest 

func ValidateListNamespacesRequest(req *gracklepb.ListNamespacesRequest) error

func ValidateListSemaphoreHoldersRequest 

func ValidateListSemaphoreHoldersRequest(req *gracklepb.ListSemaphoreHoldersRequest) error

func ValidateListSemaphoreLeasesRequest 

func ValidateListSemaphoreLeasesRequest(req *gracklepb.ListSemaphoreLeasesRequest) error

func ValidateListSemaphoresRequest 

func ValidateListSemaphoresRequest(req *gracklepb.ListSemaphoresRequest) error

func ValidateListWaitGroupCompletedJobsRequest 

func ValidateListWaitGroupCompletedJobsRequest(req *gracklepb.ListWaitGroupCompletedJobsRequest) error

func ValidateListWaitGroupsRequest 

func ValidateListWaitGroupsRequest(req *gracklepb.ListWaitGroupsRequest) error

func ValidateRefreshLockLeaseRequest 

func ValidateRefreshLockLeaseRequest(req *gracklepb.RefreshLockLeaseRequest) error

func ValidateRefreshSemaphoreLeaseRequest 

func ValidateRefreshSemaphoreLeaseRequest(req *gracklepb.RefreshSemaphoreLeaseRequest) error

func ValidateReleaseLockRequest 

func ValidateReleaseLockRequest(req *gracklepb.ReleaseLockRequest) error

func ValidateReleaseSemaphoreRequest 

func ValidateReleaseSemaphoreRequest(req *gracklepb.ReleaseSemaphoreRequest) error

func ValidateRevokeLockLeaseRequest 

func ValidateRevokeLockLeaseRequest(req *gracklepb.RevokeLockLeaseRequest) error

func ValidateRevokeSemaphoreLeaseRequest 

func ValidateRevokeSemaphoreLeaseRequest(req *gracklepb.RevokeSemaphoreLeaseRequest) error

func ValidateUpdateBarrierRequest 

func ValidateUpdateBarrierRequest(req *gracklepb.UpdateBarrierRequest) error

func ValidateUpdateNamespaceRequest 

func ValidateUpdateNamespaceRequest(req *gracklepb.UpdateNamespaceRequest) error

func ValidateUpdateSemaphoreRequest 

func ValidateUpdateSemaphoreRequest(req *gracklepb.UpdateSemaphoreRequest) error

func ValidateUpdateWaitGroupRequest 

func ValidateUpdateWaitGroupRequest(req *gracklepb.UpdateWaitGroupRequest) error

func ValidateWaitAtBarrierRequest 

func ValidateWaitAtBarrierRequest(req *gracklepb.WaitAtBarrierRequest) error

func ValidateWaitForWaitGroupRequest 

func ValidateWaitForWaitGroupRequest(req *gracklepb.WaitForWaitGroupRequest) error

Types

type AuthenticationMiddleware 

type AuthenticationMiddleware struct {
	// contains filtered or unexported fields
}

func NewAuthenticationMiddleware 

func NewAuthenticationMiddleware(authKeysPath string) *AuthenticationMiddleware

func (*AuthenticationMiddleware) Unary 

func (m *AuthenticationMiddleware) Unary(
	ctx context.Context,
	req any,
	info *grpc.UnaryServerInfo,
	handler grpc.UnaryHandler,
) (any, error)

type GrackleApiServer 

type GrackleApiServer struct {
	gracklepb.UnimplementedGrackleApiServer
	// contains filtered or unexported fields
}

func NewGrackleApiServer 

func NewGrackleApiServer(grackleClient coreapis.GrackleClientApi) *GrackleApiServer

func (*GrackleApiServer) AcquireLock 

func (s *GrackleApiServer) AcquireLock(ctx context.Context, req *gracklepb.AcquireLockRequest) (*gracklepb.AcquireLockResponse, error)

func (*GrackleApiServer) AcquireSemaphore 

func (s *GrackleApiServer) AcquireSemaphore(ctx context.Context, req *gracklepb.AcquireSemaphoreRequest) (*gracklepb.AcquireSemaphoreResponse, error)

func (*GrackleApiServer) ArriveAtBarrier 

func (s *GrackleApiServer) ArriveAtBarrier(ctx context.Context, req *gracklepb.ArriveAtBarrierRequest) (*gracklepb.ArriveAtBarrierResponse, error)

func (*GrackleApiServer) Close 

func (s *GrackleApiServer) Close()

func (*GrackleApiServer) CompleteJobsFromWaitGroup 

func (s *GrackleApiServer) CompleteJobsFromWaitGroup(ctx context.Context, req *gracklepb.CompleteJobsFromWaitGroupRequest) (*gracklepb.CompleteJobsFromWaitGroupResponse, error)

func (*GrackleApiServer) CreateBarrier 

func (s *GrackleApiServer) CreateBarrier(ctx context.Context, req *gracklepb.CreateBarrierRequest) (*gracklepb.CreateBarrierResponse, error)

func (*GrackleApiServer) CreateLockLease 

func (s *GrackleApiServer) CreateLockLease(ctx context.Context, req *gracklepb.CreateLockLeaseRequest) (*gracklepb.CreateLockLeaseResponse, error)

func (*GrackleApiServer) CreateNamespace 

func (s *GrackleApiServer) CreateNamespace(ctx context.Context, req *gracklepb.CreateNamespaceRequest) (*gracklepb.CreateNamespaceResponse, error)

func (*GrackleApiServer) CreateSemaphore 

func (s *GrackleApiServer) CreateSemaphore(ctx context.Context, req *gracklepb.CreateSemaphoreRequest) (*gracklepb.CreateSemaphoreResponse, error)

func (*GrackleApiServer) CreateSemaphoreLease 

func (s *GrackleApiServer) CreateSemaphoreLease(ctx context.Context, req *gracklepb.CreateSemaphoreLeaseRequest) (*gracklepb.CreateSemaphoreLeaseResponse, error)

func (*GrackleApiServer) CreateWaitGroup 

func (s *GrackleApiServer) CreateWaitGroup(ctx context.Context, req *gracklepb.CreateWaitGroupRequest) (*gracklepb.CreateWaitGroupResponse, error)

func (*GrackleApiServer) DeleteBarrier 

func (s *GrackleApiServer) DeleteBarrier(ctx context.Context, req *gracklepb.DeleteBarrierRequest) (*gracklepb.DeleteBarrierResponse, error)

func (*GrackleApiServer) DeleteLock 

func (s *GrackleApiServer) DeleteLock(ctx context.Context, req *gracklepb.DeleteLockRequest) (*gracklepb.DeleteLockResponse, error)

func (*GrackleApiServer) DeleteNamespace 

func (s *GrackleApiServer) DeleteNamespace(ctx context.Context, req *gracklepb.DeleteNamespaceRequest) (*gracklepb.DeleteNamespaceResponse, error)

func (*GrackleApiServer) DeleteSemaphore 

func (s *GrackleApiServer) DeleteSemaphore(ctx context.Context, req *gracklepb.DeleteSemaphoreRequest) (*gracklepb.DeleteSemaphoreResponse, error)

func (*GrackleApiServer) DeleteWaitGroup 

func (s *GrackleApiServer) DeleteWaitGroup(ctx context.Context, req *gracklepb.DeleteWaitGroupRequest) (*gracklepb.DeleteWaitGroupResponse, error)

func (*GrackleApiServer) GetBarrier 

func (s *GrackleApiServer) GetBarrier(ctx context.Context, req *gracklepb.GetBarrierRequest) (*gracklepb.GetBarrierResponse, error)

func (*GrackleApiServer) GetLock 

func (s *GrackleApiServer) GetLock(ctx context.Context, req *gracklepb.GetLockRequest) (*gracklepb.GetLockResponse, error)

func (*GrackleApiServer) GetLockLease 

func (s *GrackleApiServer) GetLockLease(ctx context.Context, req *gracklepb.GetLockLeaseRequest) (*gracklepb.GetLockLeaseResponse, error)

func (*GrackleApiServer) GetNamespace 

func (s *GrackleApiServer) GetNamespace(ctx context.Context, req *gracklepb.GetNamespaceRequest) (*gracklepb.GetNamespaceResponse, error)

func (*GrackleApiServer) GetSemaphore 

func (s *GrackleApiServer) GetSemaphore(ctx context.Context, req *gracklepb.GetSemaphoreRequest) (*gracklepb.GetSemaphoreResponse, error)

func (*GrackleApiServer) GetSemaphoreLease 

func (s *GrackleApiServer) GetSemaphoreLease(ctx context.Context, req *gracklepb.GetSemaphoreLeaseRequest) (*gracklepb.GetSemaphoreLeaseResponse, error)

func (*GrackleApiServer) GetWaitGroup 

func (s *GrackleApiServer) GetWaitGroup(ctx context.Context, req *gracklepb.GetWaitGroupRequest) (*gracklepb.GetWaitGroupResponse, error)

func (*GrackleApiServer) ListBarrierParticipants 

func (s *GrackleApiServer) ListBarrierParticipants(ctx context.Context, req *gracklepb.ListBarrierParticipantsRequest) (*gracklepb.ListBarrierParticipantsResponse, error)

func (*GrackleApiServer) ListBarriers 

func (s *GrackleApiServer) ListBarriers(ctx context.Context, req *gracklepb.ListBarriersRequest) (*gracklepb.ListBarriersResponse, error)

func (*GrackleApiServer) ListLockLeases 

func (s *GrackleApiServer) ListLockLeases(ctx context.Context, req *gracklepb.ListLockLeasesRequest) (*gracklepb.ListLockLeasesResponse, error)

func (*GrackleApiServer) ListLocks 

func (s *GrackleApiServer) ListLocks(ctx context.Context, req *gracklepb.ListLocksRequest) (*gracklepb.ListLocksResponse, error)

func (*GrackleApiServer) ListNamespaces 

func (s *GrackleApiServer) ListNamespaces(ctx context.Context, req *gracklepb.ListNamespacesRequest) (*gracklepb.ListNamespacesResponse, error)

func (*GrackleApiServer) ListSemaphoreHolders 

func (s *GrackleApiServer) ListSemaphoreHolders(ctx context.Context, req *gracklepb.ListSemaphoreHoldersRequest) (*gracklepb.ListSemaphoreHoldersResponse, error)

func (*GrackleApiServer) ListSemaphoreLeases 

func (s *GrackleApiServer) ListSemaphoreLeases(ctx context.Context, req *gracklepb.ListSemaphoreLeasesRequest) (*gracklepb.ListSemaphoreLeasesResponse, error)

func (*GrackleApiServer) ListSemaphores 

func (s *GrackleApiServer) ListSemaphores(ctx context.Context, req *gracklepb.ListSemaphoresRequest) (*gracklepb.ListSemaphoresResponse, error)

func (*GrackleApiServer) ListWaitGroupCompletedJobs 

func (s *GrackleApiServer) ListWaitGroupCompletedJobs(ctx context.Context, req *gracklepb.ListWaitGroupCompletedJobsRequest) (*gracklepb.ListWaitGroupCompletedJobsResponse, error)

func (*GrackleApiServer) ListWaitGroups 

func (s *GrackleApiServer) ListWaitGroups(ctx context.Context, req *gracklepb.ListWaitGroupsRequest) (*gracklepb.ListWaitGroupsResponse, error)

func (*GrackleApiServer) RefreshLockLease 

func (s *GrackleApiServer) RefreshLockLease(ctx context.Context, req *gracklepb.RefreshLockLeaseRequest) (*gracklepb.RefreshLockLeaseResponse, error)

func (*GrackleApiServer) RefreshSemaphoreLease 

func (s *GrackleApiServer) RefreshSemaphoreLease(ctx context.Context, req *gracklepb.RefreshSemaphoreLeaseRequest) (*gracklepb.RefreshSemaphoreLeaseResponse, error)

func (*GrackleApiServer) ReleaseLock 

func (s *GrackleApiServer) ReleaseLock(ctx context.Context, req *gracklepb.ReleaseLockRequest) (*gracklepb.ReleaseLockResponse, error)

func (*GrackleApiServer) ReleaseSemaphore 

func (s *GrackleApiServer) ReleaseSemaphore(ctx context.Context, req *gracklepb.ReleaseSemaphoreRequest) (*gracklepb.ReleaseSemaphoreResponse, error)

func (*GrackleApiServer) RevokeLockLease 

func (s *GrackleApiServer) RevokeLockLease(ctx context.Context, req *gracklepb.RevokeLockLeaseRequest) (*gracklepb.RevokeLockLeaseResponse, error)

func (*GrackleApiServer) RevokeSemaphoreLease 

func (s *GrackleApiServer) RevokeSemaphoreLease(ctx context.Context, req *gracklepb.RevokeSemaphoreLeaseRequest) (*gracklepb.RevokeSemaphoreLeaseResponse, error)

func (*GrackleApiServer) UpdateBarrier 

func (s *GrackleApiServer) UpdateBarrier(ctx context.Context, req *gracklepb.UpdateBarrierRequest) (*gracklepb.UpdateBarrierResponse, error)

func (*GrackleApiServer) UpdateNamespace 

func (s *GrackleApiServer) UpdateNamespace(ctx context.Context, req *gracklepb.UpdateNamespaceRequest) (*gracklepb.UpdateNamespaceResponse, error)

func (*GrackleApiServer) UpdateSemaphore 

func (s *GrackleApiServer) UpdateSemaphore(ctx context.Context, req *gracklepb.UpdateSemaphoreRequest) (*gracklepb.UpdateSemaphoreResponse, error)

func (*GrackleApiServer) UpdateWaitGroup 

func (s *GrackleApiServer) UpdateWaitGroup(ctx context.Context, req *gracklepb.UpdateWaitGroupRequest) (*gracklepb.UpdateWaitGroupResponse, error)

func (*GrackleApiServer) WaitAtBarrier 

func (s *GrackleApiServer) WaitAtBarrier(ctx context.Context, req *gracklepb.WaitAtBarrierRequest) (*gracklepb.WaitAtBarrierResponse, error)

func (*GrackleApiServer) WaitForWaitGroup 

func (s *GrackleApiServer) WaitForWaitGroup(ctx context.Context, req *gracklepb.WaitForWaitGroupRequest) (*gracklepb.WaitForWaitGroupResponse, error)

type GrackleApiServerHandler 

type GrackleApiServerHandler struct {
	// contains filtered or unexported fields
}

func NewGrackleApiServerHandler 

func NewGrackleApiServerHandler(grackleClient coreapis.GrackleClientApi) *GrackleApiServerHandler

NewGrackleApiServerHandler builds a handler backed by the given core client.

func (*GrackleApiServerHandler) AcquireLock 

func (s *GrackleApiServerHandler) AcquireLock(ctx context.Context, req *gracklepb.AcquireLockRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.AcquireLockResponse, error)

func (*GrackleApiServerHandler) AcquireSemaphore 

func (s *GrackleApiServerHandler) AcquireSemaphore(ctx context.Context, req *gracklepb.AcquireSemaphoreRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.AcquireSemaphoreResponse, error)

func (*GrackleApiServerHandler) ArriveAtBarrier 

func (s *GrackleApiServerHandler) ArriveAtBarrier(ctx context.Context, req *gracklepb.ArriveAtBarrierRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.ArriveAtBarrierResponse, error)

func (*GrackleApiServerHandler) CompleteJobsFromWaitGroup 

func (s *GrackleApiServerHandler) CompleteJobsFromWaitGroup(ctx context.Context, req *gracklepb.CompleteJobsFromWaitGroupRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.CompleteJobsFromWaitGroupResponse, error)

func (*GrackleApiServerHandler) CreateBarrier 

func (s *GrackleApiServerHandler) CreateBarrier(ctx context.Context, req *gracklepb.CreateBarrierRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.CreateBarrierResponse, error)

func (*GrackleApiServerHandler) CreateLockLease 

func (s *GrackleApiServerHandler) CreateLockLease(ctx context.Context, req *gracklepb.CreateLockLeaseRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.CreateLockLeaseResponse, error)

func (*GrackleApiServerHandler) CreateNamespace 

func (s *GrackleApiServerHandler) CreateNamespace(ctx context.Context, req *gracklepb.CreateNamespaceRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.CreateNamespaceResponse, error)

func (*GrackleApiServerHandler) CreateSemaphore 

func (s *GrackleApiServerHandler) CreateSemaphore(ctx context.Context, req *gracklepb.CreateSemaphoreRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.CreateSemaphoreResponse, error)

func (*GrackleApiServerHandler) CreateSemaphoreLease 

func (s *GrackleApiServerHandler) CreateSemaphoreLease(ctx context.Context, req *gracklepb.CreateSemaphoreLeaseRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.CreateSemaphoreLeaseResponse, error)

func (*GrackleApiServerHandler) CreateWaitGroup 

func (s *GrackleApiServerHandler) CreateWaitGroup(ctx context.Context, req *gracklepb.CreateWaitGroupRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.CreateWaitGroupResponse, error)

func (*GrackleApiServerHandler) DeleteBarrier 

func (s *GrackleApiServerHandler) DeleteBarrier(ctx context.Context, req *gracklepb.DeleteBarrierRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.DeleteBarrierResponse, error)

func (*GrackleApiServerHandler) DeleteLock 

func (s *GrackleApiServerHandler) DeleteLock(ctx context.Context, req *gracklepb.DeleteLockRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.DeleteLockResponse, error)

func (*GrackleApiServerHandler) DeleteNamespace 

func (s *GrackleApiServerHandler) DeleteNamespace(ctx context.Context, req *gracklepb.DeleteNamespaceRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.DeleteNamespaceResponse, error)

TODO what to do with active AcquireLock, WaitForWaitGroup, etc requests?

func (*GrackleApiServerHandler) DeleteSemaphore 

func (s *GrackleApiServerHandler) DeleteSemaphore(ctx context.Context, req *gracklepb.DeleteSemaphoreRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.DeleteSemaphoreResponse, error)

func (*GrackleApiServerHandler) DeleteWaitGroup 

func (s *GrackleApiServerHandler) DeleteWaitGroup(ctx context.Context, req *gracklepb.DeleteWaitGroupRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.DeleteWaitGroupResponse, error)

func (*GrackleApiServerHandler) GetBarrier 

func (s *GrackleApiServerHandler) GetBarrier(ctx context.Context, req *gracklepb.GetBarrierRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.GetBarrierResponse, error)

func (*GrackleApiServerHandler) GetLock 

func (s *GrackleApiServerHandler) GetLock(ctx context.Context, req *gracklepb.GetLockRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.GetLockResponse, error)

func (*GrackleApiServerHandler) GetLockLease 

func (s *GrackleApiServerHandler) GetLockLease(ctx context.Context, req *gracklepb.GetLockLeaseRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.GetLockLeaseResponse, error)

func (*GrackleApiServerHandler) GetNamespace 

func (s *GrackleApiServerHandler) GetNamespace(ctx context.Context, req *gracklepb.GetNamespaceRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.GetNamespaceResponse, error)

func (*GrackleApiServerHandler) GetSemaphore 

func (s *GrackleApiServerHandler) GetSemaphore(ctx context.Context, req *gracklepb.GetSemaphoreRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.GetSemaphoreResponse, error)

func (*GrackleApiServerHandler) GetSemaphoreLease 

func (s *GrackleApiServerHandler) GetSemaphoreLease(ctx context.Context, req *gracklepb.GetSemaphoreLeaseRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.GetSemaphoreLeaseResponse, error)

func (*GrackleApiServerHandler) GetWaitGroup 

func (s *GrackleApiServerHandler) GetWaitGroup(ctx context.Context, req *gracklepb.GetWaitGroupRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.GetWaitGroupResponse, error)

func (*GrackleApiServerHandler) ListBarrierParticipants 

func (s *GrackleApiServerHandler) ListBarrierParticipants(ctx context.Context, req *gracklepb.ListBarrierParticipantsRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.ListBarrierParticipantsResponse, error)

func (*GrackleApiServerHandler) ListBarriers 

func (s *GrackleApiServerHandler) ListBarriers(ctx context.Context, req *gracklepb.ListBarriersRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.ListBarriersResponse, error)

func (*GrackleApiServerHandler) ListLockLeases 

func (s *GrackleApiServerHandler) ListLockLeases(ctx context.Context, req *gracklepb.ListLockLeasesRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.ListLockLeasesResponse, error)

func (*GrackleApiServerHandler) ListLocks 

func (s *GrackleApiServerHandler) ListLocks(ctx context.Context, req *gracklepb.ListLocksRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.ListLocksResponse, error)

func (*GrackleApiServerHandler) ListNamespaces 

func (s *GrackleApiServerHandler) ListNamespaces(ctx context.Context, req *gracklepb.ListNamespacesRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.ListNamespacesResponse, error)

func (*GrackleApiServerHandler) ListSemaphoreHolders 

func (s *GrackleApiServerHandler) ListSemaphoreHolders(ctx context.Context, req *gracklepb.ListSemaphoreHoldersRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.ListSemaphoreHoldersResponse, error)

func (*GrackleApiServerHandler) ListSemaphoreLeases 

func (s *GrackleApiServerHandler) ListSemaphoreLeases(ctx context.Context, req *gracklepb.ListSemaphoreLeasesRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.ListSemaphoreLeasesResponse, error)

func (*GrackleApiServerHandler) ListSemaphores 

func (s *GrackleApiServerHandler) ListSemaphores(ctx context.Context, req *gracklepb.ListSemaphoresRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.ListSemaphoresResponse, error)

func (*GrackleApiServerHandler) ListWaitGroupCompletedJobs 

func (s *GrackleApiServerHandler) ListWaitGroupCompletedJobs(ctx context.Context, req *gracklepb.ListWaitGroupCompletedJobsRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.ListWaitGroupCompletedJobsResponse, error)

func (*GrackleApiServerHandler) ListWaitGroups 

func (s *GrackleApiServerHandler) ListWaitGroups(ctx context.Context, req *gracklepb.ListWaitGroupsRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.ListWaitGroupsResponse, error)

func (*GrackleApiServerHandler) RefreshLockLease 

func (s *GrackleApiServerHandler) RefreshLockLease(ctx context.Context, req *gracklepb.RefreshLockLeaseRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.RefreshLockLeaseResponse, error)

func (*GrackleApiServerHandler) RefreshSemaphoreLease 

func (s *GrackleApiServerHandler) RefreshSemaphoreLease(ctx context.Context, req *gracklepb.RefreshSemaphoreLeaseRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.RefreshSemaphoreLeaseResponse, error)

func (*GrackleApiServerHandler) ReleaseLock 

func (s *GrackleApiServerHandler) ReleaseLock(ctx context.Context, req *gracklepb.ReleaseLockRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.ReleaseLockResponse, error)

func (*GrackleApiServerHandler) ReleaseSemaphore 

func (s *GrackleApiServerHandler) ReleaseSemaphore(ctx context.Context, req *gracklepb.ReleaseSemaphoreRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.ReleaseSemaphoreResponse, error)

func (*GrackleApiServerHandler) RevokeLockLease 

func (s *GrackleApiServerHandler) RevokeLockLease(ctx context.Context, req *gracklepb.RevokeLockLeaseRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.RevokeLockLeaseResponse, error)

func (*GrackleApiServerHandler) RevokeSemaphoreLease 

func (s *GrackleApiServerHandler) RevokeSemaphoreLease(ctx context.Context, req *gracklepb.RevokeSemaphoreLeaseRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.RevokeSemaphoreLeaseResponse, error)

func (*GrackleApiServerHandler) Stop 

func (s *GrackleApiServerHandler) Stop()

func (*GrackleApiServerHandler) UpdateBarrier 

func (s *GrackleApiServerHandler) UpdateBarrier(ctx context.Context, req *gracklepb.UpdateBarrierRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.UpdateBarrierResponse, error)

func (*GrackleApiServerHandler) UpdateNamespace 

func (s *GrackleApiServerHandler) UpdateNamespace(ctx context.Context, req *gracklepb.UpdateNamespaceRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.UpdateNamespaceResponse, error)

func (*GrackleApiServerHandler) UpdateSemaphore 

func (s *GrackleApiServerHandler) UpdateSemaphore(ctx context.Context, req *gracklepb.UpdateSemaphoreRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.UpdateSemaphoreResponse, error)

func (*GrackleApiServerHandler) UpdateWaitGroup 

func (s *GrackleApiServerHandler) UpdateWaitGroup(ctx context.Context, req *gracklepb.UpdateWaitGroupRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.UpdateWaitGroupResponse, error)

func (*GrackleApiServerHandler) WaitAtBarrier 

func (s *GrackleApiServerHandler) WaitAtBarrier(ctx context.Context, req *gracklepb.WaitAtBarrierRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.WaitAtBarrierResponse, error)

func (*GrackleApiServerHandler) WaitForWaitGroup 

func (s *GrackleApiServerHandler) WaitForWaitGroup(ctx context.Context, req *gracklepb.WaitForWaitGroupRequest, accountId uint64, limits grackle.ServiceLimits) (*gracklepb.WaitForWaitGroupResponse, error)

type MonitoringMiddleware 

type MonitoringMiddleware struct {
}

func NewMonitoringMiddleware 

func NewMonitoringMiddleware() *MonitoringMiddleware

func (*MonitoringMiddleware) Unary 

func (m *MonitoringMiddleware) Unary(
	ctx context.Context,
	req any,
	info *grpc.UnaryServerInfo,
	handler grpc.UnaryHandler,
) (any, 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.