executor

type ActionResult struct {

	// Types that are valid to be assigned to Outcome:
	//
	//	*ActionResult_Output
	//	*ActionResult_Error
	Outcome isActionResult_Outcome `protobuf_oneof:"outcome"`
	// contains filtered or unexported fields
}

type ActionResult_Error struct {
	Error *errorcode.ActionPlatformError `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type ActionResult_Output struct {
	Output []byte `protobuf:"bytes,1,opt,name=output,proto3,oneof"`
}

type ActionStatus struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type ControlPlaneIdentity struct {
	Urn        string `protobuf:"bytes,1,opt,name=urn,proto3" json:"urn,omitempty"`
	PrivateKey string `protobuf:"bytes,2,opt,name=private_key,json=privateKey,proto3" json:"private_key,omitempty"`
	OrgId      int64  `protobuf:"varint,3,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	RunnerId   string `protobuf:"bytes,4,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	// contains filtered or unexported fields
}

type ControlPlaneRuntime struct {
	OpmsBaseUrl       string            `protobuf:"bytes,1,opt,name=opms_base_url,json=opmsBaseUrl,proto3" json:"opms_base_url,omitempty"`
	TaskConcurrency   int32             `protobuf:"varint,2,opt,name=task_concurrency,json=taskConcurrency,proto3" json:"task_concurrency,omitempty"`
	OpmsExtraHeaders  map[string]string `` /* 185-byte string literal not displayed */
	OpmsProxyUrl      string            `protobuf:"bytes,4,opt,name=opms_proxy_url,json=opmsProxyUrl,proto3" json:"opms_proxy_url,omitempty"`
	SkipSslValidation bool              `protobuf:"varint,5,opt,name=skip_ssl_validation,json=skipSslValidation,proto3" json:"skip_ssl_validation,omitempty"`
	MinTlsVersion     string            `protobuf:"bytes,6,opt,name=min_tls_version,json=minTlsVersion,proto3" json:"min_tls_version,omitempty"`
	// contains filtered or unexported fields
}

type ExecutorClient interface {
	GetControlPlaneConfig(ctx context.Context, in *GetControlPlaneConfigRequest, opts ...grpc.CallOption) (*GetControlPlaneConfigResponse, error)
	// RunAction runs a single action and streams updates ending in a final ActionResult.
	RunAction(ctx context.Context, in *RunActionRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[RunActionResponse], error)
	// Health reports executor readiness and liveness; used to gate dispatch.
	Health(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)
}

type ExecutorServer interface {
	GetControlPlaneConfig(context.Context, *GetControlPlaneConfigRequest) (*GetControlPlaneConfigResponse, error)
	// RunAction runs a single action and streams updates ending in a final ActionResult.
	RunAction(*RunActionRequest, grpc.ServerStreamingServer[RunActionResponse]) error
	// Health reports executor readiness and liveness; used to gate dispatch.
	Health(context.Context, *HealthRequest) (*HealthResponse, error)
	// contains filtered or unexported methods
}

type Executor_RunActionClient = grpc.ServerStreamingClient[RunActionResponse]

type Executor_RunActionServer = grpc.ServerStreamingServer[RunActionResponse]

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

type GetControlPlaneConfigResponse struct {
	SplitMode bool                  `protobuf:"varint,1,opt,name=split_mode,json=splitMode,proto3" json:"split_mode,omitempty"`
	LogLevel  string                `protobuf:"bytes,2,opt,name=log_level,json=logLevel,proto3" json:"log_level,omitempty"`
	Identity  *ControlPlaneIdentity `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	Runtime   *ControlPlaneRuntime  `protobuf:"bytes,4,opt,name=runtime,proto3" json:"runtime,omitempty"`
	// contains filtered or unexported fields
}

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

type HealthResponse struct {
	Ready         bool   `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
	ActiveActions int32  `protobuf:"varint,2,opt,name=active_actions,json=activeActions,proto3" json:"active_actions,omitempty"`
	Version       string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

type RunActionRequest struct {
	Task []byte `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

type RunActionResponse struct {

	// Types that are valid to be assigned to Event:
	//
	//	*RunActionResponse_Status
	//	*RunActionResponse_Result
	Event isRunActionResponse_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

type RunActionResponse_Result struct {
	Result *ActionResult `protobuf:"bytes,2,opt,name=result,proto3,oneof"`
}

type RunActionResponse_Status struct {
	Status *ActionStatus `protobuf:"bytes,1,opt,name=status,proto3,oneof"`
}

type UnimplementedExecutorServer struct{}

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