protov1

package
v1.0.0-beta2 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	DagBundle_GetMetadata_FullMethodName = "/bundle.v1.DagBundle/GetMetadata"
	DagBundle_Execute_FullMethodName     = "/bundle.v1.DagBundle/Execute"
)
View Source 
const Execute_Request_Task_case case_Execute_Request_Workload = 1
View Source 
const Execute_Request_Workload_not_set_case case_Execute_Request_Workload = 0

Variables

View Source 
var DagBundle_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "bundle.v1.DagBundle",
	HandlerType: (*DagBundleServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetMetadata",
			Handler:    _DagBundle_GetMetadata_Handler,
		},
		{
			MethodName: "Execute",
			Handler:    _DagBundle_Execute_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/protov1/plugin.proto",
}

DagBundle_ServiceDesc is the grpc.ServiceDesc for DagBundle 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_internal_protov1_plugin_proto protoreflect.FileDescriptor

Functions

func RegisterDagBundleServer 

func RegisterDagBundleServer(s grpc.ServiceRegistrar, srv DagBundleServer)

Types

type BundleInfo 

type BundleInfo struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*BundleInfo) ClearName 

func (x *BundleInfo) ClearName()

func (*BundleInfo) ClearVersion 

func (x *BundleInfo) ClearVersion()

func (*BundleInfo) GetName 

func (x *BundleInfo) GetName() string

func (*BundleInfo) GetVersion 

func (x *BundleInfo) GetVersion() string

func (*BundleInfo) HasName 

func (x *BundleInfo) HasName() bool

func (*BundleInfo) HasVersion 

func (x *BundleInfo) HasVersion() bool

func (*BundleInfo) ProtoMessage 

func (*BundleInfo) ProtoMessage()

func (*BundleInfo) ProtoReflect 

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

func (*BundleInfo) Reset 

func (x *BundleInfo) Reset()

func (*BundleInfo) SetName 

func (x *BundleInfo) SetName(v string)

func (*BundleInfo) SetVersion 

func (x *BundleInfo) SetVersion(v string)

func (*BundleInfo) String 

func (x *BundleInfo) String() string

type BundleInfo_builder 

type BundleInfo_builder struct {
	Name    *string
	Version *string
	// contains filtered or unexported fields
}

func (BundleInfo_builder) Build 

func (b0 BundleInfo_builder) Build() *BundleInfo

type DagBundleClient 

type DagBundleClient interface {
	// GetMetadata returns upfront information about server capabilities and
	// supported resource types without requiring the server to instantiate all
	// bundle and task information, which could be memory intensive.
	GetMetadata(ctx context.Context, in *GetMetadata_Request, opts ...grpc.CallOption) (*GetMetadata_Response, error)
	Execute(ctx context.Context, in *Execute_Request, opts ...grpc.CallOption) (*Execute_Response, error)
}

DagBundleClient is the client API for DagBundle 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 NewDagBundleClient 

func NewDagBundleClient(cc grpc.ClientConnInterface) DagBundleClient

type DagBundleServer 

type DagBundleServer interface {
	// GetMetadata returns upfront information about server capabilities and
	// supported resource types without requiring the server to instantiate all
	// bundle and task information, which could be memory intensive.
	GetMetadata(context.Context, *GetMetadata_Request) (*GetMetadata_Response, error)
	Execute(context.Context, *Execute_Request) (*Execute_Response, error)
	// contains filtered or unexported methods
}

DagBundleServer is the server API for DagBundle service. All implementations must embed UnimplementedDagBundleServer for forward compatibility.

type Execute 

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

func (*Execute) ProtoMessage 

func (*Execute) ProtoMessage()

func (*Execute) ProtoReflect 

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

func (*Execute) Reset 

func (x *Execute) Reset()

func (*Execute) String 

func (x *Execute) String() string

type ExecuteTaskWorkload 

type ExecuteTaskWorkload struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*ExecuteTaskWorkload) ClearBundleInfo 

func (x *ExecuteTaskWorkload) ClearBundleInfo()

func (*ExecuteTaskWorkload) ClearLogPath 

func (x *ExecuteTaskWorkload) ClearLogPath()

func (*ExecuteTaskWorkload) ClearTi 

func (x *ExecuteTaskWorkload) ClearTi()

func (*ExecuteTaskWorkload) ClearToken 

func (x *ExecuteTaskWorkload) ClearToken()

func (*ExecuteTaskWorkload) GetBundleInfo 

func (x *ExecuteTaskWorkload) GetBundleInfo() *BundleInfo

func (*ExecuteTaskWorkload) GetLogPath 

func (x *ExecuteTaskWorkload) GetLogPath() string

func (*ExecuteTaskWorkload) GetTi 

func (x *ExecuteTaskWorkload) GetTi() *TaskInstance

func (*ExecuteTaskWorkload) GetToken 

func (x *ExecuteTaskWorkload) GetToken() string

func (*ExecuteTaskWorkload) HasBundleInfo 

func (x *ExecuteTaskWorkload) HasBundleInfo() bool

func (*ExecuteTaskWorkload) HasLogPath 

func (x *ExecuteTaskWorkload) HasLogPath() bool

func (*ExecuteTaskWorkload) HasTi 

func (x *ExecuteTaskWorkload) HasTi() bool

func (*ExecuteTaskWorkload) HasToken 

func (x *ExecuteTaskWorkload) HasToken() bool

func (*ExecuteTaskWorkload) ProtoMessage 

func (*ExecuteTaskWorkload) ProtoMessage()

func (*ExecuteTaskWorkload) ProtoReflect 

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

func (*ExecuteTaskWorkload) Reset 

func (x *ExecuteTaskWorkload) Reset()

func (*ExecuteTaskWorkload) SetBundleInfo 

func (x *ExecuteTaskWorkload) SetBundleInfo(v *BundleInfo)

func (*ExecuteTaskWorkload) SetLogPath 

func (x *ExecuteTaskWorkload) SetLogPath(v string)

func (*ExecuteTaskWorkload) SetTi 

func (x *ExecuteTaskWorkload) SetTi(v *TaskInstance)

func (*ExecuteTaskWorkload) SetToken 

func (x *ExecuteTaskWorkload) SetToken(v string)

func (*ExecuteTaskWorkload) String 

func (x *ExecuteTaskWorkload) String() string

type ExecuteTaskWorkload_builder 

type ExecuteTaskWorkload_builder struct {
	Token      *string
	Ti         *TaskInstance
	BundleInfo *BundleInfo
	LogPath    *string
	// contains filtered or unexported fields
}

func (ExecuteTaskWorkload_builder) Build 

func (b0 ExecuteTaskWorkload_builder) Build() *ExecuteTaskWorkload

type Execute_Request 

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

func (*Execute_Request) ClearTask 

func (x *Execute_Request) ClearTask()

func (*Execute_Request) ClearWorkload 

func (x *Execute_Request) ClearWorkload()

func (*Execute_Request) GetTask 

func (x *Execute_Request) GetTask() *ExecuteTaskWorkload

func (*Execute_Request) HasTask 

func (x *Execute_Request) HasTask() bool

func (*Execute_Request) HasWorkload 

func (x *Execute_Request) HasWorkload() bool

func (*Execute_Request) ProtoMessage 

func (*Execute_Request) ProtoMessage()

func (*Execute_Request) ProtoReflect 

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

func (*Execute_Request) Reset 

func (x *Execute_Request) Reset()

func (*Execute_Request) SetTask 

func (x *Execute_Request) SetTask(v *ExecuteTaskWorkload)

func (*Execute_Request) String 

func (x *Execute_Request) String() string

func (*Execute_Request) WhichWorkload 

func (x *Execute_Request) WhichWorkload() case_Execute_Request_Workload

type Execute_Request_builder 

type Execute_Request_builder struct {

	// Fields of oneof xxx_hidden_Workload:
	Task *ExecuteTaskWorkload
	// contains filtered or unexported fields
}

func (Execute_Request_builder) Build 

func (b0 Execute_Request_builder) Build() *Execute_Request

type Execute_Response 

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

func (*Execute_Response) ProtoMessage 

func (*Execute_Response) ProtoMessage()

func (*Execute_Response) ProtoReflect 

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

func (*Execute_Response) Reset 

func (x *Execute_Response) Reset()

func (*Execute_Response) String 

func (x *Execute_Response) String() string

type Execute_Response_builder 

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

func (Execute_Response_builder) Build 

func (b0 Execute_Response_builder) Build() *Execute_Response

type Execute_builder 

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

func (Execute_builder) Build 

func (b0 Execute_builder) Build() *Execute

type GetMetadata 

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

func (*GetMetadata) ProtoMessage 

func (*GetMetadata) ProtoMessage()

func (*GetMetadata) ProtoReflect 

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

func (*GetMetadata) Reset 

func (x *GetMetadata) Reset()

func (*GetMetadata) String 

func (x *GetMetadata) String() string

type GetMetadata_Request 

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

func (*GetMetadata_Request) ProtoMessage 

func (*GetMetadata_Request) ProtoMessage()

func (*GetMetadata_Request) ProtoReflect 

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

func (*GetMetadata_Request) Reset 

func (x *GetMetadata_Request) Reset()

func (*GetMetadata_Request) String 

func (x *GetMetadata_Request) String() string

type GetMetadata_Request_builder 

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

func (GetMetadata_Request_builder) Build 

func (b0 GetMetadata_Request_builder) Build() *GetMetadata_Request

type GetMetadata_Response 

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

func (*GetMetadata_Response) ClearBundle 

func (x *GetMetadata_Response) ClearBundle()

func (*GetMetadata_Response) GetBundle 

func (x *GetMetadata_Response) GetBundle() *BundleInfo

func (*GetMetadata_Response) HasBundle 

func (x *GetMetadata_Response) HasBundle() bool

func (*GetMetadata_Response) ProtoMessage 

func (*GetMetadata_Response) ProtoMessage()

func (*GetMetadata_Response) ProtoReflect 

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

func (*GetMetadata_Response) Reset 

func (x *GetMetadata_Response) Reset()

func (*GetMetadata_Response) SetBundle 

func (x *GetMetadata_Response) SetBundle(v *BundleInfo)

func (*GetMetadata_Response) String 

func (x *GetMetadata_Response) String() string

type GetMetadata_Response_builder 

type GetMetadata_Response_builder struct {
	Bundle *BundleInfo
	// contains filtered or unexported fields
}

func (GetMetadata_Response_builder) Build 

func (b0 GetMetadata_Response_builder) Build() *GetMetadata_Response

type GetMetadata_builder 

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

func (GetMetadata_builder) Build 

func (b0 GetMetadata_builder) Build() *GetMetadata

type TaskInstance 

type TaskInstance struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*TaskInstance) ClearDagId 

func (x *TaskInstance) ClearDagId()

func (*TaskInstance) ClearHostname 

func (x *TaskInstance) ClearHostname()

func (*TaskInstance) ClearId 

func (x *TaskInstance) ClearId()

func (*TaskInstance) ClearMapIndex 

func (x *TaskInstance) ClearMapIndex()

func (*TaskInstance) ClearRunId 

func (x *TaskInstance) ClearRunId()

func (*TaskInstance) ClearTaskId 

func (x *TaskInstance) ClearTaskId()

func (*TaskInstance) ClearTryNumber 

func (x *TaskInstance) ClearTryNumber()

func (*TaskInstance) GetDagId 

func (x *TaskInstance) GetDagId() string

func (*TaskInstance) GetHostname 

func (x *TaskInstance) GetHostname() string

func (*TaskInstance) GetId 

func (x *TaskInstance) GetId() *UUID

func (*TaskInstance) GetMapIndex 

func (x *TaskInstance) GetMapIndex() int32

func (*TaskInstance) GetOtelContext 

func (x *TaskInstance) GetOtelContext() map[string]string

func (*TaskInstance) GetRunId 

func (x *TaskInstance) GetRunId() string

func (*TaskInstance) GetTaskId 

func (x *TaskInstance) GetTaskId() string

func (*TaskInstance) GetTryNumber 

func (x *TaskInstance) GetTryNumber() int32

func (*TaskInstance) HasDagId 

func (x *TaskInstance) HasDagId() bool

func (*TaskInstance) HasHostname 

func (x *TaskInstance) HasHostname() bool

func (*TaskInstance) HasId 

func (x *TaskInstance) HasId() bool

func (*TaskInstance) HasMapIndex 

func (x *TaskInstance) HasMapIndex() bool

func (*TaskInstance) HasRunId 

func (x *TaskInstance) HasRunId() bool

func (*TaskInstance) HasTaskId 

func (x *TaskInstance) HasTaskId() bool

func (*TaskInstance) HasTryNumber 

func (x *TaskInstance) HasTryNumber() bool

func (*TaskInstance) ProtoMessage 

func (*TaskInstance) ProtoMessage()

func (*TaskInstance) ProtoReflect 

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

func (*TaskInstance) Reset 

func (x *TaskInstance) Reset()

func (*TaskInstance) SetDagId 

func (x *TaskInstance) SetDagId(v string)

func (*TaskInstance) SetHostname 

func (x *TaskInstance) SetHostname(v string)

func (*TaskInstance) SetId 

func (x *TaskInstance) SetId(v *UUID)

func (*TaskInstance) SetMapIndex 

func (x *TaskInstance) SetMapIndex(v int32)

func (*TaskInstance) SetOtelContext 

func (x *TaskInstance) SetOtelContext(v map[string]string)

func (*TaskInstance) SetRunId 

func (x *TaskInstance) SetRunId(v string)

func (*TaskInstance) SetTaskId 

func (x *TaskInstance) SetTaskId(v string)

func (*TaskInstance) SetTryNumber 

func (x *TaskInstance) SetTryNumber(v int32)

func (*TaskInstance) String 

func (x *TaskInstance) String() string

type TaskInstance_builder 

type TaskInstance_builder struct {
	Id          *UUID
	DagId       *string
	RunId       *string
	TaskId      *string
	MapIndex    *int32
	TryNumber   *int32
	Hostname    *string
	OtelContext map[string]string
	// contains filtered or unexported fields
}

func (TaskInstance_builder) Build 

func (b0 TaskInstance_builder) Build() *TaskInstance

type UUID 

type UUID struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*UUID) ClearValue 

func (x *UUID) ClearValue()

func (*UUID) GetValue 

func (x *UUID) GetValue() string

func (*UUID) HasValue 

func (x *UUID) HasValue() bool

func (*UUID) ProtoMessage 

func (*UUID) ProtoMessage()

func (*UUID) ProtoReflect 

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

func (*UUID) Reset 

func (x *UUID) Reset()

func (*UUID) SetValue 

func (x *UUID) SetValue(v string)

func (*UUID) String 

func (x *UUID) String() string

type UUID_builder 

type UUID_builder struct {
	Value *string
	// contains filtered or unexported fields
}

func (UUID_builder) Build 

func (b0 UUID_builder) Build() *UUID

type UnimplementedDagBundleServer 

type UnimplementedDagBundleServer struct{}

UnimplementedDagBundleServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedDagBundleServer) Execute 

func (UnimplementedDagBundleServer) Execute(context.Context, *Execute_Request) (*Execute_Response, error)

func (UnimplementedDagBundleServer) GetMetadata 

func (UnimplementedDagBundleServer) GetMetadata(context.Context, *GetMetadata_Request) (*GetMetadata_Response, error)

type UnsafeDagBundleServer 

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

UnsafeDagBundleServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DagBundleServer 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.