apigrpc

package
v1.3.0-20240506104811-... Latest Latest
Warning

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

 Go to latest Published: unknown License: AGPL-3.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CirrusConfigurationEvaluatorService_EvaluateConfig_FullMethodName   = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusConfigurationEvaluatorService/EvaluateConfig"
	CirrusConfigurationEvaluatorService_JSONSchema_FullMethodName       = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusConfigurationEvaluatorService/JSONSchema"
	CirrusConfigurationEvaluatorService_EvaluateFunction_FullMethodName = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusConfigurationEvaluatorService/EvaluateFunction"
)
View Source 
const (
	CirrusWorkersService_Register_FullMethodName          = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusWorkersService/Register"
	CirrusWorkersService_Poll_FullMethodName              = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusWorkersService/Poll"
	CirrusWorkersService_TaskStarted_FullMethodName       = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusWorkersService/TaskStarted"
	CirrusWorkersService_TaskFailed_FullMethodName        = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusWorkersService/TaskFailed"
	CirrusWorkersService_TaskStopped_FullMethodName       = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusWorkersService/TaskStopped"
	CirrusWorkersService_UpdateStatus_FullMethodName      = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusWorkersService/UpdateStatus"
	CirrusWorkersService_QueryRunningTasks_FullMethodName = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusWorkersService/QueryRunningTasks"
)
View Source 
const (
	CirrusCIService_InitialCommands_FullMethodName            = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/InitialCommands"
	CirrusCIService_ReportCommandUpdates_FullMethodName       = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/ReportCommandUpdates"
	CirrusCIService_ReportAnnotations_FullMethodName          = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/ReportAnnotations"
	CirrusCIService_StreamLogs_FullMethodName                 = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/StreamLogs"
	CirrusCIService_SaveLogs_FullMethodName                   = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/SaveLogs"
	CirrusCIService_UploadCache_FullMethodName                = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/UploadCache"
	CirrusCIService_UploadArtifacts_FullMethodName            = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/UploadArtifacts"
	CirrusCIService_GenerateArtifactUploadURLs_FullMethodName = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/GenerateArtifactUploadURLs"
	CirrusCIService_CommitUploadedArtifacts_FullMethodName    = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/CommitUploadedArtifacts"
	CirrusCIService_DownloadCache_FullMethodName              = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/DownloadCache"
	CirrusCIService_CacheInfo_FullMethodName                  = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/CacheInfo"
	CirrusCIService_DeleteCache_FullMethodName                = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/DeleteCache"
	CirrusCIService_Heartbeat_FullMethodName                  = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/Heartbeat"
	CirrusCIService_ReportStopHook_FullMethodName             = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/ReportStopHook"
	CirrusCIService_ReportAgentError_FullMethodName           = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/ReportAgentError"
	CirrusCIService_ReportAgentWarning_FullMethodName         = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/ReportAgentWarning"
	CirrusCIService_ReportAgentSignal_FullMethodName          = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/ReportAgentSignal"
	CirrusCIService_ReportAgentLogs_FullMethodName            = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/ReportAgentLogs"
	CirrusCIService_ReportAgentFinished_FullMethodName        = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/ReportAgentFinished"
	CirrusCIService_ReportTerminalAttached_FullMethodName     = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/ReportTerminalAttached"
	CirrusCIService_ReportTerminalLifecycle_FullMethodName    = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/ReportTerminalLifecycle"
	CirrusCIService_GenerateCacheUploadURL_FullMethodName     = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/GenerateCacheUploadURL"
	CirrusCIService_GenerateCacheDownloadURLs_FullMethodName  = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService/GenerateCacheDownloadURLs"
)
View Source 
const (
	CirrusRemoteExecutorService_Capabilities_FullMethodName = "/org.cirruslabs.ci.services.cirruscigrpc.CirrusRemoteExecutorService/Capabilities"
)

Variables

View Source 
var CirrusCIService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "org.cirruslabs.ci.services.cirruscigrpc.CirrusCIService",
	HandlerType: (*CirrusCIServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "InitialCommands",
			Handler:    _CirrusCIService_InitialCommands_Handler,
		},
		{
			MethodName: "ReportCommandUpdates",
			Handler:    _CirrusCIService_ReportCommandUpdates_Handler,
		},
		{
			MethodName: "ReportAnnotations",
			Handler:    _CirrusCIService_ReportAnnotations_Handler,
		},
		{
			MethodName: "GenerateArtifactUploadURLs",
			Handler:    _CirrusCIService_GenerateArtifactUploadURLs_Handler,
		},
		{
			MethodName: "CommitUploadedArtifacts",
			Handler:    _CirrusCIService_CommitUploadedArtifacts_Handler,
		},
		{
			MethodName: "CacheInfo",
			Handler:    _CirrusCIService_CacheInfo_Handler,
		},
		{
			MethodName: "DeleteCache",
			Handler:    _CirrusCIService_DeleteCache_Handler,
		},
		{
			MethodName: "Heartbeat",
			Handler:    _CirrusCIService_Heartbeat_Handler,
		},
		{
			MethodName: "ReportStopHook",
			Handler:    _CirrusCIService_ReportStopHook_Handler,
		},
		{
			MethodName: "ReportAgentError",
			Handler:    _CirrusCIService_ReportAgentError_Handler,
		},
		{
			MethodName: "ReportAgentWarning",
			Handler:    _CirrusCIService_ReportAgentWarning_Handler,
		},
		{
			MethodName: "ReportAgentSignal",
			Handler:    _CirrusCIService_ReportAgentSignal_Handler,
		},
		{
			MethodName: "ReportAgentLogs",
			Handler:    _CirrusCIService_ReportAgentLogs_Handler,
		},
		{
			MethodName: "ReportAgentFinished",
			Handler:    _CirrusCIService_ReportAgentFinished_Handler,
		},
		{
			MethodName: "ReportTerminalAttached",
			Handler:    _CirrusCIService_ReportTerminalAttached_Handler,
		},
		{
			MethodName: "ReportTerminalLifecycle",
			Handler:    _CirrusCIService_ReportTerminalLifecycle_Handler,
		},
		{
			MethodName: "GenerateCacheUploadURL",
			Handler:    _CirrusCIService_GenerateCacheUploadURL_Handler,
		},
		{
			MethodName: "GenerateCacheDownloadURLs",
			Handler:    _CirrusCIService_GenerateCacheDownloadURLs_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamLogs",
			Handler:       _CirrusCIService_StreamLogs_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "SaveLogs",
			Handler:       _CirrusCIService_SaveLogs_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "UploadCache",
			Handler:       _CirrusCIService_UploadCache_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "UploadArtifacts",
			Handler:       _CirrusCIService_UploadArtifacts_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "DownloadCache",
			Handler:       _CirrusCIService_DownloadCache_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pkg/api/cirrus_ci_service.proto",
}

CirrusCIService_ServiceDesc is the grpc.ServiceDesc for CirrusCIService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var CirrusConfigurationEvaluatorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "org.cirruslabs.ci.services.cirruscigrpc.CirrusConfigurationEvaluatorService",
	HandlerType: (*CirrusConfigurationEvaluatorServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "EvaluateConfig",
			Handler:    _CirrusConfigurationEvaluatorService_EvaluateConfig_Handler,
		},
		{
			MethodName: "JSONSchema",
			Handler:    _CirrusConfigurationEvaluatorService_JSONSchema_Handler,
		},
		{
			MethodName: "EvaluateFunction",
			Handler:    _CirrusConfigurationEvaluatorService_EvaluateFunction_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/api/cirrus_ci_service.proto",
}

CirrusConfigurationEvaluatorService_ServiceDesc is the grpc.ServiceDesc for CirrusConfigurationEvaluatorService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var CirrusRemoteExecutorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "org.cirruslabs.ci.services.cirruscigrpc.CirrusRemoteExecutorService",
	HandlerType: (*CirrusRemoteExecutorServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Capabilities",
			Handler:    _CirrusRemoteExecutorService_Capabilities_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/api/cirrus_ci_service.proto",
}

CirrusRemoteExecutorService_ServiceDesc is the grpc.ServiceDesc for CirrusRemoteExecutorService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var CirrusWorkersService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "org.cirruslabs.ci.services.cirruscigrpc.CirrusWorkersService",
	HandlerType: (*CirrusWorkersServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Register",
			Handler:    _CirrusWorkersService_Register_Handler,
		},
		{
			MethodName: "Poll",
			Handler:    _CirrusWorkersService_Poll_Handler,
		},
		{
			MethodName: "TaskStarted",
			Handler:    _CirrusWorkersService_TaskStarted_Handler,
		},
		{
			MethodName: "TaskFailed",
			Handler:    _CirrusWorkersService_TaskFailed_Handler,
		},
		{
			MethodName: "TaskStopped",
			Handler:    _CirrusWorkersService_TaskStopped_Handler,
		},
		{
			MethodName: "UpdateStatus",
			Handler:    _CirrusWorkersService_UpdateStatus_Handler,
		},
		{
			MethodName: "QueryRunningTasks",
			Handler:    _CirrusWorkersService_QueryRunningTasks_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/api/cirrus_ci_service.proto",
}

CirrusWorkersService_ServiceDesc is the grpc.ServiceDesc for CirrusWorkersService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterCirrusCIServiceServer 

func RegisterCirrusCIServiceServer(s grpc.ServiceRegistrar, srv CirrusCIServiceServer)

func RegisterCirrusConfigurationEvaluatorServiceServer 

func RegisterCirrusConfigurationEvaluatorServiceServer(s grpc.ServiceRegistrar, srv CirrusConfigurationEvaluatorServiceServer)

func RegisterCirrusRemoteExecutorServiceServer 

func RegisterCirrusRemoteExecutorServiceServer(s grpc.ServiceRegistrar, srv CirrusRemoteExecutorServiceServer)

func RegisterCirrusWorkersServiceServer 

func RegisterCirrusWorkersServiceServer(s grpc.ServiceRegistrar, srv CirrusWorkersServiceServer)

Types

type CirrusCIServiceClient 

type CirrusCIServiceClient interface {
	InitialCommands(ctx context.Context, in *api.InitialCommandsRequest, opts ...grpc.CallOption) (*api.CommandsResponse, error)
	ReportCommandUpdates(ctx context.Context, in *api.ReportCommandUpdatesRequest, opts ...grpc.CallOption) (*api.ReportCommandUpdatesResponse, error)
	ReportAnnotations(ctx context.Context, in *api.ReportAnnotationsCommandRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	StreamLogs(ctx context.Context, opts ...grpc.CallOption) (CirrusCIService_StreamLogsClient, error)
	SaveLogs(ctx context.Context, opts ...grpc.CallOption) (CirrusCIService_SaveLogsClient, error)
	UploadCache(ctx context.Context, opts ...grpc.CallOption) (CirrusCIService_UploadCacheClient, error)
	// Artifacts upload over gRPC
	UploadArtifacts(ctx context.Context, opts ...grpc.CallOption) (CirrusCIService_UploadArtifactsClient, error)
	// Artifacts upload over HTTPS
	GenerateArtifactUploadURLs(ctx context.Context, in *api.GenerateArtifactUploadURLsRequest, opts ...grpc.CallOption) (*api.GenerateArtifactUploadURLsResponse, error)
	CommitUploadedArtifacts(ctx context.Context, in *api.CommitUploadedArtifactsRequest, opts ...grpc.CallOption) (*api.CommitUploadedArtifactsResponse, error)
	DownloadCache(ctx context.Context, in *api.DownloadCacheRequest, opts ...grpc.CallOption) (CirrusCIService_DownloadCacheClient, error)
	CacheInfo(ctx context.Context, in *api.CacheInfoRequest, opts ...grpc.CallOption) (*api.CacheInfoResponse, error)
	DeleteCache(ctx context.Context, in *api.DeleteCacheRequest, opts ...grpc.CallOption) (*api.DeleteCacheResponse, error)
	Heartbeat(ctx context.Context, in *api.HeartbeatRequest, opts ...grpc.CallOption) (*api.HeartbeatResponse, error)
	ReportStopHook(ctx context.Context, in *api.ReportStopHookRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ReportAgentError(ctx context.Context, in *api.ReportAgentProblemRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ReportAgentWarning(ctx context.Context, in *api.ReportAgentProblemRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ReportAgentSignal(ctx context.Context, in *api.ReportAgentSignalRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ReportAgentLogs(ctx context.Context, in *api.ReportAgentLogsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ReportAgentFinished(ctx context.Context, in *api.ReportAgentFinishedRequest, opts ...grpc.CallOption) (*api.ReportAgentFinishedResponse, error)
	ReportTerminalAttached(ctx context.Context, in *api.ReportTerminalAttachedRequest, opts ...grpc.CallOption) (*api.ReportTerminalAttachedResponse, error)
	ReportTerminalLifecycle(ctx context.Context, in *api.ReportTerminalLifecycleRequest, opts ...grpc.CallOption) (*api.ReportTerminalLifecycleResponse, error)
	GenerateCacheUploadURL(ctx context.Context, in *api.CacheKey, opts ...grpc.CallOption) (*api.GenerateURLResponse, error)
	GenerateCacheDownloadURLs(ctx context.Context, in *api.CacheKey, opts ...grpc.CallOption) (*api.GenerateURLsResponse, error)
}

CirrusCIServiceClient is the client API for CirrusCIService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCirrusCIServiceClient 

func NewCirrusCIServiceClient(cc grpc.ClientConnInterface) CirrusCIServiceClient

type CirrusCIServiceServer 

type CirrusCIServiceServer interface {
	InitialCommands(context.Context, *api.InitialCommandsRequest) (*api.CommandsResponse, error)
	ReportCommandUpdates(context.Context, *api.ReportCommandUpdatesRequest) (*api.ReportCommandUpdatesResponse, error)
	ReportAnnotations(context.Context, *api.ReportAnnotationsCommandRequest) (*emptypb.Empty, error)
	StreamLogs(CirrusCIService_StreamLogsServer) error
	SaveLogs(CirrusCIService_SaveLogsServer) error
	UploadCache(CirrusCIService_UploadCacheServer) error
	// Artifacts upload over gRPC
	UploadArtifacts(CirrusCIService_UploadArtifactsServer) error
	// Artifacts upload over HTTPS
	GenerateArtifactUploadURLs(context.Context, *api.GenerateArtifactUploadURLsRequest) (*api.GenerateArtifactUploadURLsResponse, error)
	CommitUploadedArtifacts(context.Context, *api.CommitUploadedArtifactsRequest) (*api.CommitUploadedArtifactsResponse, error)
	DownloadCache(*api.DownloadCacheRequest, CirrusCIService_DownloadCacheServer) error
	CacheInfo(context.Context, *api.CacheInfoRequest) (*api.CacheInfoResponse, error)
	DeleteCache(context.Context, *api.DeleteCacheRequest) (*api.DeleteCacheResponse, error)
	Heartbeat(context.Context, *api.HeartbeatRequest) (*api.HeartbeatResponse, error)
	ReportStopHook(context.Context, *api.ReportStopHookRequest) (*emptypb.Empty, error)
	ReportAgentError(context.Context, *api.ReportAgentProblemRequest) (*emptypb.Empty, error)
	ReportAgentWarning(context.Context, *api.ReportAgentProblemRequest) (*emptypb.Empty, error)
	ReportAgentSignal(context.Context, *api.ReportAgentSignalRequest) (*emptypb.Empty, error)
	ReportAgentLogs(context.Context, *api.ReportAgentLogsRequest) (*emptypb.Empty, error)
	ReportAgentFinished(context.Context, *api.ReportAgentFinishedRequest) (*api.ReportAgentFinishedResponse, error)
	ReportTerminalAttached(context.Context, *api.ReportTerminalAttachedRequest) (*api.ReportTerminalAttachedResponse, error)
	ReportTerminalLifecycle(context.Context, *api.ReportTerminalLifecycleRequest) (*api.ReportTerminalLifecycleResponse, error)
	GenerateCacheUploadURL(context.Context, *api.CacheKey) (*api.GenerateURLResponse, error)
	GenerateCacheDownloadURLs(context.Context, *api.CacheKey) (*api.GenerateURLsResponse, error)
}

CirrusCIServiceServer is the server API for CirrusCIService service. All implementations should embed UnimplementedCirrusCIServiceServer for forward compatibility

type CirrusCIService_DownloadCacheClient 

type CirrusCIService_DownloadCacheClient interface {
	Recv() (*api.DataChunk, error)
	grpc.ClientStream
}

type CirrusCIService_DownloadCacheServer 

type CirrusCIService_DownloadCacheServer interface {
	Send(*api.DataChunk) error
	grpc.ServerStream
}

type CirrusCIService_SaveLogsClient 

type CirrusCIService_SaveLogsClient interface {
	Send(*api.LogEntry) error
	CloseAndRecv() (*api.UploadLogsResponse, error)
	grpc.ClientStream
}

type CirrusCIService_SaveLogsServer 

type CirrusCIService_SaveLogsServer interface {
	SendAndClose(*api.UploadLogsResponse) error
	Recv() (*api.LogEntry, error)
	grpc.ServerStream
}

type CirrusCIService_StreamLogsClient 

type CirrusCIService_StreamLogsClient interface {
	Send(*api.LogEntry) error
	CloseAndRecv() (*api.UploadLogsResponse, error)
	grpc.ClientStream
}

type CirrusCIService_StreamLogsServer 

type CirrusCIService_StreamLogsServer interface {
	SendAndClose(*api.UploadLogsResponse) error
	Recv() (*api.LogEntry, error)
	grpc.ServerStream
}

type CirrusCIService_UploadArtifactsClient 

type CirrusCIService_UploadArtifactsClient interface {
	Send(*api.ArtifactEntry) error
	CloseAndRecv() (*api.UploadArtifactsResponse, error)
	grpc.ClientStream
}

type CirrusCIService_UploadArtifactsServer 

type CirrusCIService_UploadArtifactsServer interface {
	SendAndClose(*api.UploadArtifactsResponse) error
	Recv() (*api.ArtifactEntry, error)
	grpc.ServerStream
}

type CirrusCIService_UploadCacheClient 

type CirrusCIService_UploadCacheClient interface {
	Send(*api.CacheEntry) error
	CloseAndRecv() (*api.UploadCacheResponse, error)
	grpc.ClientStream
}

type CirrusCIService_UploadCacheServer 

type CirrusCIService_UploadCacheServer interface {
	SendAndClose(*api.UploadCacheResponse) error
	Recv() (*api.CacheEntry, error)
	grpc.ServerStream
}

type CirrusConfigurationEvaluatorServiceClient 

type CirrusConfigurationEvaluatorServiceClient interface {
	// Parser
	EvaluateConfig(ctx context.Context, in *api.EvaluateConfigRequest, opts ...grpc.CallOption) (*api.EvaluateConfigResponse, error)
	JSONSchema(ctx context.Context, in *api.JSONSchemaRequest, opts ...grpc.CallOption) (*api.JSONSchemaResponse, error)
	// Hooks
	EvaluateFunction(ctx context.Context, in *api.EvaluateFunctionRequest, opts ...grpc.CallOption) (*api.EvaluateFunctionResponse, error)
}

CirrusConfigurationEvaluatorServiceClient is the client API for CirrusConfigurationEvaluatorService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCirrusConfigurationEvaluatorServiceClient 

func NewCirrusConfigurationEvaluatorServiceClient(cc grpc.ClientConnInterface) CirrusConfigurationEvaluatorServiceClient

type CirrusConfigurationEvaluatorServiceServer 

type CirrusConfigurationEvaluatorServiceServer interface {
	// Parser
	EvaluateConfig(context.Context, *api.EvaluateConfigRequest) (*api.EvaluateConfigResponse, error)
	JSONSchema(context.Context, *api.JSONSchemaRequest) (*api.JSONSchemaResponse, error)
	// Hooks
	EvaluateFunction(context.Context, *api.EvaluateFunctionRequest) (*api.EvaluateFunctionResponse, error)
}

CirrusConfigurationEvaluatorServiceServer is the server API for CirrusConfigurationEvaluatorService service. All implementations should embed UnimplementedCirrusConfigurationEvaluatorServiceServer for forward compatibility

type CirrusRemoteExecutorServiceClient 

type CirrusRemoteExecutorServiceClient interface {
	Capabilities(ctx context.Context, in *api.CapabilitiesRequest, opts ...grpc.CallOption) (*api.CapabilitiesResponse, error)
}

CirrusRemoteExecutorServiceClient is the client API for CirrusRemoteExecutorService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCirrusRemoteExecutorServiceClient 

func NewCirrusRemoteExecutorServiceClient(cc grpc.ClientConnInterface) CirrusRemoteExecutorServiceClient

type CirrusRemoteExecutorServiceServer 

type CirrusRemoteExecutorServiceServer interface {
	Capabilities(context.Context, *api.CapabilitiesRequest) (*api.CapabilitiesResponse, error)
}

CirrusRemoteExecutorServiceServer is the server API for CirrusRemoteExecutorService service. All implementations should embed UnimplementedCirrusRemoteExecutorServiceServer for forward compatibility

type CirrusWorkersServiceClient 

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

CirrusWorkersServiceClient is the client API for CirrusWorkersService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCirrusWorkersServiceClient 

func NewCirrusWorkersServiceClient(cc grpc.ClientConnInterface) CirrusWorkersServiceClient

type CirrusWorkersServiceServer 

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

CirrusWorkersServiceServer is the server API for CirrusWorkersService service. All implementations should embed UnimplementedCirrusWorkersServiceServer for forward compatibility

type UnimplementedCirrusCIServiceServer 

type UnimplementedCirrusCIServiceServer struct {
}

UnimplementedCirrusCIServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedCirrusCIServiceServer) CacheInfo 

func (UnimplementedCirrusCIServiceServer) CacheInfo(context.Context, *api.CacheInfoRequest) (*api.CacheInfoResponse, error)

func (UnimplementedCirrusCIServiceServer) CommitUploadedArtifacts 

func (UnimplementedCirrusCIServiceServer) CommitUploadedArtifacts(context.Context, *api.CommitUploadedArtifactsRequest) (*api.CommitUploadedArtifactsResponse, error)

func (UnimplementedCirrusCIServiceServer) DeleteCache 

func (UnimplementedCirrusCIServiceServer) DeleteCache(context.Context, *api.DeleteCacheRequest) (*api.DeleteCacheResponse, error)

func (UnimplementedCirrusCIServiceServer) DownloadCache 

func (UnimplementedCirrusCIServiceServer) DownloadCache(*api.DownloadCacheRequest, CirrusCIService_DownloadCacheServer) error

func (UnimplementedCirrusCIServiceServer) GenerateArtifactUploadURLs 

func (UnimplementedCirrusCIServiceServer) GenerateArtifactUploadURLs(context.Context, *api.GenerateArtifactUploadURLsRequest) (*api.GenerateArtifactUploadURLsResponse, error)

func (UnimplementedCirrusCIServiceServer) GenerateCacheDownloadURLs 

func (UnimplementedCirrusCIServiceServer) GenerateCacheDownloadURLs(context.Context, *api.CacheKey) (*api.GenerateURLsResponse, error)

func (UnimplementedCirrusCIServiceServer) GenerateCacheUploadURL 

func (UnimplementedCirrusCIServiceServer) GenerateCacheUploadURL(context.Context, *api.CacheKey) (*api.GenerateURLResponse, error)

func (UnimplementedCirrusCIServiceServer) Heartbeat 

func (UnimplementedCirrusCIServiceServer) Heartbeat(context.Context, *api.HeartbeatRequest) (*api.HeartbeatResponse, error)

func (UnimplementedCirrusCIServiceServer) InitialCommands 

func (UnimplementedCirrusCIServiceServer) InitialCommands(context.Context, *api.InitialCommandsRequest) (*api.CommandsResponse, error)

func (UnimplementedCirrusCIServiceServer) ReportAgentError 

func (UnimplementedCirrusCIServiceServer) ReportAgentError(context.Context, *api.ReportAgentProblemRequest) (*emptypb.Empty, error)

func (UnimplementedCirrusCIServiceServer) ReportAgentFinished 

func (UnimplementedCirrusCIServiceServer) ReportAgentFinished(context.Context, *api.ReportAgentFinishedRequest) (*api.ReportAgentFinishedResponse, error)

func (UnimplementedCirrusCIServiceServer) ReportAgentLogs 

func (UnimplementedCirrusCIServiceServer) ReportAgentLogs(context.Context, *api.ReportAgentLogsRequest) (*emptypb.Empty, error)

func (UnimplementedCirrusCIServiceServer) ReportAgentSignal 

func (UnimplementedCirrusCIServiceServer) ReportAgentSignal(context.Context, *api.ReportAgentSignalRequest) (*emptypb.Empty, error)

func (UnimplementedCirrusCIServiceServer) ReportAgentWarning 

func (UnimplementedCirrusCIServiceServer) ReportAgentWarning(context.Context, *api.ReportAgentProblemRequest) (*emptypb.Empty, error)

func (UnimplementedCirrusCIServiceServer) ReportAnnotations 

func (UnimplementedCirrusCIServiceServer) ReportAnnotations(context.Context, *api.ReportAnnotationsCommandRequest) (*emptypb.Empty, error)

func (UnimplementedCirrusCIServiceServer) ReportCommandUpdates 

func (UnimplementedCirrusCIServiceServer) ReportCommandUpdates(context.Context, *api.ReportCommandUpdatesRequest) (*api.ReportCommandUpdatesResponse, error)

func (UnimplementedCirrusCIServiceServer) ReportStopHook 

func (UnimplementedCirrusCIServiceServer) ReportStopHook(context.Context, *api.ReportStopHookRequest) (*emptypb.Empty, error)

func (UnimplementedCirrusCIServiceServer) ReportTerminalAttached 

func (UnimplementedCirrusCIServiceServer) ReportTerminalAttached(context.Context, *api.ReportTerminalAttachedRequest) (*api.ReportTerminalAttachedResponse, error)

func (UnimplementedCirrusCIServiceServer) ReportTerminalLifecycle 

func (UnimplementedCirrusCIServiceServer) ReportTerminalLifecycle(context.Context, *api.ReportTerminalLifecycleRequest) (*api.ReportTerminalLifecycleResponse, error)

func (UnimplementedCirrusCIServiceServer) SaveLogs 

func (UnimplementedCirrusCIServiceServer) SaveLogs(CirrusCIService_SaveLogsServer) error

func (UnimplementedCirrusCIServiceServer) StreamLogs 

func (UnimplementedCirrusCIServiceServer) StreamLogs(CirrusCIService_StreamLogsServer) error

func (UnimplementedCirrusCIServiceServer) UploadArtifacts 

func (UnimplementedCirrusCIServiceServer) UploadArtifacts(CirrusCIService_UploadArtifactsServer) error

func (UnimplementedCirrusCIServiceServer) UploadCache 

func (UnimplementedCirrusCIServiceServer) UploadCache(CirrusCIService_UploadCacheServer) error

type UnimplementedCirrusConfigurationEvaluatorServiceServer 

type UnimplementedCirrusConfigurationEvaluatorServiceServer struct {
}

UnimplementedCirrusConfigurationEvaluatorServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedCirrusConfigurationEvaluatorServiceServer) EvaluateConfig 

func (UnimplementedCirrusConfigurationEvaluatorServiceServer) EvaluateConfig(context.Context, *api.EvaluateConfigRequest) (*api.EvaluateConfigResponse, error)

func (UnimplementedCirrusConfigurationEvaluatorServiceServer) EvaluateFunction 

func (UnimplementedCirrusConfigurationEvaluatorServiceServer) EvaluateFunction(context.Context, *api.EvaluateFunctionRequest) (*api.EvaluateFunctionResponse, error)

func (UnimplementedCirrusConfigurationEvaluatorServiceServer) JSONSchema 

func (UnimplementedCirrusConfigurationEvaluatorServiceServer) JSONSchema(context.Context, *api.JSONSchemaRequest) (*api.JSONSchemaResponse, error)

type UnimplementedCirrusRemoteExecutorServiceServer 

type UnimplementedCirrusRemoteExecutorServiceServer struct {
}

UnimplementedCirrusRemoteExecutorServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedCirrusRemoteExecutorServiceServer) Capabilities 

func (UnimplementedCirrusRemoteExecutorServiceServer) Capabilities(context.Context, *api.CapabilitiesRequest) (*api.CapabilitiesResponse, error)

type UnimplementedCirrusWorkersServiceServer 

type UnimplementedCirrusWorkersServiceServer struct {
}

UnimplementedCirrusWorkersServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedCirrusWorkersServiceServer) Poll 

func (UnimplementedCirrusWorkersServiceServer) Poll(context.Context, *api.PollRequest) (*api.PollResponse, error)

func (UnimplementedCirrusWorkersServiceServer) QueryRunningTasks 

func (UnimplementedCirrusWorkersServiceServer) QueryRunningTasks(context.Context, *api.QueryRunningTasksRequest) (*api.QueryRunningTasksResponse, error)

func (UnimplementedCirrusWorkersServiceServer) Register 

func (UnimplementedCirrusWorkersServiceServer) Register(context.Context, *api.RegisterRequest) (*api.RegisterResponse, error)

func (UnimplementedCirrusWorkersServiceServer) TaskFailed 

func (UnimplementedCirrusWorkersServiceServer) TaskFailed(context.Context, *api.TaskFailedRequest) (*emptypb.Empty, error)

func (UnimplementedCirrusWorkersServiceServer) TaskStarted 

func (UnimplementedCirrusWorkersServiceServer) TaskStarted(context.Context, *api.TaskIdentification) (*emptypb.Empty, error)

func (UnimplementedCirrusWorkersServiceServer) TaskStopped 

func (UnimplementedCirrusWorkersServiceServer) TaskStopped(context.Context, *api.TaskIdentification) (*emptypb.Empty, error)

func (UnimplementedCirrusWorkersServiceServer) UpdateStatus 

func (UnimplementedCirrusWorkersServiceServer) UpdateStatus(context.Context, *api.UpdateStatusRequest) (*api.WorkerStatus, error)

type UnsafeCirrusCIServiceServer 

type UnsafeCirrusCIServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeCirrusCIServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CirrusCIServiceServer will result in compilation errors.

type UnsafeCirrusConfigurationEvaluatorServiceServer 

type UnsafeCirrusConfigurationEvaluatorServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeCirrusConfigurationEvaluatorServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CirrusConfigurationEvaluatorServiceServer will result in compilation errors.

type UnsafeCirrusRemoteExecutorServiceServer 

type UnsafeCirrusRemoteExecutorServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeCirrusRemoteExecutorServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CirrusRemoteExecutorServiceServer will result in compilation errors.

type UnsafeCirrusWorkersServiceServer 

type UnsafeCirrusWorkersServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeCirrusWorkersServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CirrusWorkersServiceServer will result in compilation errors.

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.