sparkv1

package
v1.15.0 Latest Latest
Warning

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

 Go to latest Published: Dec 14, 2022 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrorType_name = map[int32]string{
		0: "ERROR_TYPE_FAILED_UNSPECIFIED",
		1: "ERROR_TYPE_CANCELLED",
		2: "ERROR_TYPE_SKIP",
		3: "ERROR_TYPE_RETRY",
		4: "ERROR_TYPE_FATAL",
	}
	ErrorType_value = map[string]int32{
		"ERROR_TYPE_FAILED_UNSPECIFIED": 0,
		"ERROR_TYPE_CANCELLED":          1,
		"ERROR_TYPE_SKIP":               2,
		"ERROR_TYPE_RETRY":              3,
		"ERROR_TYPE_FATAL":              4,
	}
)

Enum value maps for ErrorType.

View Source 
var (
	StageType_name = map[int32]string{
		0: "STANDARD",
		1: "COMPENSATE",
		2: "CANCEL",
		3: "COMPLETE",
	}
	StageType_value = map[string]int32{
		"STANDARD":   0,
		"COMPENSATE": 1,
		"CANCEL":     2,
		"COMPLETE":   3,
	}
)

Enum value maps for StageType.

View Source 
var (
	StageStatus_name = map[int32]string{
		0: "STAGE_PENDING",
		1: "STAGE_STARTED",
		2: "STAGE_COMPLETED",
		3: "STAGE_FAILED",
		4: "STAGE_SKIPPED",
		5: "STAGE_CANCELED",
	}
	StageStatus_value = map[string]int32{
		"STAGE_PENDING":   0,
		"STAGE_STARTED":   1,
		"STAGE_COMPLETED": 2,
		"STAGE_FAILED":    3,
		"STAGE_SKIPPED":   4,
		"STAGE_CANCELED":  5,
	}
)

Enum value maps for StageStatus.

View Source 
var (
	JobStatus_name = map[int32]string{
		0:  "STARTED",
		1:  "DONE",
		2:  "FAILED",
		3:  "COMPENSATION_STARTED",
		4:  "COMPENSATION_DONE",
		5:  "COMPENSATION_FAILED",
		6:  "COMPLETION_STARTED",
		7:  "COMPLETION_DONE",
		8:  "COMPLETION_FAILED",
		9:  "CANCELLATION_STARTED",
		10: "CANCELLATION_DONE",
		11: "CANCELLATION_FAILED",
	}
	JobStatus_value = map[string]int32{
		"STARTED":              0,
		"DONE":                 1,
		"FAILED":               2,
		"COMPENSATION_STARTED": 3,
		"COMPENSATION_DONE":    4,
		"COMPENSATION_FAILED":  5,
		"COMPLETION_STARTED":   6,
		"COMPLETION_DONE":      7,
		"COMPLETION_FAILED":    8,
		"CANCELLATION_STARTED": 9,
		"CANCELLATION_DONE":    10,
		"CANCELLATION_FAILED":  11,
	}
)

Enum value maps for JobStatus.

View Source 
var AgentService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "sdk.spark.v1.AgentService",
	HandlerType: (*AgentServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ExecuteJob",
			Handler:    _AgentService_ExecuteJob_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "azarc/sdk/spark/v1/spark.proto",
}

AgentService_ServiceDesc is the grpc.ServiceDesc for AgentService 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 File_azarc_sdk_spark_v1_spark_proto protoreflect.FileDescriptor
View Source 
var ManagerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "sdk.spark.v1.ManagerService",
	HandlerType: (*ManagerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetStageStatus",
			Handler:    _ManagerService_GetStageStatus_Handler,
		},
		{
			MethodName: "SetStageStatus",
			Handler:    _ManagerService_SetStageStatus_Handler,
		},
		{
			MethodName: "GetStageResult",
			Handler:    _ManagerService_GetStageResult_Handler,
		},
		{
			MethodName: "SetStageResult",
			Handler:    _ManagerService_SetStageResult_Handler,
		},
		{
			MethodName: "GetInputs",
			Handler:    _ManagerService_GetInputs_Handler,
		},
		{
			MethodName: "SetOutputs",
			Handler:    _ManagerService_SetOutputs_Handler,
		},
		{
			MethodName: "SyncOutputs",
			Handler:    _ManagerService_SyncOutputs_Handler,
		},
		{
			MethodName: "JobStarting",
			Handler:    _ManagerService_JobStarting_Handler,
		},
		{
			MethodName: "FinishJob",
			Handler:    _ManagerService_FinishJob_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "azarc/sdk/spark/v1/spark.proto",
}

ManagerService_ServiceDesc is the grpc.ServiceDesc for ManagerService 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 SerdesMap = map[string]serdes{
	common.MimeTypeJSON: {
		Unmarshal: func(value []byte, a any) error {
			return json2.Unmarshal(value, a)
		},
		Marshal: func(a any) ([]byte, error) {
			b, err := json2.Marshal(a)
			if err != nil {
				return nil, err
			}
			return b, nil
		},
	},
	common.NoMimeType: {
		Unmarshal: func(value []byte, a any) error {
			return json2.Unmarshal(value, a)
		},
		Marshal: func(a any) ([]byte, error) {
			b, err := json2.Marshal(a)
			if err != nil {
				return nil, err
			}
			return b, nil
		},
	},
}

Functions

func ConvertBytes added in v1.13.0 

func ConvertBytes(data []byte, mimeType string) (out []byte, err error)

func MarshalBinary added in v1.13.0 

func MarshalBinary(data interface{}) ([]byte, error)

func RegisterAgentServiceServer 

func RegisterAgentServiceServer(s grpc.ServiceRegistrar, srv AgentServiceServer)

func RegisterManagerServiceServer 

func RegisterManagerServiceServer(s grpc.ServiceRegistrar, srv ManagerServiceServer)

func UnmarshalBinaryTo added in v1.13.0 

func UnmarshalBinaryTo(data []byte, out interface{}, mimeType string) error

Types

type AgentServiceClient 

type AgentServiceClient interface {
	ExecuteJob(ctx context.Context, in *ExecuteJobRequest, opts ...grpc.CallOption) (*Void, error)
}

AgentServiceClient is the client API for AgentService 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 NewAgentServiceClient 

func NewAgentServiceClient(cc grpc.ClientConnInterface) AgentServiceClient

type AgentServiceServer 

type AgentServiceServer interface {
	ExecuteJob(context.Context, *ExecuteJobRequest) (*Void, error)
}

AgentServiceServer is the server API for AgentService service. All implementations should embed UnimplementedAgentServiceServer for forward compatibility

type Error 

type Error struct {
	Error     string          `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode uint32          `protobuf:"varint,2,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	ErrorType ErrorType       `protobuf:"varint,3,opt,name=error_type,json=errorType,proto3,enum=sdk.spark.v1.ErrorType" json:"error_type,omitempty"`
	Metadata  *structpb.Value `protobuf:"bytes,4,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"`
	Retry     *RetryStrategy  `protobuf:"bytes,5,opt,name=retry,proto3,oneof" json:"retry,omitempty"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor deprecated 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetError 

func (x *Error) GetError() string

func (*Error) GetErrorCode 

func (x *Error) GetErrorCode() uint32

func (*Error) GetErrorType 

func (x *Error) GetErrorType() ErrorType

func (*Error) GetMetadata 

func (x *Error) GetMetadata() *structpb.Value

func (*Error) GetRetry 

func (x *Error) GetRetry() *RetryStrategy

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

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

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

type ErrorType 

type ErrorType int32
const (
	ErrorType_ERROR_TYPE_FAILED_UNSPECIFIED ErrorType = 0
	ErrorType_ERROR_TYPE_CANCELLED          ErrorType = 1
	ErrorType_ERROR_TYPE_SKIP               ErrorType = 2
	ErrorType_ERROR_TYPE_RETRY              ErrorType = 3
	ErrorType_ERROR_TYPE_FATAL              ErrorType = 4
)

func (ErrorType) Descriptor 

func (ErrorType) Descriptor() protoreflect.EnumDescriptor

func (ErrorType) Enum 

func (x ErrorType) Enum() *ErrorType

func (ErrorType) EnumDescriptor deprecated 

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

Deprecated: Use ErrorType.Descriptor instead.

func (ErrorType) Number 

func (x ErrorType) Number() protoreflect.EnumNumber

func (ErrorType) String 

func (x ErrorType) String() string

func (ErrorType) Type 

func (ErrorType) Type() protoreflect.EnumType

type ExecuteJobRequest 

type ExecuteJobRequest struct {
	Key             string           `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	TransactionId   string           `protobuf:"bytes,2,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	CorrelationId   string           `protobuf:"bytes,3,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	LastActiveStage *LastActiveStage `protobuf:"bytes,4,opt,name=last_active_stage,json=lastActiveStage,proto3,oneof" json:"last_active_stage,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteJobRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteJobRequest.ProtoReflect.Descriptor instead.

func (*ExecuteJobRequest) GetCorrelationId 

func (x *ExecuteJobRequest) GetCorrelationId() string

func (*ExecuteJobRequest) GetKey 

func (x *ExecuteJobRequest) GetKey() string

func (*ExecuteJobRequest) GetLastActiveStage 

func (x *ExecuteJobRequest) GetLastActiveStage() *LastActiveStage

func (*ExecuteJobRequest) GetTransactionId 

func (x *ExecuteJobRequest) GetTransactionId() string

func (*ExecuteJobRequest) ProtoMessage 

func (*ExecuteJobRequest) ProtoMessage()

func (*ExecuteJobRequest) ProtoReflect 

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

func (*ExecuteJobRequest) Reset 

func (x *ExecuteJobRequest) Reset()

func (*ExecuteJobRequest) String 

func (x *ExecuteJobRequest) String() string

type FinishJobRequest added in v1.13.0 

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

func (*FinishJobRequest) Descriptor deprecated added in v1.13.0 

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

Deprecated: Use FinishJobRequest.ProtoReflect.Descriptor instead.

func (*FinishJobRequest) GetKey added in v1.13.0 

func (x *FinishJobRequest) GetKey() string

func (*FinishJobRequest) ProtoMessage added in v1.13.0 

func (*FinishJobRequest) ProtoMessage()

func (*FinishJobRequest) ProtoReflect added in v1.13.0 

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

func (*FinishJobRequest) Reset added in v1.13.0 

func (x *FinishJobRequest) Reset()

func (*FinishJobRequest) String added in v1.13.0 

func (x *FinishJobRequest) String() string

type GetInputsRequest added in v1.13.0 

type GetInputsRequest struct {
	Key   string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Names []string `protobuf:"bytes,2,rep,name=names,proto3" json:"names,omitempty"`
	// contains filtered or unexported fields
}

func (*GetInputsRequest) Descriptor deprecated added in v1.13.0 

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

Deprecated: Use GetInputsRequest.ProtoReflect.Descriptor instead.

func (*GetInputsRequest) GetKey added in v1.13.0 

func (x *GetInputsRequest) GetKey() string

func (*GetInputsRequest) GetNames added in v1.13.0 

func (x *GetInputsRequest) GetNames() []string

func (*GetInputsRequest) ProtoMessage added in v1.13.0 

func (*GetInputsRequest) ProtoMessage()

func (*GetInputsRequest) ProtoReflect added in v1.13.0 

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

func (*GetInputsRequest) Reset added in v1.13.0 

func (x *GetInputsRequest) Reset()

func (*GetInputsRequest) String added in v1.13.0 

func (x *GetInputsRequest) String() string

type GetInputsResponse added in v1.13.0 

type GetInputsResponse struct {
	Variables map[string]*Variable `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetInputsResponse) Descriptor deprecated added in v1.13.0 

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

Deprecated: Use GetInputsResponse.ProtoReflect.Descriptor instead.

func (*GetInputsResponse) GetVariables added in v1.13.0 

func (x *GetInputsResponse) GetVariables() map[string]*Variable

func (*GetInputsResponse) ProtoMessage added in v1.13.0 

func (*GetInputsResponse) ProtoMessage()

func (*GetInputsResponse) ProtoReflect added in v1.13.0 

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

func (*GetInputsResponse) Reset added in v1.13.0 

func (x *GetInputsResponse) Reset()

func (*GetInputsResponse) String added in v1.13.0 

func (x *GetInputsResponse) String() string

type GetStageResultRequest 

type GetStageResultRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Key  string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStageResultRequest) Descriptor deprecated 

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

Deprecated: Use GetStageResultRequest.ProtoReflect.Descriptor instead.

func (*GetStageResultRequest) GetKey added in v1.13.0 

func (x *GetStageResultRequest) GetKey() string

func (*GetStageResultRequest) GetName 

func (x *GetStageResultRequest) GetName() string

func (*GetStageResultRequest) ProtoMessage 

func (*GetStageResultRequest) ProtoMessage()

func (*GetStageResultRequest) ProtoReflect 

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

func (*GetStageResultRequest) Reset 

func (x *GetStageResultRequest) Reset()

func (*GetStageResultRequest) String 

func (x *GetStageResultRequest) String() string

type GetStageResultResponse 

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

func (*GetStageResultResponse) Bind added in v1.13.0 

func (x *GetStageResultResponse) Bind(a any) error

func (*GetStageResultResponse) Descriptor deprecated 

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

Deprecated: Use GetStageResultResponse.ProtoReflect.Descriptor instead.

func (*GetStageResultResponse) GetData added in v1.13.0 

func (x *GetStageResultResponse) GetData() []byte

func (*GetStageResultResponse) ProtoMessage 

func (*GetStageResultResponse) ProtoMessage()

func (*GetStageResultResponse) ProtoReflect 

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

func (*GetStageResultResponse) Raw added in v1.13.0 

func (x *GetStageResultResponse) Raw() ([]byte, error)

func (*GetStageResultResponse) Reset 

func (x *GetStageResultResponse) Reset()

func (*GetStageResultResponse) String 

func (x *GetStageResultResponse) String() string

type GetStageStatusRequest 

type GetStageStatusRequest struct {
	Key  string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStageStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetStageStatusRequest.ProtoReflect.Descriptor instead.

func (*GetStageStatusRequest) GetKey added in v1.13.0 

func (x *GetStageStatusRequest) GetKey() string

func (*GetStageStatusRequest) GetName 

func (x *GetStageStatusRequest) GetName() string

func (*GetStageStatusRequest) ProtoMessage 

func (*GetStageStatusRequest) ProtoMessage()

func (*GetStageStatusRequest) ProtoReflect 

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

func (*GetStageStatusRequest) Reset 

func (x *GetStageStatusRequest) Reset()

func (*GetStageStatusRequest) String 

func (x *GetStageStatusRequest) String() string

type GetStageStatusResponse 

type GetStageStatusResponse struct {
	Status StageStatus `protobuf:"varint,1,opt,name=status,proto3,enum=sdk.spark.v1.StageStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStageStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetStageStatusResponse.ProtoReflect.Descriptor instead.

func (*GetStageStatusResponse) GetStatus 

func (x *GetStageStatusResponse) GetStatus() StageStatus

func (*GetStageStatusResponse) ProtoMessage 

func (*GetStageStatusResponse) ProtoMessage()

func (*GetStageStatusResponse) ProtoReflect 

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

func (*GetStageStatusResponse) Reset 

func (x *GetStageStatusResponse) Reset()

func (*GetStageStatusResponse) String 

func (x *GetStageStatusResponse) String() string

type JobStartingRequest added in v1.13.0 

type JobStartingRequest struct {
	Key       string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	ServiceId string `protobuf:"bytes,2,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// contains filtered or unexported fields
}

func (*JobStartingRequest) Descriptor deprecated added in v1.13.0 

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

Deprecated: Use JobStartingRequest.ProtoReflect.Descriptor instead.

func (*JobStartingRequest) GetKey added in v1.13.0 

func (x *JobStartingRequest) GetKey() string

func (*JobStartingRequest) GetServiceId added in v1.13.0 

func (x *JobStartingRequest) GetServiceId() string

func (*JobStartingRequest) ProtoMessage added in v1.13.0 

func (*JobStartingRequest) ProtoMessage()

func (*JobStartingRequest) ProtoReflect added in v1.13.0 

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

func (*JobStartingRequest) Reset added in v1.13.0 

func (x *JobStartingRequest) Reset()

func (*JobStartingRequest) String added in v1.13.0 

func (x *JobStartingRequest) String() string

type JobStatus 

type JobStatus int32

TODO this should be moved 

const (
	JobStatus_STARTED              JobStatus = 0
	JobStatus_DONE                 JobStatus = 1
	JobStatus_FAILED               JobStatus = 2
	JobStatus_COMPENSATION_STARTED JobStatus = 3
	JobStatus_COMPENSATION_DONE    JobStatus = 4
	JobStatus_COMPENSATION_FAILED  JobStatus = 5
	JobStatus_COMPLETION_STARTED   JobStatus = 6
	JobStatus_COMPLETION_DONE      JobStatus = 7
	JobStatus_COMPLETION_FAILED    JobStatus = 8
	JobStatus_CANCELLATION_STARTED JobStatus = 9
	JobStatus_CANCELLATION_DONE    JobStatus = 10
	JobStatus_CANCELLATION_FAILED  JobStatus = 11
)

func (JobStatus) Descriptor 

func (JobStatus) Descriptor() protoreflect.EnumDescriptor

func (JobStatus) Enum 

func (x JobStatus) Enum() *JobStatus

func (JobStatus) EnumDescriptor deprecated 

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

Deprecated: Use JobStatus.Descriptor instead.

func (JobStatus) Number 

func (x JobStatus) Number() protoreflect.EnumNumber

func (JobStatus) String 

func (x JobStatus) String() string

func (JobStatus) Type 

func (JobStatus) Type() protoreflect.EnumType

type LastActiveStage 

type LastActiveStage struct {
	Name   string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Status StageStatus `protobuf:"varint,2,opt,name=status,proto3,enum=sdk.spark.v1.StageStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*LastActiveStage) Descriptor deprecated 

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

Deprecated: Use LastActiveStage.ProtoReflect.Descriptor instead.

func (*LastActiveStage) GetName 

func (x *LastActiveStage) GetName() string

func (*LastActiveStage) GetStatus 

func (x *LastActiveStage) GetStatus() StageStatus

func (*LastActiveStage) ProtoMessage 

func (*LastActiveStage) ProtoMessage()

func (*LastActiveStage) ProtoReflect 

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

func (*LastActiveStage) Reset 

func (x *LastActiveStage) Reset()

func (*LastActiveStage) String 

func (x *LastActiveStage) String() string

type ManagerServiceClient 

type ManagerServiceClient interface {
	GetStageStatus(ctx context.Context, in *GetStageStatusRequest, opts ...grpc.CallOption) (*GetStageStatusResponse, error)
	SetStageStatus(ctx context.Context, in *SetStageStatusRequest, opts ...grpc.CallOption) (*Void, error)
	GetStageResult(ctx context.Context, in *GetStageResultRequest, opts ...grpc.CallOption) (*GetStageResultResponse, error)
	SetStageResult(ctx context.Context, in *SetStageResultRequest, opts ...grpc.CallOption) (*Void, error)
	GetInputs(ctx context.Context, in *GetInputsRequest, opts ...grpc.CallOption) (*GetInputsResponse, error)
	SetOutputs(ctx context.Context, in *SetOutputsRequest, opts ...grpc.CallOption) (*Void, error)
	SyncOutputs(ctx context.Context, in *SyncOutputsRequest, opts ...grpc.CallOption) (*Void, error)
	JobStarting(ctx context.Context, in *JobStartingRequest, opts ...grpc.CallOption) (*Void, error)
	FinishJob(ctx context.Context, in *FinishJobRequest, opts ...grpc.CallOption) (*Void, error)
}

ManagerServiceClient is the client API for ManagerService 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 NewManagerServiceClient 

func NewManagerServiceClient(cc grpc.ClientConnInterface) ManagerServiceClient

type ManagerServiceServer 

type ManagerServiceServer interface {
	GetStageStatus(context.Context, *GetStageStatusRequest) (*GetStageStatusResponse, error)
	SetStageStatus(context.Context, *SetStageStatusRequest) (*Void, error)
	GetStageResult(context.Context, *GetStageResultRequest) (*GetStageResultResponse, error)
	SetStageResult(context.Context, *SetStageResultRequest) (*Void, error)
	GetInputs(context.Context, *GetInputsRequest) (*GetInputsResponse, error)
	SetOutputs(context.Context, *SetOutputsRequest) (*Void, error)
	SyncOutputs(context.Context, *SyncOutputsRequest) (*Void, error)
	JobStarting(context.Context, *JobStartingRequest) (*Void, error)
	FinishJob(context.Context, *FinishJobRequest) (*Void, error)
}

ManagerServiceServer is the server API for ManagerService service. All implementations should embed UnimplementedManagerServiceServer for forward compatibility

type RetryStrategy 

type RetryStrategy struct {
	Backoff uint32 `protobuf:"varint,1,opt,name=backoff,proto3" json:"backoff,omitempty"`
	Count   uint32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*RetryStrategy) Descriptor deprecated 

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

Deprecated: Use RetryStrategy.ProtoReflect.Descriptor instead.

func (*RetryStrategy) GetBackoff 

func (x *RetryStrategy) GetBackoff() uint32

func (*RetryStrategy) GetCount 

func (x *RetryStrategy) GetCount() uint32

func (*RetryStrategy) ProtoMessage 

func (*RetryStrategy) ProtoMessage()

func (*RetryStrategy) ProtoReflect 

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

func (*RetryStrategy) Reset 

func (x *RetryStrategy) Reset()

func (*RetryStrategy) String 

func (x *RetryStrategy) String() string

type SetOutputsRequest added in v1.13.0 

type SetOutputsRequest struct {
	Key       string               `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Variables map[string]*Variable `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SetOutputsRequest) Descriptor deprecated added in v1.13.0 

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

Deprecated: Use SetOutputsRequest.ProtoReflect.Descriptor instead.

func (*SetOutputsRequest) GetKey added in v1.13.0 

func (x *SetOutputsRequest) GetKey() string

func (*SetOutputsRequest) GetVariables added in v1.13.0 

func (x *SetOutputsRequest) GetVariables() map[string]*Variable

func (*SetOutputsRequest) ProtoMessage added in v1.13.0 

func (*SetOutputsRequest) ProtoMessage()

func (*SetOutputsRequest) ProtoReflect added in v1.13.0 

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

func (*SetOutputsRequest) Reset added in v1.13.0 

func (x *SetOutputsRequest) Reset()

func (*SetOutputsRequest) String added in v1.13.0 

func (x *SetOutputsRequest) String() string

type SetStageResultRequest 

type SetStageResultRequest struct {
	Key  string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SetStageResultRequest) Descriptor deprecated 

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

Deprecated: Use SetStageResultRequest.ProtoReflect.Descriptor instead.

func (*SetStageResultRequest) GetData added in v1.13.0 

func (x *SetStageResultRequest) GetData() []byte

func (*SetStageResultRequest) GetKey added in v1.13.0 

func (x *SetStageResultRequest) GetKey() string

func (*SetStageResultRequest) GetName 

func (x *SetStageResultRequest) GetName() string

func (*SetStageResultRequest) ProtoMessage 

func (*SetStageResultRequest) ProtoMessage()

func (*SetStageResultRequest) ProtoReflect 

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

func (*SetStageResultRequest) Reset 

func (x *SetStageResultRequest) Reset()

func (*SetStageResultRequest) String 

func (x *SetStageResultRequest) String() string

type SetStageStatusRequest 

type SetStageStatusRequest struct {
	Name   string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Key    string      `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Depth  uint32      `protobuf:"varint,3,opt,name=depth,proto3" json:"depth,omitempty"`
	Type   StageType   `protobuf:"varint,4,opt,name=type,proto3,enum=sdk.spark.v1.StageType" json:"type,omitempty"`
	Status StageStatus `protobuf:"varint,5,opt,name=status,proto3,enum=sdk.spark.v1.StageStatus" json:"status,omitempty"`
	Err    *Error      `protobuf:"bytes,6,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*SetStageStatusRequest) Descriptor deprecated 

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

Deprecated: Use SetStageStatusRequest.ProtoReflect.Descriptor instead.

func (*SetStageStatusRequest) GetDepth added in v1.13.0 

func (x *SetStageStatusRequest) GetDepth() uint32

func (*SetStageStatusRequest) GetErr 

func (x *SetStageStatusRequest) GetErr() *Error

func (*SetStageStatusRequest) GetKey added in v1.13.0 

func (x *SetStageStatusRequest) GetKey() string

func (*SetStageStatusRequest) GetName 

func (x *SetStageStatusRequest) GetName() string

func (*SetStageStatusRequest) GetStatus 

func (x *SetStageStatusRequest) GetStatus() StageStatus

func (*SetStageStatusRequest) GetType added in v1.13.0 

func (x *SetStageStatusRequest) GetType() StageType

func (*SetStageStatusRequest) ProtoMessage 

func (*SetStageStatusRequest) ProtoMessage()

func (*SetStageStatusRequest) ProtoReflect 

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

func (*SetStageStatusRequest) Reset 

func (x *SetStageStatusRequest) Reset()

func (*SetStageStatusRequest) String 

func (x *SetStageStatusRequest) String() string

type StageStatus 

type StageStatus int32
const (
	StageStatus_STAGE_PENDING   StageStatus = 0
	StageStatus_STAGE_STARTED   StageStatus = 1
	StageStatus_STAGE_COMPLETED StageStatus = 2
	StageStatus_STAGE_FAILED    StageStatus = 3
	StageStatus_STAGE_SKIPPED   StageStatus = 4
	StageStatus_STAGE_CANCELED  StageStatus = 5
)

func (StageStatus) Descriptor 

func (StageStatus) Descriptor() protoreflect.EnumDescriptor

func (StageStatus) Enum 

func (x StageStatus) Enum() *StageStatus

func (StageStatus) EnumDescriptor deprecated 

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

Deprecated: Use StageStatus.Descriptor instead.

func (StageStatus) Number 

func (x StageStatus) Number() protoreflect.EnumNumber

func (StageStatus) String 

func (x StageStatus) String() string

func (StageStatus) Type 

func (StageStatus) Type() protoreflect.EnumType

type StageType added in v1.13.0 

type StageType int32
const (
	StageType_STANDARD   StageType = 0
	StageType_COMPENSATE StageType = 1
	StageType_CANCEL     StageType = 2
	StageType_COMPLETE   StageType = 3
)

func (StageType) Descriptor added in v1.13.0 

func (StageType) Descriptor() protoreflect.EnumDescriptor

func (StageType) Enum added in v1.13.0 

func (x StageType) Enum() *StageType

func (StageType) EnumDescriptor deprecated added in v1.13.0 

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

Deprecated: Use StageType.Descriptor instead.

func (StageType) Number added in v1.13.0 

func (x StageType) Number() protoreflect.EnumNumber

func (StageType) String added in v1.13.0 

func (x StageType) String() string

func (StageType) Type added in v1.13.0 

func (StageType) Type() protoreflect.EnumType

type SyncOutputsRequest added in v1.13.0 

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

func (*SyncOutputsRequest) Descriptor deprecated added in v1.13.0 

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

Deprecated: Use SyncOutputsRequest.ProtoReflect.Descriptor instead.

func (*SyncOutputsRequest) GetKey added in v1.13.0 

func (x *SyncOutputsRequest) GetKey() string

func (*SyncOutputsRequest) ProtoMessage added in v1.13.0 

func (*SyncOutputsRequest) ProtoMessage()

func (*SyncOutputsRequest) ProtoReflect added in v1.13.0 

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

func (*SyncOutputsRequest) Reset added in v1.13.0 

func (x *SyncOutputsRequest) Reset()

func (*SyncOutputsRequest) String added in v1.13.0 

func (x *SyncOutputsRequest) String() string

type UnimplementedAgentServiceServer 

type UnimplementedAgentServiceServer struct {
}

UnimplementedAgentServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedAgentServiceServer) ExecuteJob 

func (UnimplementedAgentServiceServer) ExecuteJob(context.Context, *ExecuteJobRequest) (*Void, error)

type UnimplementedManagerServiceServer 

type UnimplementedManagerServiceServer struct {
}

UnimplementedManagerServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedManagerServiceServer) FinishJob added in v1.13.0 

func (UnimplementedManagerServiceServer) FinishJob(context.Context, *FinishJobRequest) (*Void, error)

func (UnimplementedManagerServiceServer) GetInputs added in v1.13.0 

func (UnimplementedManagerServiceServer) GetInputs(context.Context, *GetInputsRequest) (*GetInputsResponse, error)

func (UnimplementedManagerServiceServer) GetStageResult 

func (UnimplementedManagerServiceServer) GetStageResult(context.Context, *GetStageResultRequest) (*GetStageResultResponse, error)

func (UnimplementedManagerServiceServer) GetStageStatus 

func (UnimplementedManagerServiceServer) GetStageStatus(context.Context, *GetStageStatusRequest) (*GetStageStatusResponse, error)

func (UnimplementedManagerServiceServer) JobStarting added in v1.13.0 

func (UnimplementedManagerServiceServer) JobStarting(context.Context, *JobStartingRequest) (*Void, error)

func (UnimplementedManagerServiceServer) SetOutputs added in v1.13.0 

func (UnimplementedManagerServiceServer) SetOutputs(context.Context, *SetOutputsRequest) (*Void, error)

func (UnimplementedManagerServiceServer) SetStageResult 

func (UnimplementedManagerServiceServer) SetStageResult(context.Context, *SetStageResultRequest) (*Void, error)

func (UnimplementedManagerServiceServer) SetStageStatus 

func (UnimplementedManagerServiceServer) SetStageStatus(context.Context, *SetStageStatusRequest) (*Void, error)

func (UnimplementedManagerServiceServer) SyncOutputs added in v1.13.0 

func (UnimplementedManagerServiceServer) SyncOutputs(context.Context, *SyncOutputsRequest) (*Void, error)

type UnsafeAgentServiceServer 

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

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

type UnsafeManagerServiceServer 

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

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

type Variable 

type Variable struct {
	Data     []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	MimeType string `protobuf:"bytes,2,opt,name=mime_type,json=mimeType,proto3" json:"mime_type,omitempty"`
	// contains filtered or unexported fields
}

func (*Variable) Bind 

func (x *Variable) Bind(a any) error

func (*Variable) Descriptor deprecated 

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

Deprecated: Use Variable.ProtoReflect.Descriptor instead.

func (*Variable) GetData added in v1.13.0 

func (x *Variable) GetData() []byte

func (*Variable) GetMimeType 

func (x *Variable) GetMimeType() string

func (*Variable) ProtoMessage 

func (*Variable) ProtoMessage()

func (*Variable) ProtoReflect 

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

func (*Variable) Raw 

func (x *Variable) Raw() ([]byte, error)

func (*Variable) Reset 

func (x *Variable) Reset()

func (*Variable) String 

func (x *Variable) String() string

type Void added in v1.13.0 

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

func (*Void) Descriptor deprecated added in v1.13.0 

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

Deprecated: Use Void.ProtoReflect.Descriptor instead.

func (*Void) ProtoMessage added in v1.13.0 

func (*Void) ProtoMessage()

func (*Void) ProtoReflect added in v1.13.0 

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

func (*Void) Reset added in v1.13.0 

func (x *Void) Reset()

func (*Void) String added in v1.13.0 

func (x *Void) 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.