preview

package
v0.0.0-...-73cfedd Latest Latest
Warning

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

 Go to latest Published: Apr 15, 2026 License: AGPL-3.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterMetrics 

func RegisterMetrics()

func ValidateAcquireLockRequest 

func ValidateAcquireLockRequest(request *gracklepb.AcquireLockRequest) error

func ValidateAcquireSemaphoreRequest 

func ValidateAcquireSemaphoreRequest(request *gracklepb.AcquireSemaphoreRequest) error

func ValidateAddJobsToWaitGroupRequest 

func ValidateAddJobsToWaitGroupRequest(request *gracklepb.AddJobsToWaitGroupRequest) error

func ValidateArriveAtBarrierRequest 

func ValidateArriveAtBarrierRequest(request *gracklepb.ArriveAtBarrierRequest) error

func ValidateCompleteJobsFromWaitGroupRequest 

func ValidateCompleteJobsFromWaitGroupRequest(request *gracklepb.CompleteJobsFromWaitGroupRequest) error

func ValidateCreateBarrierRequest 

func ValidateCreateBarrierRequest(request *gracklepb.CreateBarrierRequest) error

func ValidateCreateNamespaceRequest 

func ValidateCreateNamespaceRequest(request *gracklepb.CreateNamespaceRequest) error

func ValidateCreateSemaphoreRequest 

func ValidateCreateSemaphoreRequest(request *gracklepb.CreateSemaphoreRequest) error

func ValidateCreateWaitGroupRequest 

func ValidateCreateWaitGroupRequest(request *gracklepb.CreateWaitGroupRequest) error

func ValidateDeleteBarrierRequest 

func ValidateDeleteBarrierRequest(request *gracklepb.DeleteBarrierRequest) error

func ValidateDeleteLockRequest 

func ValidateDeleteLockRequest(request *gracklepb.DeleteLockRequest) error

func ValidateDeleteNamespaceRequest 

func ValidateDeleteNamespaceRequest(request *gracklepb.DeleteNamespaceRequest) error

func ValidateDeleteSemaphoreRequest 

func ValidateDeleteSemaphoreRequest(request *gracklepb.DeleteSemaphoreRequest) error

func ValidateDeleteWaitGroupRequest 

func ValidateDeleteWaitGroupRequest(request *gracklepb.DeleteWaitGroupRequest) error

func ValidateGetBarrierRequest 

func ValidateGetBarrierRequest(request *gracklepb.GetBarrierRequest) error

func ValidateGetLockRequest 

func ValidateGetLockRequest(request *gracklepb.GetLockRequest) error

func ValidateGetNamespaceRequest 

func ValidateGetNamespaceRequest(request *gracklepb.GetNamespaceRequest) error

func ValidateGetSemaphoreRequest 

func ValidateGetSemaphoreRequest(request *gracklepb.GetSemaphoreRequest) error

func ValidateGetWaitGroupRequest 

func ValidateGetWaitGroupRequest(request *gracklepb.GetWaitGroupRequest) error

func ValidateListBarrierParticipantsRequest 

func ValidateListBarrierParticipantsRequest(request *gracklepb.ListBarrierParticipantsRequest) error

func ValidateListBarriersRequest 

func ValidateListBarriersRequest(request *gracklepb.ListBarriersRequest) error

func ValidateListLocksRequest 

func ValidateListLocksRequest(request *gracklepb.ListLocksRequest) error

func ValidateListNamespacesRequest 

func ValidateListNamespacesRequest(request *gracklepb.ListNamespacesRequest) error

func ValidateListSemaphoreHoldersRequest 

func ValidateListSemaphoreHoldersRequest(request *gracklepb.ListSemaphoreHoldersRequest) error

func ValidateListSemaphoresRequest 

func ValidateListSemaphoresRequest(request *gracklepb.ListSemaphoresRequest) error

func ValidateListWaitGroupJobsRequest 

func ValidateListWaitGroupJobsRequest(request *gracklepb.ListWaitGroupJobsRequest) error

func ValidateListWaitGroupsRequest 

func ValidateListWaitGroupsRequest(request *gracklepb.ListWaitGroupsRequest) error

func ValidateReleaseLockRequest 

func ValidateReleaseLockRequest(request *gracklepb.ReleaseLockRequest) error

func ValidateReleaseSemaphoreRequest 

func ValidateReleaseSemaphoreRequest(request *gracklepb.ReleaseSemaphoreRequest) error

func ValidateUpdateBarrierRequest 

func ValidateUpdateBarrierRequest(request *gracklepb.UpdateBarrierRequest) error

func ValidateUpdateNamespaceRequest 

func ValidateUpdateNamespaceRequest(request *gracklepb.UpdateNamespaceRequest) error

func ValidateUpdateSemaphoreRequest 

func ValidateUpdateSemaphoreRequest(request *gracklepb.UpdateSemaphoreRequest) error

func ValidateWaitAtBarrierRequest 

func ValidateWaitAtBarrierRequest(request *gracklepb.WaitAtBarrierRequest) 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 interface{},
	info *grpc.UnaryServerInfo,
	handler grpc.UnaryHandler,
) (interface{}, error)

type GrackleApiServer 

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

func NewGrackleApiServer 

func NewGrackleApiServer(grackleCoreApiClient monsteragen.GrackleCoreApi) *GrackleApiServer

func (*GrackleApiServer) AcquireLock 

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

func (*GrackleApiServer) AcquireSemaphore 

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

func (*GrackleApiServer) AddJobsToWaitGroup 

func (s *GrackleApiServer) AddJobsToWaitGroup(ctx context.Context, request *gracklepb.AddJobsToWaitGroupRequest) (*gracklepb.AddJobsToWaitGroupResponse, error)

func (*GrackleApiServer) ArriveAtBarrier 

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

func (*GrackleApiServer) Close 

func (s *GrackleApiServer) Close()

func (*GrackleApiServer) CompleteJobsFromWaitGroup 

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

func (*GrackleApiServer) CreateBarrier 

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

func (*GrackleApiServer) CreateNamespace 

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

func (*GrackleApiServer) CreateSemaphore 

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

func (*GrackleApiServer) CreateWaitGroup 

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

func (*GrackleApiServer) DeleteBarrier 

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

func (*GrackleApiServer) DeleteLock 

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

func (*GrackleApiServer) DeleteNamespace 

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

func (*GrackleApiServer) DeleteSemaphore 

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

func (*GrackleApiServer) DeleteWaitGroup 

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

func (*GrackleApiServer) GetBarrier 

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

func (*GrackleApiServer) GetLock 

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

func (*GrackleApiServer) GetNamespace 

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

func (*GrackleApiServer) GetSemaphore 

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

func (*GrackleApiServer) GetWaitGroup 

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

func (*GrackleApiServer) ListBarrierParticipants 

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

func (*GrackleApiServer) ListBarriers 

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

func (*GrackleApiServer) ListLocks 

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

func (*GrackleApiServer) ListNamespaces 

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

func (*GrackleApiServer) ListSemaphoreHolders 

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

func (*GrackleApiServer) ListSemaphores 

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

func (*GrackleApiServer) ListWaitGroupJobs 

func (s *GrackleApiServer) ListWaitGroupJobs(ctx context.Context, request *gracklepb.ListWaitGroupJobsRequest) (*gracklepb.ListWaitGroupJobsResponse, error)

func (*GrackleApiServer) ListWaitGroups 

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

func (*GrackleApiServer) ReleaseLock 

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

func (*GrackleApiServer) ReleaseSemaphore 

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

func (*GrackleApiServer) UpdateBarrier 

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

func (*GrackleApiServer) UpdateNamespace 

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

func (*GrackleApiServer) UpdateSemaphore 

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

func (*GrackleApiServer) WaitAtBarrier 

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

type GrackleApiServerHandler 

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

func NewGrackleApiServerHandler 

func NewGrackleApiServerHandler(grackleCoreApiClient monsteragen.GrackleCoreApi) *GrackleApiServerHandler

func (*GrackleApiServerHandler) AcquireLock 

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

func (*GrackleApiServerHandler) AcquireSemaphore 

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

func (*GrackleApiServerHandler) AddJobsToWaitGroup 

func (s *GrackleApiServerHandler) AddJobsToWaitGroup(ctx context.Context, request *gracklepb.AddJobsToWaitGroupRequest, accountId uint64, limits grackle.GrackleServiceLimits) (*gracklepb.AddJobsToWaitGroupResponse, error)

func (*GrackleApiServerHandler) ArriveAtBarrier 

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

func (*GrackleApiServerHandler) CompleteJobsFromWaitGroup 

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

func (*GrackleApiServerHandler) CreateBarrier 

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

func (*GrackleApiServerHandler) CreateNamespace 

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

func (*GrackleApiServerHandler) CreateSemaphore 

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

func (*GrackleApiServerHandler) CreateWaitGroup 

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

func (*GrackleApiServerHandler) DeleteBarrier 

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

func (*GrackleApiServerHandler) DeleteLock 

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

func (*GrackleApiServerHandler) DeleteNamespace 

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

func (*GrackleApiServerHandler) DeleteSemaphore 

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

func (*GrackleApiServerHandler) DeleteWaitGroup 

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

func (*GrackleApiServerHandler) GetBarrier 

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

func (*GrackleApiServerHandler) GetLock 

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

func (*GrackleApiServerHandler) GetNamespace 

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

func (*GrackleApiServerHandler) GetSemaphore 

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

func (*GrackleApiServerHandler) GetWaitGroup 

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

func (*GrackleApiServerHandler) ListBarrierParticipants 

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

func (*GrackleApiServerHandler) ListBarriers 

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

func (*GrackleApiServerHandler) ListLocks 

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

func (*GrackleApiServerHandler) ListNamespaces 

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

func (*GrackleApiServerHandler) ListSemaphoreHolders 

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

func (*GrackleApiServerHandler) ListSemaphores 

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

func (*GrackleApiServerHandler) ListWaitGroupJobs 

func (s *GrackleApiServerHandler) ListWaitGroupJobs(ctx context.Context, request *gracklepb.ListWaitGroupJobsRequest, accountId uint64, limits grackle.GrackleServiceLimits) (*gracklepb.ListWaitGroupJobsResponse, error)

func (*GrackleApiServerHandler) ListWaitGroups 

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

func (*GrackleApiServerHandler) ReleaseLock 

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

func (*GrackleApiServerHandler) ReleaseSemaphore 

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

func (*GrackleApiServerHandler) Stop 

func (s *GrackleApiServerHandler) Stop()

func (*GrackleApiServerHandler) UpdateBarrier 

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

func (*GrackleApiServerHandler) UpdateNamespace 

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

func (*GrackleApiServerHandler) UpdateSemaphore 

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

func (*GrackleApiServerHandler) WaitAtBarrier 

func (s *GrackleApiServerHandler) WaitAtBarrier(ctx context.Context, request *gracklepb.WaitAtBarrierRequest, accountId uint64, limits grackle.GrackleServiceLimits) (*gracklepb.WaitAtBarrierResponse, 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.