service

package
v2.0.0 Latest Latest
Warning

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

 Go to latest Published: Dec 22, 2025 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type QueueClientInterface 

type QueueClientInterface interface {
	EnqueueAction(ctx context.Context, req *workflow.EnqueueActionRequest) error
	AbortQueuedRun(ctx context.Context, runID *common.RunIdentifier, reason *string) error
	AbortQueuedAction(ctx context.Context, actionID *common.ActionIdentifier, reason *string) error
}

QueueClientInterface defines the interface for queue operations This allows for easier testing and mocking

type QueueService 

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

QueueService implements the QueueServiceHandler interface

func NewQueueService 

func NewQueueService(k8sClient *k8s.QueueClient) *QueueService

NewQueueService creates a new QueueService instance

func NewQueueServiceWithClient 

func NewQueueServiceWithClient(client QueueClientInterface) *QueueService

NewQueueServiceWithClient creates a new QueueService with a custom client implementation This is useful for testing

func (*QueueService) AbortQueuedAction 

func (s *QueueService) AbortQueuedAction(
	ctx context.Context,
	req *connect.Request[workflow.AbortQueuedActionRequest],
) (*connect.Response[workflow.AbortQueuedActionResponse], error)

AbortQueuedAction deletes a specific TaskAction CR

func (*QueueService) AbortQueuedRun 

func (s *QueueService) AbortQueuedRun(
	ctx context.Context,
	req *connect.Request[workflow.AbortQueuedRunRequest],
) (*connect.Response[workflow.AbortQueuedRunResponse], error)

AbortQueuedRun deletes all TaskAction CRs for a run

func (*QueueService) EnqueueAction 

func (s *QueueService) EnqueueAction(
	ctx context.Context,
	req *connect.Request[workflow.EnqueueActionRequest],
) (*connect.Response[workflow.EnqueueActionResponse], error)

EnqueueAction creates a TaskAction CR in Kubernetes

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.