apiconnect

package
v1.20.0-20260601171352... Latest Latest
Warning

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

 Go to latest Published: unknown License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// CirrusConfigurationEvaluatorServiceName is the fully-qualified name of the
	// CirrusConfigurationEvaluatorService service.
	CirrusConfigurationEvaluatorServiceName = "org.cirruslabs.ci.services.cirruscigrpc.CirrusConfigurationEvaluatorService"
	// CirrusRemoteExecutorServiceName is the fully-qualified name of the CirrusRemoteExecutorService
	// service.
	CirrusRemoteExecutorServiceName = "org.cirruslabs.ci.services.cirruscigrpc.CirrusRemoteExecutorService"
	// CirrusWorkersServiceName is the fully-qualified name of the CirrusWorkersService service.
	CirrusWorkersServiceName = "org.cirruslabs.ci.services.cirruscigrpc.CirrusWorkersService"
	// CirrusCIServiceName is the fully-qualified name of the CirrusCIService service.
	CirrusCIServiceName = "org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService"
)
View Source 
const (
	// CirrusConfigurationEvaluatorServiceEvaluateConfigProcedure is the fully-qualified name of the
	// CirrusConfigurationEvaluatorService's EvaluateConfig RPC.
	CirrusConfigurationEvaluatorServiceEvaluateConfigProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusConfigurationEvaluatorService/EvaluateConfig"
	// CirrusConfigurationEvaluatorServiceJSONSchemaProcedure is the fully-qualified name of the
	// CirrusConfigurationEvaluatorService's JSONSchema RPC.
	CirrusConfigurationEvaluatorServiceJSONSchemaProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusConfigurationEvaluatorService/JSONSchema"
	// CirrusConfigurationEvaluatorServiceEvaluateFunctionProcedure is the fully-qualified name of the
	// CirrusConfigurationEvaluatorService's EvaluateFunction RPC.
	CirrusConfigurationEvaluatorServiceEvaluateFunctionProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusConfigurationEvaluatorService/EvaluateFunction"
	// CirrusRemoteExecutorServiceCapabilitiesProcedure is the fully-qualified name of the
	// CirrusRemoteExecutorService's Capabilities RPC.
	CirrusRemoteExecutorServiceCapabilitiesProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusRemoteExecutorService/Capabilities"
	// CirrusWorkersServiceRegisterProcedure is the fully-qualified name of the CirrusWorkersService's
	// Register RPC.
	CirrusWorkersServiceRegisterProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusWorkersService/Register"
	// CirrusWorkersServicePollProcedure is the fully-qualified name of the CirrusWorkersService's Poll
	// RPC.
	CirrusWorkersServicePollProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusWorkersService/Poll"
	// CirrusWorkersServiceTaskStartedProcedure is the fully-qualified name of the
	// CirrusWorkersService's TaskStarted RPC.
	CirrusWorkersServiceTaskStartedProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusWorkersService/TaskStarted"
	// CirrusWorkersServiceTaskFailedProcedure is the fully-qualified name of the CirrusWorkersService's
	// TaskFailed RPC.
	CirrusWorkersServiceTaskFailedProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusWorkersService/TaskFailed"
	// CirrusWorkersServiceTaskStoppedProcedure is the fully-qualified name of the
	// CirrusWorkersService's TaskStopped RPC.
	CirrusWorkersServiceTaskStoppedProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusWorkersService/TaskStopped"
	// CirrusWorkersServiceUpdateStatusProcedure is the fully-qualified name of the
	// CirrusWorkersService's UpdateStatus RPC.
	CirrusWorkersServiceUpdateStatusProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusWorkersService/UpdateStatus"
	// CirrusWorkersServiceQueryRunningTasksProcedure is the fully-qualified name of the
	// CirrusWorkersService's QueryRunningTasks RPC.
	CirrusWorkersServiceQueryRunningTasksProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusWorkersService/QueryRunningTasks"
	// CirrusCIServiceInitialCommandsProcedure is the fully-qualified name of the CirrusCIService's
	// InitialCommands RPC.
	CirrusCIServiceInitialCommandsProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/InitialCommands"
	// CirrusCIServiceReportCommandUpdatesProcedure is the fully-qualified name of the CirrusCIService's
	// ReportCommandUpdates RPC.
	CirrusCIServiceReportCommandUpdatesProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/ReportCommandUpdates"
	// CirrusCIServiceReportAnnotationsProcedure is the fully-qualified name of the CirrusCIService's
	// ReportAnnotations RPC.
	CirrusCIServiceReportAnnotationsProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/ReportAnnotations"
	// CirrusCIServiceStreamLogsProcedure is the fully-qualified name of the CirrusCIService's
	// StreamLogs RPC.
	CirrusCIServiceStreamLogsProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/StreamLogs"
	// CirrusCIServiceSaveLogsProcedure is the fully-qualified name of the CirrusCIService's SaveLogs
	// RPC.
	CirrusCIServiceSaveLogsProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/SaveLogs"
	// CirrusCIServiceUploadArtifactsProcedure is the fully-qualified name of the CirrusCIService's
	// UploadArtifacts RPC.
	CirrusCIServiceUploadArtifactsProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/UploadArtifacts"
	// CirrusCIServiceGenerateArtifactUploadURLsProcedure is the fully-qualified name of the
	// CirrusCIService's GenerateArtifactUploadURLs RPC.
	CirrusCIServiceGenerateArtifactUploadURLsProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/GenerateArtifactUploadURLs"
	// CirrusCIServiceCommitUploadedArtifactsProcedure is the fully-qualified name of the
	// CirrusCIService's CommitUploadedArtifacts RPC.
	CirrusCIServiceCommitUploadedArtifactsProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/CommitUploadedArtifacts"
	// CirrusCIServiceCacheInfoProcedure is the fully-qualified name of the CirrusCIService's CacheInfo
	// RPC.
	CirrusCIServiceCacheInfoProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/CacheInfo"
	// CirrusCIServiceDeleteCacheProcedure is the fully-qualified name of the CirrusCIService's
	// DeleteCache RPC.
	CirrusCIServiceDeleteCacheProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/DeleteCache"
	// CirrusCIServiceHeartbeatProcedure is the fully-qualified name of the CirrusCIService's Heartbeat
	// RPC.
	CirrusCIServiceHeartbeatProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/Heartbeat"
	// CirrusCIServiceReportStopHookProcedure is the fully-qualified name of the CirrusCIService's
	// ReportStopHook RPC.
	CirrusCIServiceReportStopHookProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/ReportStopHook"
	// CirrusCIServiceReportAgentErrorProcedure is the fully-qualified name of the CirrusCIService's
	// ReportAgentError RPC.
	CirrusCIServiceReportAgentErrorProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/ReportAgentError"
	// CirrusCIServiceReportAgentWarningProcedure is the fully-qualified name of the CirrusCIService's
	// ReportAgentWarning RPC.
	CirrusCIServiceReportAgentWarningProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/ReportAgentWarning"
	// CirrusCIServiceReportAgentSignalProcedure is the fully-qualified name of the CirrusCIService's
	// ReportAgentSignal RPC.
	CirrusCIServiceReportAgentSignalProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/ReportAgentSignal"
	// CirrusCIServiceReportAgentLogsProcedure is the fully-qualified name of the CirrusCIService's
	// ReportAgentLogs RPC.
	CirrusCIServiceReportAgentLogsProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/ReportAgentLogs"
	// CirrusCIServiceReportAgentFinishedProcedure is the fully-qualified name of the CirrusCIService's
	// ReportAgentFinished RPC.
	CirrusCIServiceReportAgentFinishedProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/ReportAgentFinished"
	// CirrusCIServiceReportTerminalAttachedProcedure is the fully-qualified name of the
	// CirrusCIService's ReportTerminalAttached RPC.
	CirrusCIServiceReportTerminalAttachedProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/ReportTerminalAttached"
	// CirrusCIServiceReportTerminalLifecycleProcedure is the fully-qualified name of the
	// CirrusCIService's ReportTerminalLifecycle RPC.
	CirrusCIServiceReportTerminalLifecycleProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/ReportTerminalLifecycle"
	// CirrusCIServiceGenerateCacheUploadURLProcedure is the fully-qualified name of the
	// CirrusCIService's GenerateCacheUploadURL RPC.
	CirrusCIServiceGenerateCacheUploadURLProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/GenerateCacheUploadURL"
	// CirrusCIServiceGenerateCacheDownloadURLsProcedure is the fully-qualified name of the
	// CirrusCIService's GenerateCacheDownloadURLs RPC.
	CirrusCIServiceGenerateCacheDownloadURLsProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/GenerateCacheDownloadURLs"
	// CirrusCIServiceMultipartCacheUploadCreateProcedure is the fully-qualified name of the
	// CirrusCIService's MultipartCacheUploadCreate RPC.
	CirrusCIServiceMultipartCacheUploadCreateProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/MultipartCacheUploadCreate"
	// CirrusCIServiceMultipartCacheUploadPartProcedure is the fully-qualified name of the
	// CirrusCIService's MultipartCacheUploadPart RPC.
	CirrusCIServiceMultipartCacheUploadPartProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/MultipartCacheUploadPart"
	// CirrusCIServiceMultipartCacheUploadCommitProcedure is the fully-qualified name of the
	// CirrusCIService's MultipartCacheUploadCommit RPC.
	CirrusCIServiceMultipartCacheUploadCommitProcedure = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/MultipartCacheUploadCommit"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

Variables

This section is empty.

Functions

func NewCirrusCIServiceHandler 

func NewCirrusCIServiceHandler(svc CirrusCIServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewCirrusCIServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewCirrusConfigurationEvaluatorServiceHandler 

func NewCirrusConfigurationEvaluatorServiceHandler(svc CirrusConfigurationEvaluatorServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewCirrusConfigurationEvaluatorServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewCirrusRemoteExecutorServiceHandler 

func NewCirrusRemoteExecutorServiceHandler(svc CirrusRemoteExecutorServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewCirrusRemoteExecutorServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewCirrusWorkersServiceHandler 

func NewCirrusWorkersServiceHandler(svc CirrusWorkersServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewCirrusWorkersServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

Types

type CirrusCIServiceClient 

type CirrusCIServiceClient interface {
	InitialCommands(context.Context, *connect.Request[api.InitialCommandsRequest]) (*connect.Response[api.CommandsResponse], error)
	ReportCommandUpdates(context.Context, *connect.Request[api.ReportCommandUpdatesRequest]) (*connect.Response[api.ReportCommandUpdatesResponse], error)
	ReportAnnotations(context.Context, *connect.Request[api.ReportAnnotationsCommandRequest]) (*connect.Response[emptypb.Empty], error)
	StreamLogs(context.Context) *connect.ClientStreamForClient[api.LogEntry, api.UploadLogsResponse]
	SaveLogs(context.Context) *connect.ClientStreamForClient[api.LogEntry, api.UploadLogsResponse]
	// Artifacts upload over gRPC
	UploadArtifacts(context.Context) *connect.ClientStreamForClient[api.ArtifactEntry, api.UploadArtifactsResponse]
	// Artifacts upload over HTTPS
	GenerateArtifactUploadURLs(context.Context, *connect.Request[api.GenerateArtifactUploadURLsRequest]) (*connect.Response[api.GenerateArtifactUploadURLsResponse], error)
	CommitUploadedArtifacts(context.Context, *connect.Request[api.CommitUploadedArtifactsRequest]) (*connect.Response[api.CommitUploadedArtifactsResponse], error)
	CacheInfo(context.Context, *connect.Request[api.CacheInfoRequest]) (*connect.Response[api.CacheInfoResponse], error)
	DeleteCache(context.Context, *connect.Request[api.DeleteCacheRequest]) (*connect.Response[api.DeleteCacheResponse], error)
	Heartbeat(context.Context, *connect.Request[api.HeartbeatRequest]) (*connect.Response[api.HeartbeatResponse], error)
	ReportStopHook(context.Context, *connect.Request[api.ReportStopHookRequest]) (*connect.Response[emptypb.Empty], error)
	ReportAgentError(context.Context, *connect.Request[api.ReportAgentProblemRequest]) (*connect.Response[emptypb.Empty], error)
	ReportAgentWarning(context.Context, *connect.Request[api.ReportAgentProblemRequest]) (*connect.Response[emptypb.Empty], error)
	ReportAgentSignal(context.Context, *connect.Request[api.ReportAgentSignalRequest]) (*connect.Response[emptypb.Empty], error)
	ReportAgentLogs(context.Context, *connect.Request[api.ReportAgentLogsRequest]) (*connect.Response[emptypb.Empty], error)
	ReportAgentFinished(context.Context, *connect.Request[api.ReportAgentFinishedRequest]) (*connect.Response[api.ReportAgentFinishedResponse], error)
	ReportTerminalAttached(context.Context, *connect.Request[api.ReportTerminalAttachedRequest]) (*connect.Response[api.ReportTerminalAttachedResponse], error)
	ReportTerminalLifecycle(context.Context, *connect.Request[api.ReportTerminalLifecycleRequest]) (*connect.Response[api.ReportTerminalLifecycleResponse], error)
	GenerateCacheUploadURL(context.Context, *connect.Request[api.CacheKey]) (*connect.Response[api.GenerateURLResponse], error)
	GenerateCacheDownloadURLs(context.Context, *connect.Request[api.CacheKey]) (*connect.Response[api.GenerateURLsResponse], error)
	// Multipart cache upload
	MultipartCacheUploadCreate(context.Context, *connect.Request[api.CacheKey]) (*connect.Response[api.MultipartCacheUploadCreateResponse], error)
	MultipartCacheUploadPart(context.Context, *connect.Request[api.MultipartCacheUploadPartRequest]) (*connect.Response[api.GenerateURLResponse], error)
	MultipartCacheUploadCommit(context.Context, *connect.Request[api.MultipartCacheUploadCommitRequest]) (*connect.Response[emptypb.Empty], error)
}

CirrusCIServiceClient is a client for the org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService service.

func NewCirrusCIServiceClient 

func NewCirrusCIServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) CirrusCIServiceClient

NewCirrusCIServiceClient constructs a client for the org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type CirrusCIServiceHandler 

type CirrusCIServiceHandler interface {
	InitialCommands(context.Context, *connect.Request[api.InitialCommandsRequest]) (*connect.Response[api.CommandsResponse], error)
	ReportCommandUpdates(context.Context, *connect.Request[api.ReportCommandUpdatesRequest]) (*connect.Response[api.ReportCommandUpdatesResponse], error)
	ReportAnnotations(context.Context, *connect.Request[api.ReportAnnotationsCommandRequest]) (*connect.Response[emptypb.Empty], error)
	StreamLogs(context.Context, *connect.ClientStream[api.LogEntry]) (*connect.Response[api.UploadLogsResponse], error)
	SaveLogs(context.Context, *connect.ClientStream[api.LogEntry]) (*connect.Response[api.UploadLogsResponse], error)
	// Artifacts upload over gRPC
	UploadArtifacts(context.Context, *connect.ClientStream[api.ArtifactEntry]) (*connect.Response[api.UploadArtifactsResponse], error)
	// Artifacts upload over HTTPS
	GenerateArtifactUploadURLs(context.Context, *connect.Request[api.GenerateArtifactUploadURLsRequest]) (*connect.Response[api.GenerateArtifactUploadURLsResponse], error)
	CommitUploadedArtifacts(context.Context, *connect.Request[api.CommitUploadedArtifactsRequest]) (*connect.Response[api.CommitUploadedArtifactsResponse], error)
	CacheInfo(context.Context, *connect.Request[api.CacheInfoRequest]) (*connect.Response[api.CacheInfoResponse], error)
	DeleteCache(context.Context, *connect.Request[api.DeleteCacheRequest]) (*connect.Response[api.DeleteCacheResponse], error)
	Heartbeat(context.Context, *connect.Request[api.HeartbeatRequest]) (*connect.Response[api.HeartbeatResponse], error)
	ReportStopHook(context.Context, *connect.Request[api.ReportStopHookRequest]) (*connect.Response[emptypb.Empty], error)
	ReportAgentError(context.Context, *connect.Request[api.ReportAgentProblemRequest]) (*connect.Response[emptypb.Empty], error)
	ReportAgentWarning(context.Context, *connect.Request[api.ReportAgentProblemRequest]) (*connect.Response[emptypb.Empty], error)
	ReportAgentSignal(context.Context, *connect.Request[api.ReportAgentSignalRequest]) (*connect.Response[emptypb.Empty], error)
	ReportAgentLogs(context.Context, *connect.Request[api.ReportAgentLogsRequest]) (*connect.Response[emptypb.Empty], error)
	ReportAgentFinished(context.Context, *connect.Request[api.ReportAgentFinishedRequest]) (*connect.Response[api.ReportAgentFinishedResponse], error)
	ReportTerminalAttached(context.Context, *connect.Request[api.ReportTerminalAttachedRequest]) (*connect.Response[api.ReportTerminalAttachedResponse], error)
	ReportTerminalLifecycle(context.Context, *connect.Request[api.ReportTerminalLifecycleRequest]) (*connect.Response[api.ReportTerminalLifecycleResponse], error)
	GenerateCacheUploadURL(context.Context, *connect.Request[api.CacheKey]) (*connect.Response[api.GenerateURLResponse], error)
	GenerateCacheDownloadURLs(context.Context, *connect.Request[api.CacheKey]) (*connect.Response[api.GenerateURLsResponse], error)
	// Multipart cache upload
	MultipartCacheUploadCreate(context.Context, *connect.Request[api.CacheKey]) (*connect.Response[api.MultipartCacheUploadCreateResponse], error)
	MultipartCacheUploadPart(context.Context, *connect.Request[api.MultipartCacheUploadPartRequest]) (*connect.Response[api.GenerateURLResponse], error)
	MultipartCacheUploadCommit(context.Context, *connect.Request[api.MultipartCacheUploadCommitRequest]) (*connect.Response[emptypb.Empty], error)
}

CirrusCIServiceHandler is an implementation of the org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService service.

type CirrusConfigurationEvaluatorServiceClient 

type CirrusConfigurationEvaluatorServiceClient interface {
	// Parser
	EvaluateConfig(context.Context, *connect.Request[api.EvaluateConfigRequest]) (*connect.Response[api.EvaluateConfigResponse], error)
	JSONSchema(context.Context, *connect.Request[api.JSONSchemaRequest]) (*connect.Response[api.JSONSchemaResponse], error)
	// Hooks
	EvaluateFunction(context.Context, *connect.Request[api.EvaluateFunctionRequest]) (*connect.Response[api.EvaluateFunctionResponse], error)
}

CirrusConfigurationEvaluatorServiceClient is a client for the org.cirruslabs.ci.services.cirruscigrpc.CirrusConfigurationEvaluatorService service.

func NewCirrusConfigurationEvaluatorServiceClient 

func NewCirrusConfigurationEvaluatorServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) CirrusConfigurationEvaluatorServiceClient

NewCirrusConfigurationEvaluatorServiceClient constructs a client for the org.cirruslabs.ci.services.cirruscigrpc.CirrusConfigurationEvaluatorService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type CirrusConfigurationEvaluatorServiceHandler 

type CirrusConfigurationEvaluatorServiceHandler interface {
	// Parser
	EvaluateConfig(context.Context, *connect.Request[api.EvaluateConfigRequest]) (*connect.Response[api.EvaluateConfigResponse], error)
	JSONSchema(context.Context, *connect.Request[api.JSONSchemaRequest]) (*connect.Response[api.JSONSchemaResponse], error)
	// Hooks
	EvaluateFunction(context.Context, *connect.Request[api.EvaluateFunctionRequest]) (*connect.Response[api.EvaluateFunctionResponse], error)
}

CirrusConfigurationEvaluatorServiceHandler is an implementation of the org.cirruslabs.ci.services.cirruscigrpc.CirrusConfigurationEvaluatorService service.

type CirrusRemoteExecutorServiceClient 

type CirrusRemoteExecutorServiceClient interface {
	Capabilities(context.Context, *connect.Request[api.CapabilitiesRequest]) (*connect.Response[api.CapabilitiesResponse], error)
}

CirrusRemoteExecutorServiceClient is a client for the org.cirruslabs.ci.services.cirruscigrpc.CirrusRemoteExecutorService service.

func NewCirrusRemoteExecutorServiceClient 

func NewCirrusRemoteExecutorServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) CirrusRemoteExecutorServiceClient

NewCirrusRemoteExecutorServiceClient constructs a client for the org.cirruslabs.ci.services.cirruscigrpc.CirrusRemoteExecutorService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type CirrusRemoteExecutorServiceHandler 

type CirrusRemoteExecutorServiceHandler interface {
	Capabilities(context.Context, *connect.Request[api.CapabilitiesRequest]) (*connect.Response[api.CapabilitiesResponse], error)
}

CirrusRemoteExecutorServiceHandler is an implementation of the org.cirruslabs.ci.services.cirruscigrpc.CirrusRemoteExecutorService service.

type CirrusWorkersServiceClient 

type CirrusWorkersServiceClient interface {
	// Issued by the persistent worker after it starts
	//
	// Can be called without a session token.
	Register(context.Context, *connect.Request[api.RegisterRequest]) (*connect.Response[api.RegisterResponse], error)
	// Periodically issued by the registered persistent worker to get new jobs and indicate that it's alive
	Poll(context.Context, *connect.Request[api.PollRequest]) (*connect.Response[api.PollResponse], error)
	// Issued by the registered persistent worker to indicate task status
	TaskStarted(context.Context, *connect.Request[api.TaskIdentification]) (*connect.Response[emptypb.Empty], error)
	TaskFailed(context.Context, *connect.Request[api.TaskFailedRequest]) (*connect.Response[emptypb.Empty], error)
	TaskStopped(context.Context, *connect.Request[api.TaskIdentification]) (*connect.Response[emptypb.Empty], error)
	UpdateStatus(context.Context, *connect.Request[api.UpdateStatusRequest]) (*connect.Response[api.WorkerStatus], error)
	QueryRunningTasks(context.Context, *connect.Request[api.QueryRunningTasksRequest]) (*connect.Response[api.QueryRunningTasksResponse], error)
}

CirrusWorkersServiceClient is a client for the org.cirruslabs.ci.services.cirruscigrpc.CirrusWorkersService service.

func NewCirrusWorkersServiceClient 

func NewCirrusWorkersServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) CirrusWorkersServiceClient

NewCirrusWorkersServiceClient constructs a client for the org.cirruslabs.ci.services.cirruscigrpc.CirrusWorkersService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type CirrusWorkersServiceHandler 

type CirrusWorkersServiceHandler interface {
	// Issued by the persistent worker after it starts
	//
	// Can be called without a session token.
	Register(context.Context, *connect.Request[api.RegisterRequest]) (*connect.Response[api.RegisterResponse], error)
	// Periodically issued by the registered persistent worker to get new jobs and indicate that it's alive
	Poll(context.Context, *connect.Request[api.PollRequest]) (*connect.Response[api.PollResponse], error)
	// Issued by the registered persistent worker to indicate task status
	TaskStarted(context.Context, *connect.Request[api.TaskIdentification]) (*connect.Response[emptypb.Empty], error)
	TaskFailed(context.Context, *connect.Request[api.TaskFailedRequest]) (*connect.Response[emptypb.Empty], error)
	TaskStopped(context.Context, *connect.Request[api.TaskIdentification]) (*connect.Response[emptypb.Empty], error)
	UpdateStatus(context.Context, *connect.Request[api.UpdateStatusRequest]) (*connect.Response[api.WorkerStatus], error)
	QueryRunningTasks(context.Context, *connect.Request[api.QueryRunningTasksRequest]) (*connect.Response[api.QueryRunningTasksResponse], error)
}

CirrusWorkersServiceHandler is an implementation of the org.cirruslabs.ci.services.cirruscigrpc.CirrusWorkersService service.

type UnimplementedCirrusCIServiceHandler 

type UnimplementedCirrusCIServiceHandler struct{}

UnimplementedCirrusCIServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedCirrusCIServiceHandler) CacheInfo 

func (UnimplementedCirrusCIServiceHandler) CacheInfo(context.Context, *connect.Request[api.CacheInfoRequest]) (*connect.Response[api.CacheInfoResponse], error)

func (UnimplementedCirrusCIServiceHandler) CommitUploadedArtifacts 

func (UnimplementedCirrusCIServiceHandler) CommitUploadedArtifacts(context.Context, *connect.Request[api.CommitUploadedArtifactsRequest]) (*connect.Response[api.CommitUploadedArtifactsResponse], error)

func (UnimplementedCirrusCIServiceHandler) DeleteCache 

func (UnimplementedCirrusCIServiceHandler) DeleteCache(context.Context, *connect.Request[api.DeleteCacheRequest]) (*connect.Response[api.DeleteCacheResponse], error)

func (UnimplementedCirrusCIServiceHandler) GenerateArtifactUploadURLs 

func (UnimplementedCirrusCIServiceHandler) GenerateArtifactUploadURLs(context.Context, *connect.Request[api.GenerateArtifactUploadURLsRequest]) (*connect.Response[api.GenerateArtifactUploadURLsResponse], error)

func (UnimplementedCirrusCIServiceHandler) GenerateCacheDownloadURLs 

func (UnimplementedCirrusCIServiceHandler) GenerateCacheDownloadURLs(context.Context, *connect.Request[api.CacheKey]) (*connect.Response[api.GenerateURLsResponse], error)

func (UnimplementedCirrusCIServiceHandler) GenerateCacheUploadURL 

func (UnimplementedCirrusCIServiceHandler) GenerateCacheUploadURL(context.Context, *connect.Request[api.CacheKey]) (*connect.Response[api.GenerateURLResponse], error)

func (UnimplementedCirrusCIServiceHandler) Heartbeat 

func (UnimplementedCirrusCIServiceHandler) Heartbeat(context.Context, *connect.Request[api.HeartbeatRequest]) (*connect.Response[api.HeartbeatResponse], error)

func (UnimplementedCirrusCIServiceHandler) InitialCommands 

func (UnimplementedCirrusCIServiceHandler) InitialCommands(context.Context, *connect.Request[api.InitialCommandsRequest]) (*connect.Response[api.CommandsResponse], error)

func (UnimplementedCirrusCIServiceHandler) MultipartCacheUploadCommit 

func (UnimplementedCirrusCIServiceHandler) MultipartCacheUploadCommit(context.Context, *connect.Request[api.MultipartCacheUploadCommitRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedCirrusCIServiceHandler) MultipartCacheUploadCreate 

func (UnimplementedCirrusCIServiceHandler) MultipartCacheUploadCreate(context.Context, *connect.Request[api.CacheKey]) (*connect.Response[api.MultipartCacheUploadCreateResponse], error)

func (UnimplementedCirrusCIServiceHandler) MultipartCacheUploadPart 

func (UnimplementedCirrusCIServiceHandler) MultipartCacheUploadPart(context.Context, *connect.Request[api.MultipartCacheUploadPartRequest]) (*connect.Response[api.GenerateURLResponse], error)

func (UnimplementedCirrusCIServiceHandler) ReportAgentError 

func (UnimplementedCirrusCIServiceHandler) ReportAgentError(context.Context, *connect.Request[api.ReportAgentProblemRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedCirrusCIServiceHandler) ReportAgentFinished 

func (UnimplementedCirrusCIServiceHandler) ReportAgentFinished(context.Context, *connect.Request[api.ReportAgentFinishedRequest]) (*connect.Response[api.ReportAgentFinishedResponse], error)

func (UnimplementedCirrusCIServiceHandler) ReportAgentLogs 

func (UnimplementedCirrusCIServiceHandler) ReportAgentLogs(context.Context, *connect.Request[api.ReportAgentLogsRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedCirrusCIServiceHandler) ReportAgentSignal 

func (UnimplementedCirrusCIServiceHandler) ReportAgentSignal(context.Context, *connect.Request[api.ReportAgentSignalRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedCirrusCIServiceHandler) ReportAgentWarning 

func (UnimplementedCirrusCIServiceHandler) ReportAgentWarning(context.Context, *connect.Request[api.ReportAgentProblemRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedCirrusCIServiceHandler) ReportAnnotations 

func (UnimplementedCirrusCIServiceHandler) ReportAnnotations(context.Context, *connect.Request[api.ReportAnnotationsCommandRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedCirrusCIServiceHandler) ReportCommandUpdates 

func (UnimplementedCirrusCIServiceHandler) ReportCommandUpdates(context.Context, *connect.Request[api.ReportCommandUpdatesRequest]) (*connect.Response[api.ReportCommandUpdatesResponse], error)

func (UnimplementedCirrusCIServiceHandler) ReportStopHook 

func (UnimplementedCirrusCIServiceHandler) ReportStopHook(context.Context, *connect.Request[api.ReportStopHookRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedCirrusCIServiceHandler) ReportTerminalAttached 

func (UnimplementedCirrusCIServiceHandler) ReportTerminalAttached(context.Context, *connect.Request[api.ReportTerminalAttachedRequest]) (*connect.Response[api.ReportTerminalAttachedResponse], error)

func (UnimplementedCirrusCIServiceHandler) ReportTerminalLifecycle 

func (UnimplementedCirrusCIServiceHandler) ReportTerminalLifecycle(context.Context, *connect.Request[api.ReportTerminalLifecycleRequest]) (*connect.Response[api.ReportTerminalLifecycleResponse], error)

func (UnimplementedCirrusCIServiceHandler) SaveLogs 

func (UnimplementedCirrusCIServiceHandler) SaveLogs(context.Context, *connect.ClientStream[api.LogEntry]) (*connect.Response[api.UploadLogsResponse], error)

func (UnimplementedCirrusCIServiceHandler) StreamLogs 

func (UnimplementedCirrusCIServiceHandler) StreamLogs(context.Context, *connect.ClientStream[api.LogEntry]) (*connect.Response[api.UploadLogsResponse], error)

func (UnimplementedCirrusCIServiceHandler) UploadArtifacts 

func (UnimplementedCirrusCIServiceHandler) UploadArtifacts(context.Context, *connect.ClientStream[api.ArtifactEntry]) (*connect.Response[api.UploadArtifactsResponse], error)

type UnimplementedCirrusConfigurationEvaluatorServiceHandler 

type UnimplementedCirrusConfigurationEvaluatorServiceHandler struct{}

UnimplementedCirrusConfigurationEvaluatorServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedCirrusConfigurationEvaluatorServiceHandler) EvaluateConfig 

func (UnimplementedCirrusConfigurationEvaluatorServiceHandler) EvaluateConfig(context.Context, *connect.Request[api.EvaluateConfigRequest]) (*connect.Response[api.EvaluateConfigResponse], error)

func (UnimplementedCirrusConfigurationEvaluatorServiceHandler) EvaluateFunction 

func (UnimplementedCirrusConfigurationEvaluatorServiceHandler) EvaluateFunction(context.Context, *connect.Request[api.EvaluateFunctionRequest]) (*connect.Response[api.EvaluateFunctionResponse], error)

func (UnimplementedCirrusConfigurationEvaluatorServiceHandler) JSONSchema 

func (UnimplementedCirrusConfigurationEvaluatorServiceHandler) JSONSchema(context.Context, *connect.Request[api.JSONSchemaRequest]) (*connect.Response[api.JSONSchemaResponse], error)

type UnimplementedCirrusRemoteExecutorServiceHandler 

type UnimplementedCirrusRemoteExecutorServiceHandler struct{}

UnimplementedCirrusRemoteExecutorServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedCirrusRemoteExecutorServiceHandler) Capabilities 

func (UnimplementedCirrusRemoteExecutorServiceHandler) Capabilities(context.Context, *connect.Request[api.CapabilitiesRequest]) (*connect.Response[api.CapabilitiesResponse], error)

type UnimplementedCirrusWorkersServiceHandler 

type UnimplementedCirrusWorkersServiceHandler struct{}

UnimplementedCirrusWorkersServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedCirrusWorkersServiceHandler) Poll 

func (UnimplementedCirrusWorkersServiceHandler) Poll(context.Context, *connect.Request[api.PollRequest]) (*connect.Response[api.PollResponse], error)

func (UnimplementedCirrusWorkersServiceHandler) QueryRunningTasks 

func (UnimplementedCirrusWorkersServiceHandler) QueryRunningTasks(context.Context, *connect.Request[api.QueryRunningTasksRequest]) (*connect.Response[api.QueryRunningTasksResponse], error)

func (UnimplementedCirrusWorkersServiceHandler) Register 

func (UnimplementedCirrusWorkersServiceHandler) Register(context.Context, *connect.Request[api.RegisterRequest]) (*connect.Response[api.RegisterResponse], error)

func (UnimplementedCirrusWorkersServiceHandler) TaskFailed 

func (UnimplementedCirrusWorkersServiceHandler) TaskFailed(context.Context, *connect.Request[api.TaskFailedRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedCirrusWorkersServiceHandler) TaskStarted 

func (UnimplementedCirrusWorkersServiceHandler) TaskStarted(context.Context, *connect.Request[api.TaskIdentification]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedCirrusWorkersServiceHandler) TaskStopped 

func (UnimplementedCirrusWorkersServiceHandler) TaskStopped(context.Context, *connect.Request[api.TaskIdentification]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedCirrusWorkersServiceHandler) UpdateStatus 

func (UnimplementedCirrusWorkersServiceHandler) UpdateStatus(context.Context, *connect.Request[api.UpdateStatusRequest]) (*connect.Response[api.WorkerStatus], error)

Source Files

  • cirrus_ci_service.connect.go

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.