implementations

package
v1.3.14 Latest Latest
Warning

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

 Go to latest Published: Jun 9, 2023 License: ISC Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type HealthChecker 

type HealthChecker struct{}

func NewHealthChecker 

func NewHealthChecker() *HealthChecker

func (*HealthChecker) Check 

func (s *HealthChecker) Check(ctx context.Context, req *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

func (*HealthChecker) Watch 

func (s *HealthChecker) Watch(req *grpc_health_v1.HealthCheckRequest, server grpc_health_v1.Health_WatchServer) error

type V1Alpha1Server 

type V1Alpha1Server struct {
	corndogsv1alpha1.UnimplementedCorndogsServiceServer
}

implements the corndogs api

func (*V1Alpha1Server) CancelTask 

func (s *V1Alpha1Server) CancelTask(ctx context.Context, req *corndogsv1alpha1.CancelTaskRequest) (*corndogsv1alpha1.CancelTaskResponse, error)

func (*V1Alpha1Server) CleanUpTimedOut added in v1.1.0 

func (s *V1Alpha1Server) CleanUpTimedOut(ctx context.Context, req *corndogsv1alpha1.CleanUpTimedOutRequest) (*corndogsv1alpha1.CleanUpTimedOutResponse, error)

func (*V1Alpha1Server) CompleteTask 

func (s *V1Alpha1Server) CompleteTask(ctx context.Context, req *corndogsv1alpha1.CompleteTaskRequest) (*corndogsv1alpha1.CompleteTaskResponse, error)

func (*V1Alpha1Server) GetNextTask 

func (s *V1Alpha1Server) GetNextTask(ctx context.Context, req *corndogsv1alpha1.GetNextTaskRequest) (*corndogsv1alpha1.GetNextTaskResponse, error)

func (*V1Alpha1Server) GetQueueAndStateCounts added in v1.3.0 

func (s *V1Alpha1Server) GetQueueAndStateCounts(ctx context.Context, req *corndogsv1alpha1.GetQueueAndStateCountsRequest) (*corndogsv1alpha1.GetQueueAndStateCountsResponse, error)

func (*V1Alpha1Server) GetQueueTaskCounts added in v1.3.0 

func (s *V1Alpha1Server) GetQueueTaskCounts(ctx context.Context, req *corndogsv1alpha1.GetQueueTaskCountsRequest) (*corndogsv1alpha1.GetQueueTaskCountsResponse, error)

func (*V1Alpha1Server) GetQueues added in v1.3.0 

func (s *V1Alpha1Server) GetQueues(ctx context.Context, req *corndogsv1alpha1.GetQueuesRequest) (*corndogsv1alpha1.GetQueuesResponse, error)

func (*V1Alpha1Server) GetTaskStateByID added in v1.3.1 

func (s *V1Alpha1Server) GetTaskStateByID(ctx context.Context, req *corndogsv1alpha1.GetTaskStateByIDRequest) (*corndogsv1alpha1.GetTaskStateByIDResponse, error)

func (*V1Alpha1Server) GetTaskStateCounts added in v1.3.0 

func (s *V1Alpha1Server) GetTaskStateCounts(ctx context.Context, req *corndogsv1alpha1.GetTaskStateCountsRequest) (*corndogsv1alpha1.GetTaskStateCountsResponse, error)

func (*V1Alpha1Server) SubmitTask 

func (s *V1Alpha1Server) SubmitTask(ctx context.Context, req *corndogsv1alpha1.SubmitTaskRequest) (*corndogsv1alpha1.SubmitTaskResponse, error)

func (*V1Alpha1Server) UpdateTask 

func (s *V1Alpha1Server) UpdateTask(ctx context.Context, req *corndogsv1alpha1.UpdateTaskRequest) (*corndogsv1alpha1.UpdateTaskResponse, 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.