pb

package
v0.0.6 Latest Latest
Warning

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

 Go to latest Published: Jun 6, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ReconcileEventMessage_ReconcileType_name = map[int32]string{
		0: "RECONCILE_TYPE_INVALID",
		1: "RECONCILE_TYPE_CREATE_OR_UPDATE",
		2: "RECONCILE_TYPE_DELETE",
	}
	ReconcileEventMessage_ReconcileType_value = map[string]int32{
		"RECONCILE_TYPE_INVALID":          0,
		"RECONCILE_TYPE_CREATE_OR_UPDATE": 1,
		"RECONCILE_TYPE_DELETE":           2,
	}
)

Enum value maps for ReconcileEventMessage_ReconcileType.

View Source 
var (
	TaskExecutionResponseMessage_TaskState_name = map[int32]string{
		0: "TASK_STATE_INVALID",
		1: "TASK_STATE_COMPLETED",
		2: "TASK_STATE_FAILED_RETRYABLE",
		3: "TASK_STATE_FAILED_NON_RETRYABLE",
		4: "TASK_STATE_FAILED_NON_CHARGEABLE",
	}
	TaskExecutionResponseMessage_TaskState_value = map[string]int32{
		"TASK_STATE_INVALID":               0,
		"TASK_STATE_COMPLETED":             1,
		"TASK_STATE_FAILED_RETRYABLE":      2,
		"TASK_STATE_FAILED_NON_RETRYABLE":  3,
		"TASK_STATE_FAILED_NON_CHARGEABLE": 4,
	}
)

Enum value maps for TaskExecutionResponseMessage_TaskState.

View Source 
var (
	TaskType_name = map[int32]string{
		0: "TASK_TYPE_INVALID",
		1: "TASK_TYPE_VOID",
		2: "TASK_TYPE_HTTP",
		3: "TASK_TYPE_SCRIPT",
		4: "TASK_TYPE_KUBERNETES_API_REQUEST",
	}
	TaskType_value = map[string]int32{
		"TASK_TYPE_INVALID":                0,
		"TASK_TYPE_VOID":                   1,
		"TASK_TYPE_HTTP":                   2,
		"TASK_TYPE_SCRIPT":                 3,
		"TASK_TYPE_KUBERNETES_API_REQUEST": 4,
	}
)

Enum value maps for TaskType.

View Source 
var File_client_messages_proto protoreflect.FileDescriptor
View Source 
var File_reconciliation_request_proto protoreflect.FileDescriptor
View Source 
var File_remote_work_processor_service_proto protoreflect.FileDescriptor
View Source 
var File_server_messages_proto protoreflect.FileDescriptor
View Source 
var File_task_type_proto protoreflect.FileDescriptor
View Source 
var RemoteWorkProcessorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "sap.autopilot.remote.work.processor.v1.RemoteWorkProcessorService",
	HandlerType: (*RemoteWorkProcessorServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Session",
			Handler:       _RemoteWorkProcessorService_Session_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "remote_work_processor_service.proto",
}

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

Functions

func RegisterRemoteWorkProcessorServiceServer 

func RegisterRemoteWorkProcessorServiceServer(s grpc.ServiceRegistrar, srv RemoteWorkProcessorServiceServer)

Types

type ClientMessage 

type ClientMessage struct {

	// Types that are assignable to Body:
	//
	//	*ClientMessage_ProbeSession
	//	*ClientMessage_TaskExecutionResponse
	//	*ClientMessage_ReconcileEvent
	//	*ClientMessage_ConfirmConfigUpdate
	//	*ClientMessage_ConfirmEnabled
	//	*ClientMessage_ConfirmDisabled
	Body isClientMessage_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

func (*ClientMessage) Descriptor deprecated 

func (*ClientMessage) Descriptor() ([]byte, []int)

Deprecated: Use ClientMessage.ProtoReflect.Descriptor instead.

func (*ClientMessage) GetBody 

func (m *ClientMessage) GetBody() isClientMessage_Body

func (*ClientMessage) GetConfirmConfigUpdate 

func (x *ClientMessage) GetConfirmConfigUpdate() *ConfirmConfigUpdateMessage

func (*ClientMessage) GetConfirmDisabled 

func (x *ClientMessage) GetConfirmDisabled() *ConfirmDisabledMessage

func (*ClientMessage) GetConfirmEnabled 

func (x *ClientMessage) GetConfirmEnabled() *ConfirmEnabledMessage

func (*ClientMessage) GetProbeSession 

func (x *ClientMessage) GetProbeSession() *ProbeSessionMessage

func (*ClientMessage) GetReconcileEvent 

func (x *ClientMessage) GetReconcileEvent() *ReconcileEventMessage

func (*ClientMessage) GetTaskExecutionResponse 

func (x *ClientMessage) GetTaskExecutionResponse() *TaskExecutionResponseMessage

func (*ClientMessage) ProtoMessage 

func (*ClientMessage) ProtoMessage()

func (*ClientMessage) ProtoReflect 

func (x *ClientMessage) ProtoReflect() protoreflect.Message

func (*ClientMessage) Reset 

func (x *ClientMessage) Reset()

func (*ClientMessage) String 

func (x *ClientMessage) String() string

type ClientMessage_ConfirmConfigUpdate 

type ClientMessage_ConfirmConfigUpdate struct {
	ConfirmConfigUpdate *ConfirmConfigUpdateMessage `protobuf:"bytes,4,opt,name=confirm_config_update,json=confirmConfigUpdate,proto3,oneof"`
}

type ClientMessage_ConfirmDisabled 

type ClientMessage_ConfirmDisabled struct {
	ConfirmDisabled *ConfirmDisabledMessage `protobuf:"bytes,6,opt,name=confirm_disabled,json=confirmDisabled,proto3,oneof"`
}

type ClientMessage_ConfirmEnabled 

type ClientMessage_ConfirmEnabled struct {
	ConfirmEnabled *ConfirmEnabledMessage `protobuf:"bytes,5,opt,name=confirm_enabled,json=confirmEnabled,proto3,oneof"`
}

type ClientMessage_ProbeSession 

type ClientMessage_ProbeSession struct {
	ProbeSession *ProbeSessionMessage `protobuf:"bytes,1,opt,name=probe_session,json=probeSession,proto3,oneof"`
}

type ClientMessage_ReconcileEvent 

type ClientMessage_ReconcileEvent struct {
	ReconcileEvent *ReconcileEventMessage `protobuf:"bytes,3,opt,name=reconcile_event,json=reconcileEvent,proto3,oneof"`
}

type ClientMessage_TaskExecutionResponse 

type ClientMessage_TaskExecutionResponse struct {
	TaskExecutionResponse *TaskExecutionResponseMessage `protobuf:"bytes,2,opt,name=task_execution_response,json=taskExecutionResponse,proto3,oneof"`
}

type ConfirmConfigUpdateMessage 

type ConfirmConfigUpdateMessage struct {
	ConfigVersion string `protobuf:"bytes,1,opt,name=config_version,json=configVersion,proto3" json:"config_version,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfirmConfigUpdateMessage) Descriptor deprecated 

func (*ConfirmConfigUpdateMessage) Descriptor() ([]byte, []int)

Deprecated: Use ConfirmConfigUpdateMessage.ProtoReflect.Descriptor instead.

func (*ConfirmConfigUpdateMessage) GetConfigVersion 

func (x *ConfirmConfigUpdateMessage) GetConfigVersion() string

func (*ConfirmConfigUpdateMessage) ProtoMessage 

func (*ConfirmConfigUpdateMessage) ProtoMessage()

func (*ConfirmConfigUpdateMessage) ProtoReflect 

func (x *ConfirmConfigUpdateMessage) ProtoReflect() protoreflect.Message

func (*ConfirmConfigUpdateMessage) Reset 

func (x *ConfirmConfigUpdateMessage) Reset()

func (*ConfirmConfigUpdateMessage) String 

func (x *ConfirmConfigUpdateMessage) String() string

type ConfirmDisabledMessage 

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

func (*ConfirmDisabledMessage) Descriptor deprecated 

func (*ConfirmDisabledMessage) Descriptor() ([]byte, []int)

Deprecated: Use ConfirmDisabledMessage.ProtoReflect.Descriptor instead.

func (*ConfirmDisabledMessage) ProtoMessage 

func (*ConfirmDisabledMessage) ProtoMessage()

func (*ConfirmDisabledMessage) ProtoReflect 

func (x *ConfirmDisabledMessage) ProtoReflect() protoreflect.Message

func (*ConfirmDisabledMessage) Reset 

func (x *ConfirmDisabledMessage) Reset()

func (*ConfirmDisabledMessage) String 

func (x *ConfirmDisabledMessage) String() string

type ConfirmEnabledMessage 

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

func (*ConfirmEnabledMessage) Descriptor deprecated 

func (*ConfirmEnabledMessage) Descriptor() ([]byte, []int)

Deprecated: Use ConfirmEnabledMessage.ProtoReflect.Descriptor instead.

func (*ConfirmEnabledMessage) ProtoMessage 

func (*ConfirmEnabledMessage) ProtoMessage()

func (*ConfirmEnabledMessage) ProtoReflect 

func (x *ConfirmEnabledMessage) ProtoReflect() protoreflect.Message

func (*ConfirmEnabledMessage) Reset 

func (x *ConfirmEnabledMessage) Reset()

func (*ConfirmEnabledMessage) String 

func (x *ConfirmEnabledMessage) String() string

type DisableRequestMessage 

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

func (*DisableRequestMessage) Descriptor deprecated 

func (*DisableRequestMessage) Descriptor() ([]byte, []int)

Deprecated: Use DisableRequestMessage.ProtoReflect.Descriptor instead.

func (*DisableRequestMessage) ProtoMessage 

func (*DisableRequestMessage) ProtoMessage()

func (*DisableRequestMessage) ProtoReflect 

func (x *DisableRequestMessage) ProtoReflect() protoreflect.Message

func (*DisableRequestMessage) Reset 

func (x *DisableRequestMessage) Reset()

func (*DisableRequestMessage) String 

func (x *DisableRequestMessage) String() string

type EnableRequestMessage 

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

func (*EnableRequestMessage) Descriptor deprecated 

func (*EnableRequestMessage) Descriptor() ([]byte, []int)

Deprecated: Use EnableRequestMessage.ProtoReflect.Descriptor instead.

func (*EnableRequestMessage) ProtoMessage 

func (*EnableRequestMessage) ProtoMessage()

func (*EnableRequestMessage) ProtoReflect 

func (x *EnableRequestMessage) ProtoReflect() protoreflect.Message

func (*EnableRequestMessage) Reset 

func (x *EnableRequestMessage) Reset()

func (*EnableRequestMessage) String 

func (x *EnableRequestMessage) String() string

type NextEventRequestMessage 

type NextEventRequestMessage struct {
	Request         *ReconciliationRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	ResourceVersion string                 `protobuf:"bytes,2,opt,name=resource_version,json=resourceVersion,proto3" json:"resource_version,omitempty"`
	ReconcilerName  string                 `protobuf:"bytes,3,opt,name=reconciler_name,json=reconcilerName,proto3" json:"reconciler_name,omitempty"`
	// contains filtered or unexported fields
}

func (*NextEventRequestMessage) Descriptor deprecated 

func (*NextEventRequestMessage) Descriptor() ([]byte, []int)

Deprecated: Use NextEventRequestMessage.ProtoReflect.Descriptor instead.

func (*NextEventRequestMessage) GetReconcilerName 

func (x *NextEventRequestMessage) GetReconcilerName() string

func (*NextEventRequestMessage) GetRequest 

func (x *NextEventRequestMessage) GetRequest() *ReconciliationRequest

func (*NextEventRequestMessage) GetResourceVersion 

func (x *NextEventRequestMessage) GetResourceVersion() string

func (*NextEventRequestMessage) ProtoMessage 

func (*NextEventRequestMessage) ProtoMessage()

func (*NextEventRequestMessage) ProtoReflect 

func (x *NextEventRequestMessage) ProtoReflect() protoreflect.Message

func (*NextEventRequestMessage) Reset 

func (x *NextEventRequestMessage) Reset()

func (*NextEventRequestMessage) String 

func (x *NextEventRequestMessage) String() string

type ProbeSessionMessage 

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

func (*ProbeSessionMessage) Descriptor deprecated 

func (*ProbeSessionMessage) Descriptor() ([]byte, []int)

Deprecated: Use ProbeSessionMessage.ProtoReflect.Descriptor instead.

func (*ProbeSessionMessage) ProtoMessage 

func (*ProbeSessionMessage) ProtoMessage()

func (*ProbeSessionMessage) ProtoReflect 

func (x *ProbeSessionMessage) ProtoReflect() protoreflect.Message

func (*ProbeSessionMessage) Reset 

func (x *ProbeSessionMessage) Reset()

func (*ProbeSessionMessage) String 

func (x *ProbeSessionMessage) String() string

type ReconcileEventMessage 

type ReconcileEventMessage struct {
	ReconcilerName        string                              `protobuf:"bytes,1,opt,name=reconciler_name,json=reconcilerName,proto3" json:"reconciler_name,omitempty"`
	Type                  ReconcileEventMessage_ReconcileType `` /* 142-byte string literal not displayed */
	ResourceVersion       string                              `protobuf:"bytes,3,opt,name=resource_version,json=resourceVersion,proto3" json:"resource_version,omitempty"`
	Content               string                              `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"`
	ReconciliationRequest *ReconciliationRequest              `protobuf:"bytes,5,opt,name=reconciliation_request,json=reconciliationRequest,proto3" json:"reconciliation_request,omitempty"`
	// contains filtered or unexported fields
}

func (*ReconcileEventMessage) Descriptor deprecated 

func (*ReconcileEventMessage) Descriptor() ([]byte, []int)

Deprecated: Use ReconcileEventMessage.ProtoReflect.Descriptor instead.

func (*ReconcileEventMessage) GetContent 

func (x *ReconcileEventMessage) GetContent() string

func (*ReconcileEventMessage) GetReconcilerName 

func (x *ReconcileEventMessage) GetReconcilerName() string

func (*ReconcileEventMessage) GetReconciliationRequest 

func (x *ReconcileEventMessage) GetReconciliationRequest() *ReconciliationRequest

func (*ReconcileEventMessage) GetResourceVersion 

func (x *ReconcileEventMessage) GetResourceVersion() string

func (*ReconcileEventMessage) GetType 

func (x *ReconcileEventMessage) GetType() ReconcileEventMessage_ReconcileType

func (*ReconcileEventMessage) ProtoMessage 

func (*ReconcileEventMessage) ProtoMessage()

func (*ReconcileEventMessage) ProtoReflect 

func (x *ReconcileEventMessage) ProtoReflect() protoreflect.Message

func (*ReconcileEventMessage) Reset 

func (x *ReconcileEventMessage) Reset()

func (*ReconcileEventMessage) String 

func (x *ReconcileEventMessage) String() string

type ReconcileEventMessage_ReconcileType 

type ReconcileEventMessage_ReconcileType int32
const (
	ReconcileEventMessage_RECONCILE_TYPE_INVALID          ReconcileEventMessage_ReconcileType = 0
	ReconcileEventMessage_RECONCILE_TYPE_CREATE_OR_UPDATE ReconcileEventMessage_ReconcileType = 1
	ReconcileEventMessage_RECONCILE_TYPE_DELETE           ReconcileEventMessage_ReconcileType = 2
)

func (ReconcileEventMessage_ReconcileType) Descriptor 

func (ReconcileEventMessage_ReconcileType) Descriptor() protoreflect.EnumDescriptor

func (ReconcileEventMessage_ReconcileType) Enum 

func (x ReconcileEventMessage_ReconcileType) Enum() *ReconcileEventMessage_ReconcileType

func (ReconcileEventMessage_ReconcileType) EnumDescriptor deprecated 

func (ReconcileEventMessage_ReconcileType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ReconcileEventMessage_ReconcileType.Descriptor instead.

func (ReconcileEventMessage_ReconcileType) Number 

func (x ReconcileEventMessage_ReconcileType) Number() protoreflect.EnumNumber

func (ReconcileEventMessage_ReconcileType) String 

func (x ReconcileEventMessage_ReconcileType) String() string

func (ReconcileEventMessage_ReconcileType) Type 

func (ReconcileEventMessage_ReconcileType) Type() protoreflect.EnumType

type ReconciliationRequest 

type ReconciliationRequest struct {
	ResourceName      string  `protobuf:"bytes,1,opt,name=resource_name,json=resourceName,proto3" json:"resource_name,omitempty"`
	ResourceNamespace *string `protobuf:"bytes,2,opt,name=resource_namespace,json=resourceNamespace,proto3,oneof" json:"resource_namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*ReconciliationRequest) Descriptor deprecated 

func (*ReconciliationRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReconciliationRequest.ProtoReflect.Descriptor instead.

func (*ReconciliationRequest) GetResourceName 

func (x *ReconciliationRequest) GetResourceName() string

func (*ReconciliationRequest) GetResourceNamespace 

func (x *ReconciliationRequest) GetResourceNamespace() string

func (*ReconciliationRequest) ProtoMessage 

func (*ReconciliationRequest) ProtoMessage()

func (*ReconciliationRequest) ProtoReflect 

func (x *ReconciliationRequest) ProtoReflect() protoreflect.Message

func (*ReconciliationRequest) Reset 

func (x *ReconciliationRequest) Reset()

func (*ReconciliationRequest) String 

func (x *ReconciliationRequest) String() string

type RemoteWorkProcessorServiceClient 

type RemoteWorkProcessorServiceClient interface {
	Session(ctx context.Context, opts ...grpc.CallOption) (RemoteWorkProcessorService_SessionClient, error)
}

RemoteWorkProcessorServiceClient is the client API for RemoteWorkProcessorService 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 NewRemoteWorkProcessorServiceClient 

func NewRemoteWorkProcessorServiceClient(cc grpc.ClientConnInterface) RemoteWorkProcessorServiceClient

type RemoteWorkProcessorServiceServer 

type RemoteWorkProcessorServiceServer interface {
	Session(RemoteWorkProcessorService_SessionServer) error
	// contains filtered or unexported methods
}

RemoteWorkProcessorServiceServer is the server API for RemoteWorkProcessorService service. All implementations must embed UnimplementedRemoteWorkProcessorServiceServer for forward compatibility

type RemoteWorkProcessorService_SessionClient 

type RemoteWorkProcessorService_SessionClient interface {
	Send(*ClientMessage) error
	Recv() (*ServerMessage, error)
	grpc.ClientStream
}

type RemoteWorkProcessorService_SessionServer 

type RemoteWorkProcessorService_SessionServer interface {
	Send(*ServerMessage) error
	Recv() (*ClientMessage, error)
	grpc.ServerStream
}

type Resource 

type Resource struct {
	ApiVersion                    string                  `protobuf:"bytes,1,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
	Kind                          string                  `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"`
	Namespace                     *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ReconciliationPeriodInMinutes int32                   `` /* 153-byte string literal not displayed */
	// selector values are passed as list of strings, e.g ["app=autopi", "environment in (production, dev)"]
	LabelSelectors []string `protobuf:"bytes,5,rep,name=label_selectors,json=labelSelectors,proto3" json:"label_selectors,omitempty"`
	FieldSelectors []string `protobuf:"bytes,6,rep,name=field_selectors,json=fieldSelectors,proto3" json:"field_selectors,omitempty"`
	// contains filtered or unexported fields
}

func (*Resource) Descriptor deprecated 

func (*Resource) Descriptor() ([]byte, []int)

Deprecated: Use Resource.ProtoReflect.Descriptor instead.

func (*Resource) GetApiVersion 

func (x *Resource) GetApiVersion() string

func (*Resource) GetFieldSelectors 

func (x *Resource) GetFieldSelectors() []string

func (*Resource) GetKind 

func (x *Resource) GetKind() string

func (*Resource) GetLabelSelectors 

func (x *Resource) GetLabelSelectors() []string

func (*Resource) GetNamespace 

func (x *Resource) GetNamespace() *wrapperspb.StringValue

func (*Resource) GetReconciliationPeriodInMinutes 

func (x *Resource) GetReconciliationPeriodInMinutes() int32

func (*Resource) ProtoMessage 

func (*Resource) ProtoMessage()

func (*Resource) ProtoReflect 

func (x *Resource) ProtoReflect() protoreflect.Message

func (*Resource) Reset 

func (x *Resource) Reset()

func (*Resource) String 

func (x *Resource) String() string

type ServerMessage 

type ServerMessage struct {

	// Types that are assignable to Body:
	//
	//	*ServerMessage_TaskExecutionRequest
	//	*ServerMessage_UpdateConfigRequest
	//	*ServerMessage_EnableRequest
	//	*ServerMessage_DisableRequest
	//	*ServerMessage_NextEventRequest
	Body isServerMessage_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

func (*ServerMessage) Descriptor deprecated 

func (*ServerMessage) Descriptor() ([]byte, []int)

Deprecated: Use ServerMessage.ProtoReflect.Descriptor instead.

func (*ServerMessage) GetBody 

func (m *ServerMessage) GetBody() isServerMessage_Body

func (*ServerMessage) GetDisableRequest 

func (x *ServerMessage) GetDisableRequest() *DisableRequestMessage

func (*ServerMessage) GetEnableRequest 

func (x *ServerMessage) GetEnableRequest() *EnableRequestMessage

func (*ServerMessage) GetNextEventRequest 

func (x *ServerMessage) GetNextEventRequest() *NextEventRequestMessage

func (*ServerMessage) GetTaskExecutionRequest 

func (x *ServerMessage) GetTaskExecutionRequest() *TaskExecutionRequestMessage

func (*ServerMessage) GetUpdateConfigRequest 

func (x *ServerMessage) GetUpdateConfigRequest() *UpdateConfigRequestMessage

func (*ServerMessage) ProtoMessage 

func (*ServerMessage) ProtoMessage()

func (*ServerMessage) ProtoReflect 

func (x *ServerMessage) ProtoReflect() protoreflect.Message

func (*ServerMessage) Reset 

func (x *ServerMessage) Reset()

func (*ServerMessage) String 

func (x *ServerMessage) String() string

type ServerMessage_DisableRequest 

type ServerMessage_DisableRequest struct {
	DisableRequest *DisableRequestMessage `protobuf:"bytes,4,opt,name=disable_request,json=disableRequest,proto3,oneof"`
}

type ServerMessage_EnableRequest 

type ServerMessage_EnableRequest struct {
	EnableRequest *EnableRequestMessage `protobuf:"bytes,3,opt,name=enable_request,json=enableRequest,proto3,oneof"`
}

type ServerMessage_NextEventRequest 

type ServerMessage_NextEventRequest struct {
	NextEventRequest *NextEventRequestMessage `protobuf:"bytes,5,opt,name=next_event_request,json=nextEventRequest,proto3,oneof"`
}

type ServerMessage_TaskExecutionRequest 

type ServerMessage_TaskExecutionRequest struct {
	TaskExecutionRequest *TaskExecutionRequestMessage `protobuf:"bytes,1,opt,name=task_execution_request,json=taskExecutionRequest,proto3,oneof"`
}

type ServerMessage_UpdateConfigRequest 

type ServerMessage_UpdateConfigRequest struct {
	UpdateConfigRequest *UpdateConfigRequestMessage `protobuf:"bytes,2,opt,name=update_config_request,json=updateConfigRequest,proto3,oneof"`
}

type TaskExecutionRequestMessage 

type TaskExecutionRequestMessage struct {
	ExecutionId      string            `protobuf:"bytes,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	ExecutionVersion int64             `protobuf:"varint,2,opt,name=execution_version,json=executionVersion,proto3" json:"execution_version,omitempty"`
	Type             TaskType          `protobuf:"varint,3,opt,name=type,proto3,enum=sap.autopilot.remote.work.processor.v1.TaskType" json:"type,omitempty"`
	Input            map[string]string `` /* 151-byte string literal not displayed */
	Store            map[string]string `` /* 151-byte string literal not displayed */
	TaskVersion      int32             `protobuf:"varint,6,opt,name=task_version,json=taskVersion,proto3" json:"task_version,omitempty"`
	IsSensitive      bool              `protobuf:"varint,7,opt,name=is_sensitive,json=isSensitive,proto3" json:"is_sensitive,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskExecutionRequestMessage) Descriptor deprecated 

func (*TaskExecutionRequestMessage) Descriptor() ([]byte, []int)

Deprecated: Use TaskExecutionRequestMessage.ProtoReflect.Descriptor instead.

func (*TaskExecutionRequestMessage) GetExecutionId 

func (x *TaskExecutionRequestMessage) GetExecutionId() string

func (*TaskExecutionRequestMessage) GetExecutionVersion 

func (x *TaskExecutionRequestMessage) GetExecutionVersion() int64

func (*TaskExecutionRequestMessage) GetInput 

func (x *TaskExecutionRequestMessage) GetInput() map[string]string

func (*TaskExecutionRequestMessage) GetIsSensitive 

func (x *TaskExecutionRequestMessage) GetIsSensitive() bool

func (*TaskExecutionRequestMessage) GetStore 

func (x *TaskExecutionRequestMessage) GetStore() map[string]string

func (*TaskExecutionRequestMessage) GetTaskVersion 

func (x *TaskExecutionRequestMessage) GetTaskVersion() int32

func (*TaskExecutionRequestMessage) GetType 

func (x *TaskExecutionRequestMessage) GetType() TaskType

func (*TaskExecutionRequestMessage) ProtoMessage 

func (*TaskExecutionRequestMessage) ProtoMessage()

func (*TaskExecutionRequestMessage) ProtoReflect 

func (x *TaskExecutionRequestMessage) ProtoReflect() protoreflect.Message

func (*TaskExecutionRequestMessage) Reset 

func (x *TaskExecutionRequestMessage) Reset()

func (*TaskExecutionRequestMessage) String 

func (x *TaskExecutionRequestMessage) String() string

type TaskExecutionResponseMessage 

type TaskExecutionResponseMessage struct {
	ExecutionId      string                                 `protobuf:"bytes,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	ExecutionVersion int64                                  `protobuf:"varint,2,opt,name=execution_version,json=executionVersion,proto3" json:"execution_version,omitempty"`
	State            TaskExecutionResponseMessage_TaskState `` /* 147-byte string literal not displayed */
	Output           map[string]string                      `` /* 153-byte string literal not displayed */
	Store            map[string]string                      `` /* 151-byte string literal not displayed */
	Error            *wrapperspb.StringValue                `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
	Type             TaskType                               `protobuf:"varint,7,opt,name=type,proto3,enum=sap.autopilot.remote.work.processor.v1.TaskType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskExecutionResponseMessage) Descriptor deprecated 

func (*TaskExecutionResponseMessage) Descriptor() ([]byte, []int)

Deprecated: Use TaskExecutionResponseMessage.ProtoReflect.Descriptor instead.

func (*TaskExecutionResponseMessage) GetError 

func (x *TaskExecutionResponseMessage) GetError() *wrapperspb.StringValue

func (*TaskExecutionResponseMessage) GetExecutionId 

func (x *TaskExecutionResponseMessage) GetExecutionId() string

func (*TaskExecutionResponseMessage) GetExecutionVersion 

func (x *TaskExecutionResponseMessage) GetExecutionVersion() int64

func (*TaskExecutionResponseMessage) GetOutput 

func (x *TaskExecutionResponseMessage) GetOutput() map[string]string

func (*TaskExecutionResponseMessage) GetState 

func (x *TaskExecutionResponseMessage) GetState() TaskExecutionResponseMessage_TaskState

func (*TaskExecutionResponseMessage) GetStore 

func (x *TaskExecutionResponseMessage) GetStore() map[string]string

func (*TaskExecutionResponseMessage) GetType 

func (x *TaskExecutionResponseMessage) GetType() TaskType

func (*TaskExecutionResponseMessage) ProtoMessage 

func (*TaskExecutionResponseMessage) ProtoMessage()

func (*TaskExecutionResponseMessage) ProtoReflect 

func (x *TaskExecutionResponseMessage) ProtoReflect() protoreflect.Message

func (*TaskExecutionResponseMessage) Reset 

func (x *TaskExecutionResponseMessage) Reset()

func (*TaskExecutionResponseMessage) String 

func (x *TaskExecutionResponseMessage) String() string

type TaskExecutionResponseMessage_TaskState 

type TaskExecutionResponseMessage_TaskState int32
const (
	TaskExecutionResponseMessage_TASK_STATE_INVALID               TaskExecutionResponseMessage_TaskState = 0
	TaskExecutionResponseMessage_TASK_STATE_COMPLETED             TaskExecutionResponseMessage_TaskState = 1
	TaskExecutionResponseMessage_TASK_STATE_FAILED_RETRYABLE      TaskExecutionResponseMessage_TaskState = 2
	TaskExecutionResponseMessage_TASK_STATE_FAILED_NON_RETRYABLE  TaskExecutionResponseMessage_TaskState = 3
	TaskExecutionResponseMessage_TASK_STATE_FAILED_NON_CHARGEABLE TaskExecutionResponseMessage_TaskState = 4
)

func (TaskExecutionResponseMessage_TaskState) Descriptor 

func (TaskExecutionResponseMessage_TaskState) Descriptor() protoreflect.EnumDescriptor

func (TaskExecutionResponseMessage_TaskState) Enum 

func (x TaskExecutionResponseMessage_TaskState) Enum() *TaskExecutionResponseMessage_TaskState

func (TaskExecutionResponseMessage_TaskState) EnumDescriptor deprecated 

func (TaskExecutionResponseMessage_TaskState) EnumDescriptor() ([]byte, []int)

Deprecated: Use TaskExecutionResponseMessage_TaskState.Descriptor instead.

func (TaskExecutionResponseMessage_TaskState) Number 

func (x TaskExecutionResponseMessage_TaskState) Number() protoreflect.EnumNumber

func (TaskExecutionResponseMessage_TaskState) String 

func (x TaskExecutionResponseMessage_TaskState) String() string

func (TaskExecutionResponseMessage_TaskState) Type 

func (TaskExecutionResponseMessage_TaskState) Type() protoreflect.EnumType

type TaskType 

type TaskType int32
const (
	TaskType_TASK_TYPE_INVALID                TaskType = 0
	TaskType_TASK_TYPE_VOID                   TaskType = 1
	TaskType_TASK_TYPE_HTTP                   TaskType = 2
	TaskType_TASK_TYPE_SCRIPT                 TaskType = 3
	TaskType_TASK_TYPE_KUBERNETES_API_REQUEST TaskType = 4
)

func (TaskType) Descriptor 

func (TaskType) Descriptor() protoreflect.EnumDescriptor

func (TaskType) Enum 

func (x TaskType) Enum() *TaskType

func (TaskType) EnumDescriptor deprecated 

func (TaskType) EnumDescriptor() ([]byte, []int)

Deprecated: Use TaskType.Descriptor instead.

func (TaskType) Number 

func (x TaskType) Number() protoreflect.EnumNumber

func (TaskType) String 

func (x TaskType) String() string

func (TaskType) Type 

func (TaskType) Type() protoreflect.EnumType

type UnimplementedRemoteWorkProcessorServiceServer 

type UnimplementedRemoteWorkProcessorServiceServer struct {
}

UnimplementedRemoteWorkProcessorServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedRemoteWorkProcessorServiceServer) Session 

func (UnimplementedRemoteWorkProcessorServiceServer) Session(RemoteWorkProcessorService_SessionServer) error

type UnsafeRemoteWorkProcessorServiceServer 

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

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

type UpdateConfigRequestMessage 

type UpdateConfigRequestMessage struct {

	// reconciler name -> resource to watch
	Resources     map[string]*Resource `` /* 159-byte string literal not displayed */
	ConfigVersion string               `protobuf:"bytes,2,opt,name=config_version,json=configVersion,proto3" json:"config_version,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConfigRequestMessage) Descriptor deprecated 

func (*UpdateConfigRequestMessage) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConfigRequestMessage.ProtoReflect.Descriptor instead.

func (*UpdateConfigRequestMessage) GetConfigVersion 

func (x *UpdateConfigRequestMessage) GetConfigVersion() string

func (*UpdateConfigRequestMessage) GetResources 

func (x *UpdateConfigRequestMessage) GetResources() map[string]*Resource

func (*UpdateConfigRequestMessage) ProtoMessage 

func (*UpdateConfigRequestMessage) ProtoMessage()

func (*UpdateConfigRequestMessage) ProtoReflect 

func (x *UpdateConfigRequestMessage) ProtoReflect() protoreflect.Message

func (*UpdateConfigRequestMessage) Reset 

func (x *UpdateConfigRequestMessage) Reset()

func (*UpdateConfigRequestMessage) String 

func (x *UpdateConfigRequestMessage) String() string

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.