dataproxy

package
v2.0.21 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	DataProxyService_CreateUploadLocation_FullMethodName = "/flyteidl2.dataproxy.DataProxyService/CreateUploadLocation"
	DataProxyService_UploadInputs_FullMethodName         = "/flyteidl2.dataproxy.DataProxyService/UploadInputs"
	DataProxyService_CreateDownloadLink_FullMethodName   = "/flyteidl2.dataproxy.DataProxyService/CreateDownloadLink"
	DataProxyService_GetActionData_FullMethodName        = "/flyteidl2.dataproxy.DataProxyService/GetActionData"
	DataProxyService_TailLogs_FullMethodName             = "/flyteidl2.dataproxy.DataProxyService/TailLogs"
)

Variables

View Source 
var (
	ArtifactType_name = map[int32]string{
		0: "ARTIFACT_TYPE_UNSPECIFIED",
		1: "ARTIFACT_TYPE_REPORT",
		2: "ARTIFACT_TYPE_CODE_BUNDLE",
	}
	ArtifactType_value = map[string]int32{
		"ARTIFACT_TYPE_UNSPECIFIED": 0,
		"ARTIFACT_TYPE_REPORT":      1,
		"ARTIFACT_TYPE_CODE_BUNDLE": 2,
	}
)

Enum value maps for ArtifactType.

View Source 
var DataProxyService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flyteidl2.dataproxy.DataProxyService",
	HandlerType: (*DataProxyServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateUploadLocation",
			Handler:    _DataProxyService_CreateUploadLocation_Handler,
		},
		{
			MethodName: "UploadInputs",
			Handler:    _DataProxyService_UploadInputs_Handler,
		},
		{
			MethodName: "CreateDownloadLink",
			Handler:    _DataProxyService_CreateDownloadLink_Handler,
		},
		{
			MethodName: "GetActionData",
			Handler:    _DataProxyService_GetActionData_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "TailLogs",
			Handler:       _DataProxyService_TailLogs_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "flyteidl2/dataproxy/dataproxy_service.proto",
}

DataProxyService_ServiceDesc is the grpc.ServiceDesc for DataProxyService 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_flyteidl2_dataproxy_dataproxy_service_proto protoreflect.FileDescriptor

Functions

func RegisterDataProxyServiceServer 

func RegisterDataProxyServiceServer(s grpc.ServiceRegistrar, srv DataProxyServiceServer)

Types

type ArtifactType added in v2.0.12 

type ArtifactType int32

ArtifactType defines the type of artifact to be downloaded. 

const (
	ArtifactType_ARTIFACT_TYPE_UNSPECIFIED ArtifactType = 0
	// ARTIFACT_TYPE_REPORT refers to the HTML report file optionally generated after a task finishes executing.
	ArtifactType_ARTIFACT_TYPE_REPORT ArtifactType = 1
	// ARTIFACT_TYPE_CODE_BUNDLE refers to the code bundle (tarball) generated for an action.
	ArtifactType_ARTIFACT_TYPE_CODE_BUNDLE ArtifactType = 2
)

func (ArtifactType) Descriptor added in v2.0.12 

func (ArtifactType) Descriptor() protoreflect.EnumDescriptor

func (ArtifactType) Enum added in v2.0.12 

func (x ArtifactType) Enum() *ArtifactType

func (ArtifactType) EnumDescriptor deprecated added in v2.0.12 

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

Deprecated: Use ArtifactType.Descriptor instead.

func (ArtifactType) Number added in v2.0.12 

func (x ArtifactType) Number() protoreflect.EnumNumber

func (ArtifactType) String added in v2.0.12 

func (x ArtifactType) String() string

func (ArtifactType) Type added in v2.0.12 

func (ArtifactType) Type() protoreflect.EnumType

type CreateDownloadLinkRequest added in v2.0.12 

type CreateDownloadLinkRequest struct {

	// ArtifactType is the type of artifact to download.
	// +required
	ArtifactType ArtifactType `` /* 136-byte string literal not displayed */
	// ExpiresIn defines the requested expiration duration for the generated URLs. The request will be
	// rejected if this exceeds the platform's configured maximum.
	// +optional. The default value comes from the global config.
	ExpiresIn *durationpb.Duration `protobuf:"bytes,2,opt,name=expires_in,json=expiresIn,proto3" json:"expires_in,omitempty"`
	// Source identifies the action attempt whose artifact is to be downloaded.
	//
	// Types that are assignable to Source:
	//
	//	*CreateDownloadLinkRequest_ActionAttemptId
	//	*CreateDownloadLinkRequest_AppId
	//	*CreateDownloadLinkRequest_TaskId
	Source isCreateDownloadLinkRequest_Source `protobuf_oneof:"source"`
	// contains filtered or unexported fields
}

CreateDownloadLinkRequest specifies the request for the CreateDownloadLink API.

func (*CreateDownloadLinkRequest) Descriptor deprecated added in v2.0.12 

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

Deprecated: Use CreateDownloadLinkRequest.ProtoReflect.Descriptor instead.

func (*CreateDownloadLinkRequest) GetActionAttemptId added in v2.0.12 

func (x *CreateDownloadLinkRequest) GetActionAttemptId() *common.ActionAttemptIdentifier

func (*CreateDownloadLinkRequest) GetAppId added in v2.0.12 

func (x *CreateDownloadLinkRequest) GetAppId() *app.Identifier

func (*CreateDownloadLinkRequest) GetArtifactType added in v2.0.12 

func (x *CreateDownloadLinkRequest) GetArtifactType() ArtifactType

func (*CreateDownloadLinkRequest) GetExpiresIn added in v2.0.12 

func (x *CreateDownloadLinkRequest) GetExpiresIn() *durationpb.Duration

func (*CreateDownloadLinkRequest) GetSource added in v2.0.12 

func (m *CreateDownloadLinkRequest) GetSource() isCreateDownloadLinkRequest_Source

func (*CreateDownloadLinkRequest) GetTaskId added in v2.0.12 

func (x *CreateDownloadLinkRequest) GetTaskId() *task.TaskIdentifier

func (*CreateDownloadLinkRequest) ProtoMessage added in v2.0.12 

func (*CreateDownloadLinkRequest) ProtoMessage()

func (*CreateDownloadLinkRequest) ProtoReflect added in v2.0.12 

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

func (*CreateDownloadLinkRequest) Reset added in v2.0.12 

func (x *CreateDownloadLinkRequest) Reset()

func (*CreateDownloadLinkRequest) String added in v2.0.12 

func (x *CreateDownloadLinkRequest) String() string

func (*CreateDownloadLinkRequest) Validate added in v2.0.12 

func (m *CreateDownloadLinkRequest) Validate() error

Validate checks the field values on CreateDownloadLinkRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CreateDownloadLinkRequest) ValidateAll added in v2.0.12 

func (m *CreateDownloadLinkRequest) ValidateAll() error

ValidateAll checks the field values on CreateDownloadLinkRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CreateDownloadLinkRequestMultiError, or nil if none found.

type CreateDownloadLinkRequestMultiError added in v2.0.12 

type CreateDownloadLinkRequestMultiError []error

CreateDownloadLinkRequestMultiError is an error wrapping multiple validation errors returned by CreateDownloadLinkRequest.ValidateAll() if the designated constraints aren't met.

func (CreateDownloadLinkRequestMultiError) AllErrors added in v2.0.12 

func (m CreateDownloadLinkRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CreateDownloadLinkRequestMultiError) Error added in v2.0.12 

func (m CreateDownloadLinkRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CreateDownloadLinkRequestValidationError added in v2.0.12 

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

CreateDownloadLinkRequestValidationError is the validation error returned by CreateDownloadLinkRequest.Validate if the designated constraints aren't met.

func (CreateDownloadLinkRequestValidationError) Cause added in v2.0.12 

func (e CreateDownloadLinkRequestValidationError) Cause() error

Cause function returns cause value.

func (CreateDownloadLinkRequestValidationError) Error added in v2.0.12 

func (e CreateDownloadLinkRequestValidationError) Error() string

Error satisfies the builtin error interface

func (CreateDownloadLinkRequestValidationError) ErrorName added in v2.0.12 

func (e CreateDownloadLinkRequestValidationError) ErrorName() string

ErrorName returns error name.

func (CreateDownloadLinkRequestValidationError) Field added in v2.0.12 

func (e CreateDownloadLinkRequestValidationError) Field() string

Field function returns field value.

func (CreateDownloadLinkRequestValidationError) Key added in v2.0.12 

func (e CreateDownloadLinkRequestValidationError) Key() bool

Key function returns key value.

func (CreateDownloadLinkRequestValidationError) Reason added in v2.0.12 

func (e CreateDownloadLinkRequestValidationError) Reason() string

Reason function returns reason value.

type CreateDownloadLinkRequest_ActionAttemptId added in v2.0.12 

type CreateDownloadLinkRequest_ActionAttemptId struct {
	// ActionAttemptId identifies the specific attempt of a run action that produced the artifact.
	ActionAttemptId *common.ActionAttemptIdentifier `protobuf:"bytes,3,opt,name=action_attempt_id,json=actionAttemptId,proto3,oneof"`
}

type CreateDownloadLinkRequest_AppId added in v2.0.12 

type CreateDownloadLinkRequest_AppId struct {
	AppId *app.Identifier `protobuf:"bytes,4,opt,name=app_id,json=appId,proto3,oneof"`
}

type CreateDownloadLinkRequest_TaskId added in v2.0.12 

type CreateDownloadLinkRequest_TaskId struct {
	TaskId *task.TaskIdentifier `protobuf:"bytes,5,opt,name=task_id,json=taskId,proto3,oneof"`
}

type CreateDownloadLinkResponse added in v2.0.12 

type CreateDownloadLinkResponse struct {

	// PreSignedUrls contains the signed URLs and their expiration time.
	PreSignedUrls *PreSignedURLs `protobuf:"bytes,1,opt,name=pre_signed_urls,json=preSignedUrls,proto3" json:"pre_signed_urls,omitempty"`
	// contains filtered or unexported fields
}

CreateDownloadLinkResponse specifies the response for the CreateDownloadLink API.

func (*CreateDownloadLinkResponse) Descriptor deprecated added in v2.0.12 

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

Deprecated: Use CreateDownloadLinkResponse.ProtoReflect.Descriptor instead.

func (*CreateDownloadLinkResponse) GetPreSignedUrls added in v2.0.12 

func (x *CreateDownloadLinkResponse) GetPreSignedUrls() *PreSignedURLs

func (*CreateDownloadLinkResponse) ProtoMessage added in v2.0.12 

func (*CreateDownloadLinkResponse) ProtoMessage()

func (*CreateDownloadLinkResponse) ProtoReflect added in v2.0.12 

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

func (*CreateDownloadLinkResponse) Reset added in v2.0.12 

func (x *CreateDownloadLinkResponse) Reset()

func (*CreateDownloadLinkResponse) String added in v2.0.12 

func (x *CreateDownloadLinkResponse) String() string

func (*CreateDownloadLinkResponse) Validate added in v2.0.12 

func (m *CreateDownloadLinkResponse) Validate() error

Validate checks the field values on CreateDownloadLinkResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CreateDownloadLinkResponse) ValidateAll added in v2.0.12 

func (m *CreateDownloadLinkResponse) ValidateAll() error

ValidateAll checks the field values on CreateDownloadLinkResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CreateDownloadLinkResponseMultiError, or nil if none found.

type CreateDownloadLinkResponseMultiError added in v2.0.12 

type CreateDownloadLinkResponseMultiError []error

CreateDownloadLinkResponseMultiError is an error wrapping multiple validation errors returned by CreateDownloadLinkResponse.ValidateAll() if the designated constraints aren't met.

func (CreateDownloadLinkResponseMultiError) AllErrors added in v2.0.12 

func (m CreateDownloadLinkResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CreateDownloadLinkResponseMultiError) Error added in v2.0.12 

func (m CreateDownloadLinkResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CreateDownloadLinkResponseValidationError added in v2.0.12 

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

CreateDownloadLinkResponseValidationError is the validation error returned by CreateDownloadLinkResponse.Validate if the designated constraints aren't met.

func (CreateDownloadLinkResponseValidationError) Cause added in v2.0.12 

func (e CreateDownloadLinkResponseValidationError) Cause() error

Cause function returns cause value.

func (CreateDownloadLinkResponseValidationError) Error added in v2.0.12 

func (e CreateDownloadLinkResponseValidationError) Error() string

Error satisfies the builtin error interface

func (CreateDownloadLinkResponseValidationError) ErrorName added in v2.0.12 

func (e CreateDownloadLinkResponseValidationError) ErrorName() string

ErrorName returns error name.

func (CreateDownloadLinkResponseValidationError) Field added in v2.0.12 

func (e CreateDownloadLinkResponseValidationError) Field() string

Field function returns field value.

func (CreateDownloadLinkResponseValidationError) Key added in v2.0.12 

func (e CreateDownloadLinkResponseValidationError) Key() bool

Key function returns key value.

func (CreateDownloadLinkResponseValidationError) Reason added in v2.0.12 

func (e CreateDownloadLinkResponseValidationError) Reason() string

Reason function returns reason value.

type CreateUploadLocationRequest 

type CreateUploadLocationRequest struct {

	// Project to create the upload location for.
	// +required
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Domain to create the upload location for.
	// +required
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// Filename specifies the desired suffix for the generated location. E.g. `file.py` or `pre/fix/file.zip`.
	// +optional. By default, the service generates a consistent name based on the default filename length provided in the global config..
	Filename string `protobuf:"bytes,3,opt,name=filename,proto3" json:"filename,omitempty"`
	// ExpiresIn defines the requested expiration duration for the generated URL. The request will be rejected if this
	// exceeds the platform's configured maximum.
	// +optional. The default value comes from the global config.
	ExpiresIn *durationpb.Duration `protobuf:"bytes,4,opt,name=expires_in,json=expiresIn,proto3" json:"expires_in,omitempty"`
	// ContentMD5 restricts the upload location to the specific MD5 provided. The MD5 hash will also appear in the
	// generated path for verification.
	// +required
	ContentMd5 []byte `protobuf:"bytes,5,opt,name=content_md5,json=contentMd5,proto3" json:"content_md5,omitempty"`
	// FilenameRoot, if present, will be used instead of the MD5 hash in the path. When combined with filename,
	// this makes the upload location deterministic. The native URL will still be prefixed by the upload location prefix
	// configured in the data proxy. This option is useful when uploading multiple related files.
	// +optional
	FilenameRoot string `protobuf:"bytes,6,opt,name=filename_root,json=filenameRoot,proto3" json:"filename_root,omitempty"`
	// If true, the data proxy will add content_md5 to the Signed URL requirements,
	// forcing clients to send this checksum with the object.
	// This is required to enforce data integrity on backends like GCP, ensuring that
	// the uploaded file matches the hash.
	AddContentMd5Metadata bool `` /* 129-byte string literal not displayed */
	// Org is the organization key applied to the resource.
	// +optional
	Org string `protobuf:"bytes,8,opt,name=org,proto3" json:"org,omitempty"`
	// ContentLength specifies the size of the content to be uploaded in bytes.
	// This is validated against the platform's maximum upload size if provided.
	// +optional
	ContentLength int64 `protobuf:"varint,9,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
	// contains filtered or unexported fields
}

CreateUploadLocationRequest specifies the request for the CreateUploadLocation API. The data proxy service will generate a storage location with server-side configured prefixes. The generated path follows one of these patterns:

  • project/domain/(deterministic hash of content_md5)/filename (if filename is present); OR
  • project/domain/filename_root/filename (if filename_root and filename are present).

func (*CreateUploadLocationRequest) Descriptor deprecated 

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

Deprecated: Use CreateUploadLocationRequest.ProtoReflect.Descriptor instead.

func (*CreateUploadLocationRequest) GetAddContentMd5Metadata 

func (x *CreateUploadLocationRequest) GetAddContentMd5Metadata() bool

func (*CreateUploadLocationRequest) GetContentLength 

func (x *CreateUploadLocationRequest) GetContentLength() int64

func (*CreateUploadLocationRequest) GetContentMd5 

func (x *CreateUploadLocationRequest) GetContentMd5() []byte

func (*CreateUploadLocationRequest) GetDomain 

func (x *CreateUploadLocationRequest) GetDomain() string

func (*CreateUploadLocationRequest) GetExpiresIn 

func (x *CreateUploadLocationRequest) GetExpiresIn() *durationpb.Duration

func (*CreateUploadLocationRequest) GetFilename 

func (x *CreateUploadLocationRequest) GetFilename() string

func (*CreateUploadLocationRequest) GetFilenameRoot 

func (x *CreateUploadLocationRequest) GetFilenameRoot() string

func (*CreateUploadLocationRequest) GetOrg 

func (x *CreateUploadLocationRequest) GetOrg() string

func (*CreateUploadLocationRequest) GetProject 

func (x *CreateUploadLocationRequest) GetProject() string

func (*CreateUploadLocationRequest) ProtoMessage 

func (*CreateUploadLocationRequest) ProtoMessage()

func (*CreateUploadLocationRequest) ProtoReflect 

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

func (*CreateUploadLocationRequest) Reset 

func (x *CreateUploadLocationRequest) Reset()

func (*CreateUploadLocationRequest) String 

func (x *CreateUploadLocationRequest) String() string

func (*CreateUploadLocationRequest) Validate 

func (m *CreateUploadLocationRequest) Validate() error

Validate checks the field values on CreateUploadLocationRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CreateUploadLocationRequest) ValidateAll 

func (m *CreateUploadLocationRequest) ValidateAll() error

ValidateAll checks the field values on CreateUploadLocationRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CreateUploadLocationRequestMultiError, or nil if none found.

type CreateUploadLocationRequestMultiError 

type CreateUploadLocationRequestMultiError []error

CreateUploadLocationRequestMultiError is an error wrapping multiple validation errors returned by CreateUploadLocationRequest.ValidateAll() if the designated constraints aren't met.

func (CreateUploadLocationRequestMultiError) AllErrors 

func (m CreateUploadLocationRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CreateUploadLocationRequestMultiError) Error 

func (m CreateUploadLocationRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CreateUploadLocationRequestValidationError 

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

CreateUploadLocationRequestValidationError is the validation error returned by CreateUploadLocationRequest.Validate if the designated constraints aren't met.

func (CreateUploadLocationRequestValidationError) Cause 

func (e CreateUploadLocationRequestValidationError) Cause() error

Cause function returns cause value.

func (CreateUploadLocationRequestValidationError) Error 

func (e CreateUploadLocationRequestValidationError) Error() string

Error satisfies the builtin error interface

func (CreateUploadLocationRequestValidationError) ErrorName 

func (e CreateUploadLocationRequestValidationError) ErrorName() string

ErrorName returns error name.

func (CreateUploadLocationRequestValidationError) Field 

func (e CreateUploadLocationRequestValidationError) Field() string

Field function returns field value.

func (CreateUploadLocationRequestValidationError) Key 

func (e CreateUploadLocationRequestValidationError) Key() bool

Key function returns key value.

func (CreateUploadLocationRequestValidationError) Reason 

func (e CreateUploadLocationRequestValidationError) Reason() string

Reason function returns reason value.

type CreateUploadLocationResponse 

type CreateUploadLocationResponse struct {

	// SignedUrl is the URL to use for uploading content (e.g. https://my-bucket.s3.amazonaws.com/randomstring/suffix.tar?X-...).
	SignedUrl string `protobuf:"bytes,1,opt,name=signed_url,json=signedUrl,proto3" json:"signed_url,omitempty"`
	// NativeUrl is the URL in the format of the configured storage provider (e.g. s3://my-bucket/randomstring/suffix.tar).
	NativeUrl string `protobuf:"bytes,2,opt,name=native_url,json=nativeUrl,proto3" json:"native_url,omitempty"`
	// ExpiresAt defines when the signed URL will expire.
	ExpiresAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// Headers are generated by the data proxy for the client. Clients must include these headers in the upload request.
	Headers map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

CreateUploadLocationResponse specifies the response for the CreateUploadLocation API.

func (*CreateUploadLocationResponse) Descriptor deprecated 

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

Deprecated: Use CreateUploadLocationResponse.ProtoReflect.Descriptor instead.

func (*CreateUploadLocationResponse) GetExpiresAt 

func (x *CreateUploadLocationResponse) GetExpiresAt() *timestamppb.Timestamp

func (*CreateUploadLocationResponse) GetHeaders 

func (x *CreateUploadLocationResponse) GetHeaders() map[string]string

func (*CreateUploadLocationResponse) GetNativeUrl 

func (x *CreateUploadLocationResponse) GetNativeUrl() string

func (*CreateUploadLocationResponse) GetSignedUrl 

func (x *CreateUploadLocationResponse) GetSignedUrl() string

func (*CreateUploadLocationResponse) ProtoMessage 

func (*CreateUploadLocationResponse) ProtoMessage()

func (*CreateUploadLocationResponse) ProtoReflect 

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

func (*CreateUploadLocationResponse) Reset 

func (x *CreateUploadLocationResponse) Reset()

func (*CreateUploadLocationResponse) String 

func (x *CreateUploadLocationResponse) String() string

func (*CreateUploadLocationResponse) Validate 

func (m *CreateUploadLocationResponse) Validate() error

Validate checks the field values on CreateUploadLocationResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CreateUploadLocationResponse) ValidateAll 

func (m *CreateUploadLocationResponse) ValidateAll() error

ValidateAll checks the field values on CreateUploadLocationResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CreateUploadLocationResponseMultiError, or nil if none found.

type CreateUploadLocationResponseMultiError 

type CreateUploadLocationResponseMultiError []error

CreateUploadLocationResponseMultiError is an error wrapping multiple validation errors returned by CreateUploadLocationResponse.ValidateAll() if the designated constraints aren't met.

func (CreateUploadLocationResponseMultiError) AllErrors 

func (m CreateUploadLocationResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CreateUploadLocationResponseMultiError) Error 

func (m CreateUploadLocationResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CreateUploadLocationResponseValidationError 

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

CreateUploadLocationResponseValidationError is the validation error returned by CreateUploadLocationResponse.Validate if the designated constraints aren't met.

func (CreateUploadLocationResponseValidationError) Cause 

func (e CreateUploadLocationResponseValidationError) Cause() error

Cause function returns cause value.

func (CreateUploadLocationResponseValidationError) Error 

func (e CreateUploadLocationResponseValidationError) Error() string

Error satisfies the builtin error interface

func (CreateUploadLocationResponseValidationError) ErrorName 

func (e CreateUploadLocationResponseValidationError) ErrorName() string

ErrorName returns error name.

func (CreateUploadLocationResponseValidationError) Field 

func (e CreateUploadLocationResponseValidationError) Field() string

Field function returns field value.

func (CreateUploadLocationResponseValidationError) Key 

func (e CreateUploadLocationResponseValidationError) Key() bool

Key function returns key value.

func (CreateUploadLocationResponseValidationError) Reason 

func (e CreateUploadLocationResponseValidationError) Reason() string

Reason function returns reason value.

type DataProxyServiceClient 

type DataProxyServiceClient interface {
	// CreateUploadLocation generates a signed URL for uploading data to the configured storage backend.
	CreateUploadLocation(ctx context.Context, in *CreateUploadLocationRequest, opts ...grpc.CallOption) (*CreateUploadLocationResponse, error)
	UploadInputs(ctx context.Context, in *UploadInputsRequest, opts ...grpc.CallOption) (*UploadInputsResponse, error)
	// CreateDownloadLink generates signed URL(s) for downloading a given artifact.
	CreateDownloadLink(ctx context.Context, in *CreateDownloadLinkRequest, opts ...grpc.CallOption) (*CreateDownloadLinkResponse, error)
	// Get input and output data for an action.
	GetActionData(ctx context.Context, in *GetActionDataRequest, opts ...grpc.CallOption) (*GetActionDataResponse, error)
	// Stream logs for an action attempt.
	TailLogs(ctx context.Context, in *TailLogsRequest, opts ...grpc.CallOption) (DataProxyService_TailLogsClient, error)
}

DataProxyServiceClient is the client API for DataProxyService 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 NewDataProxyServiceClient 

func NewDataProxyServiceClient(cc grpc.ClientConnInterface) DataProxyServiceClient

type DataProxyServiceServer 

type DataProxyServiceServer interface {
	// CreateUploadLocation generates a signed URL for uploading data to the configured storage backend.
	CreateUploadLocation(context.Context, *CreateUploadLocationRequest) (*CreateUploadLocationResponse, error)
	UploadInputs(context.Context, *UploadInputsRequest) (*UploadInputsResponse, error)
	// CreateDownloadLink generates signed URL(s) for downloading a given artifact.
	CreateDownloadLink(context.Context, *CreateDownloadLinkRequest) (*CreateDownloadLinkResponse, error)
	// Get input and output data for an action.
	GetActionData(context.Context, *GetActionDataRequest) (*GetActionDataResponse, error)
	// Stream logs for an action attempt.
	TailLogs(*TailLogsRequest, DataProxyService_TailLogsServer) error
}

DataProxyServiceServer is the server API for DataProxyService service. All implementations should embed UnimplementedDataProxyServiceServer for forward compatibility

type DataProxyService_TailLogsClient added in v2.0.12 

type DataProxyService_TailLogsClient interface {
	Recv() (*TailLogsResponse, error)
	grpc.ClientStream
}

type DataProxyService_TailLogsServer added in v2.0.12 

type DataProxyService_TailLogsServer interface {
	Send(*TailLogsResponse) error
	grpc.ServerStream
}

type GetActionDataRequest added in v2.0.12 

type GetActionDataRequest struct {

	// Action to query.
	ActionId *common.ActionIdentifier `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// contains filtered or unexported fields
}

Request message for querying action data.

func (*GetActionDataRequest) Descriptor deprecated added in v2.0.12 

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

Deprecated: Use GetActionDataRequest.ProtoReflect.Descriptor instead.

func (*GetActionDataRequest) GetActionId added in v2.0.12 

func (x *GetActionDataRequest) GetActionId() *common.ActionIdentifier

func (*GetActionDataRequest) ProtoMessage added in v2.0.12 

func (*GetActionDataRequest) ProtoMessage()

func (*GetActionDataRequest) ProtoReflect added in v2.0.12 

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

func (*GetActionDataRequest) Reset added in v2.0.12 

func (x *GetActionDataRequest) Reset()

func (*GetActionDataRequest) String added in v2.0.12 

func (x *GetActionDataRequest) String() string

func (*GetActionDataRequest) Validate added in v2.0.12 

func (m *GetActionDataRequest) Validate() error

Validate checks the field values on GetActionDataRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetActionDataRequest) ValidateAll added in v2.0.12 

func (m *GetActionDataRequest) ValidateAll() error

ValidateAll checks the field values on GetActionDataRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetActionDataRequestMultiError, or nil if none found.

type GetActionDataRequestMultiError added in v2.0.12 

type GetActionDataRequestMultiError []error

GetActionDataRequestMultiError is an error wrapping multiple validation errors returned by GetActionDataRequest.ValidateAll() if the designated constraints aren't met.

func (GetActionDataRequestMultiError) AllErrors added in v2.0.12 

func (m GetActionDataRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetActionDataRequestMultiError) Error added in v2.0.12 

func (m GetActionDataRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetActionDataRequestValidationError added in v2.0.12 

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

GetActionDataRequestValidationError is the validation error returned by GetActionDataRequest.Validate if the designated constraints aren't met.

func (GetActionDataRequestValidationError) Cause added in v2.0.12 

func (e GetActionDataRequestValidationError) Cause() error

Cause function returns cause value.

func (GetActionDataRequestValidationError) Error added in v2.0.12 

func (e GetActionDataRequestValidationError) Error() string

Error satisfies the builtin error interface

func (GetActionDataRequestValidationError) ErrorName added in v2.0.12 

func (e GetActionDataRequestValidationError) ErrorName() string

ErrorName returns error name.

func (GetActionDataRequestValidationError) Field added in v2.0.12 

func (e GetActionDataRequestValidationError) Field() string

Field function returns field value.

func (GetActionDataRequestValidationError) Key added in v2.0.12 

func (e GetActionDataRequestValidationError) Key() bool

Key function returns key value.

func (GetActionDataRequestValidationError) Reason added in v2.0.12 

func (e GetActionDataRequestValidationError) Reason() string

Reason function returns reason value.

type GetActionDataResponse added in v2.0.12 

type GetActionDataResponse struct {

	// Inputs for the action.
	Inputs *task.Inputs `protobuf:"bytes,1,opt,name=inputs,proto3" json:"inputs,omitempty"`
	// Outputs for the action.
	Outputs *task.Outputs `protobuf:"bytes,2,opt,name=outputs,proto3" json:"outputs,omitempty"`
	// contains filtered or unexported fields
}

Response message for querying action data.

func (*GetActionDataResponse) Descriptor deprecated added in v2.0.12 

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

Deprecated: Use GetActionDataResponse.ProtoReflect.Descriptor instead.

func (*GetActionDataResponse) GetInputs added in v2.0.12 

func (x *GetActionDataResponse) GetInputs() *task.Inputs

func (*GetActionDataResponse) GetOutputs added in v2.0.12 

func (x *GetActionDataResponse) GetOutputs() *task.Outputs

func (*GetActionDataResponse) ProtoMessage added in v2.0.12 

func (*GetActionDataResponse) ProtoMessage()

func (*GetActionDataResponse) ProtoReflect added in v2.0.12 

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

func (*GetActionDataResponse) Reset added in v2.0.12 

func (x *GetActionDataResponse) Reset()

func (*GetActionDataResponse) String added in v2.0.12 

func (x *GetActionDataResponse) String() string

func (*GetActionDataResponse) Validate added in v2.0.12 

func (m *GetActionDataResponse) Validate() error

Validate checks the field values on GetActionDataResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetActionDataResponse) ValidateAll added in v2.0.12 

func (m *GetActionDataResponse) ValidateAll() error

ValidateAll checks the field values on GetActionDataResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetActionDataResponseMultiError, or nil if none found.

type GetActionDataResponseMultiError added in v2.0.12 

type GetActionDataResponseMultiError []error

GetActionDataResponseMultiError is an error wrapping multiple validation errors returned by GetActionDataResponse.ValidateAll() if the designated constraints aren't met.

func (GetActionDataResponseMultiError) AllErrors added in v2.0.12 

func (m GetActionDataResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetActionDataResponseMultiError) Error added in v2.0.12 

func (m GetActionDataResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetActionDataResponseValidationError added in v2.0.12 

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

GetActionDataResponseValidationError is the validation error returned by GetActionDataResponse.Validate if the designated constraints aren't met.

func (GetActionDataResponseValidationError) Cause added in v2.0.12 

func (e GetActionDataResponseValidationError) Cause() error

Cause function returns cause value.

func (GetActionDataResponseValidationError) Error added in v2.0.12 

func (e GetActionDataResponseValidationError) Error() string

Error satisfies the builtin error interface

func (GetActionDataResponseValidationError) ErrorName added in v2.0.12 

func (e GetActionDataResponseValidationError) ErrorName() string

ErrorName returns error name.

func (GetActionDataResponseValidationError) Field added in v2.0.12 

func (e GetActionDataResponseValidationError) Field() string

Field function returns field value.

func (GetActionDataResponseValidationError) Key added in v2.0.12 

func (e GetActionDataResponseValidationError) Key() bool

Key function returns key value.

func (GetActionDataResponseValidationError) Reason added in v2.0.12 

func (e GetActionDataResponseValidationError) Reason() string

Reason function returns reason value.

type PreSignedURLs added in v2.0.12 

type PreSignedURLs struct {

	// SignedUrl are the pre-signed URLs for downloading the artifact.
	SignedUrl []string `protobuf:"bytes,1,rep,name=signed_url,json=signedUrl,proto3" json:"signed_url,omitempty"`
	// ExpiresAt defines when the signed URLs will expire.
	ExpiresAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// contains filtered or unexported fields
}

PreSignedURLs contains a list of signed URLs for downloading artifacts.

func (*PreSignedURLs) Descriptor deprecated added in v2.0.12 

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

Deprecated: Use PreSignedURLs.ProtoReflect.Descriptor instead.

func (*PreSignedURLs) GetExpiresAt added in v2.0.12 

func (x *PreSignedURLs) GetExpiresAt() *timestamppb.Timestamp

func (*PreSignedURLs) GetSignedUrl added in v2.0.12 

func (x *PreSignedURLs) GetSignedUrl() []string

func (*PreSignedURLs) ProtoMessage added in v2.0.12 

func (*PreSignedURLs) ProtoMessage()

func (*PreSignedURLs) ProtoReflect added in v2.0.12 

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

func (*PreSignedURLs) Reset added in v2.0.12 

func (x *PreSignedURLs) Reset()

func (*PreSignedURLs) String added in v2.0.12 

func (x *PreSignedURLs) String() string

func (*PreSignedURLs) Validate added in v2.0.12 

func (m *PreSignedURLs) Validate() error

Validate checks the field values on PreSignedURLs with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PreSignedURLs) ValidateAll added in v2.0.12 

func (m *PreSignedURLs) ValidateAll() error

ValidateAll checks the field values on PreSignedURLs with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PreSignedURLsMultiError, or nil if none found.

type PreSignedURLsMultiError added in v2.0.12 

type PreSignedURLsMultiError []error

PreSignedURLsMultiError is an error wrapping multiple validation errors returned by PreSignedURLs.ValidateAll() if the designated constraints aren't met.

func (PreSignedURLsMultiError) AllErrors added in v2.0.12 

func (m PreSignedURLsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PreSignedURLsMultiError) Error added in v2.0.12 

func (m PreSignedURLsMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PreSignedURLsValidationError added in v2.0.12 

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

PreSignedURLsValidationError is the validation error returned by PreSignedURLs.Validate if the designated constraints aren't met.

func (PreSignedURLsValidationError) Cause added in v2.0.12 

func (e PreSignedURLsValidationError) Cause() error

Cause function returns cause value.

func (PreSignedURLsValidationError) Error added in v2.0.12 

func (e PreSignedURLsValidationError) Error() string

Error satisfies the builtin error interface

func (PreSignedURLsValidationError) ErrorName added in v2.0.12 

func (e PreSignedURLsValidationError) ErrorName() string

ErrorName returns error name.

func (PreSignedURLsValidationError) Field added in v2.0.12 

func (e PreSignedURLsValidationError) Field() string

Field function returns field value.

func (PreSignedURLsValidationError) Key added in v2.0.12 

func (e PreSignedURLsValidationError) Key() bool

Key function returns key value.

func (PreSignedURLsValidationError) Reason added in v2.0.12 

func (e PreSignedURLsValidationError) Reason() string

Reason function returns reason value.

type TailLogsRequest added in v2.0.12 

type TailLogsRequest struct {

	// The action id.
	ActionId *common.ActionIdentifier `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// The attempt number.
	Attempt uint32 `protobuf:"varint,2,opt,name=attempt,proto3" json:"attempt,omitempty"`
	// Selects which pod(s) to tail. If unset, defaults to primary_pod.
	//
	// Types that are assignable to PodSelector:
	//
	//	*TailLogsRequest_PrimaryPod
	//	*TailLogsRequest_AllPods
	//	*TailLogsRequest_PodName
	PodSelector isTailLogsRequest_PodSelector `protobuf_oneof:"pod_selector"`
	// +optional. The dataproxy uses this to stream logs from the connector via
	// AsyncConnectorService.GetTaskLogs instead of pod logs.
	ConnectorEndpoint *string `protobuf:"bytes,4,opt,name=connector_endpoint,json=connectorEndpoint,proto3,oneof" json:"connector_endpoint,omitempty"`
	// contains filtered or unexported fields
}

Request message for tailing logs.

func (*TailLogsRequest) Descriptor deprecated added in v2.0.12 

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

Deprecated: Use TailLogsRequest.ProtoReflect.Descriptor instead.

func (*TailLogsRequest) GetActionId added in v2.0.12 

func (x *TailLogsRequest) GetActionId() *common.ActionIdentifier

func (*TailLogsRequest) GetAllPods added in v2.0.18 

func (x *TailLogsRequest) GetAllPods() bool

func (*TailLogsRequest) GetAttempt added in v2.0.12 

func (x *TailLogsRequest) GetAttempt() uint32

func (*TailLogsRequest) GetConnectorEndpoint added in v2.0.15 

func (x *TailLogsRequest) GetConnectorEndpoint() string

func (*TailLogsRequest) GetPodName added in v2.0.14 

func (x *TailLogsRequest) GetPodName() string

func (*TailLogsRequest) GetPodSelector added in v2.0.18 

func (m *TailLogsRequest) GetPodSelector() isTailLogsRequest_PodSelector

func (*TailLogsRequest) GetPrimaryPod added in v2.0.18 

func (x *TailLogsRequest) GetPrimaryPod() bool

func (*TailLogsRequest) ProtoMessage added in v2.0.12 

func (*TailLogsRequest) ProtoMessage()

func (*TailLogsRequest) ProtoReflect added in v2.0.12 

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

func (*TailLogsRequest) Reset added in v2.0.12 

func (x *TailLogsRequest) Reset()

func (*TailLogsRequest) String added in v2.0.12 

func (x *TailLogsRequest) String() string

func (*TailLogsRequest) Validate added in v2.0.12 

func (m *TailLogsRequest) Validate() error

Validate checks the field values on TailLogsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TailLogsRequest) ValidateAll added in v2.0.12 

func (m *TailLogsRequest) ValidateAll() error

ValidateAll checks the field values on TailLogsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TailLogsRequestMultiError, or nil if none found.

type TailLogsRequestMultiError added in v2.0.12 

type TailLogsRequestMultiError []error

TailLogsRequestMultiError is an error wrapping multiple validation errors returned by TailLogsRequest.ValidateAll() if the designated constraints aren't met.

func (TailLogsRequestMultiError) AllErrors added in v2.0.12 

func (m TailLogsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TailLogsRequestMultiError) Error added in v2.0.12 

func (m TailLogsRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TailLogsRequestValidationError added in v2.0.12 

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

TailLogsRequestValidationError is the validation error returned by TailLogsRequest.Validate if the designated constraints aren't met.

func (TailLogsRequestValidationError) Cause added in v2.0.12 

func (e TailLogsRequestValidationError) Cause() error

Cause function returns cause value.

func (TailLogsRequestValidationError) Error added in v2.0.12 

func (e TailLogsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (TailLogsRequestValidationError) ErrorName added in v2.0.12 

func (e TailLogsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (TailLogsRequestValidationError) Field added in v2.0.12 

func (e TailLogsRequestValidationError) Field() string

Field function returns field value.

func (TailLogsRequestValidationError) Key added in v2.0.12 

func (e TailLogsRequestValidationError) Key() bool

Key function returns key value.

func (TailLogsRequestValidationError) Reason added in v2.0.12 

func (e TailLogsRequestValidationError) Reason() string

Reason function returns reason value.

type TailLogsRequest_AllPods added in v2.0.18 

type TailLogsRequest_AllPods struct {
	// Tail logs from all pods.
	AllPods bool `protobuf:"varint,5,opt,name=all_pods,json=allPods,proto3,oneof"`
}

type TailLogsRequest_PodName added in v2.0.18 

type TailLogsRequest_PodName struct {
	// Tail logs from the named pod only.
	PodName string `protobuf:"bytes,3,opt,name=pod_name,json=podName,proto3,oneof"`
}

type TailLogsRequest_PrimaryPod added in v2.0.18 

type TailLogsRequest_PrimaryPod struct {
	// Tail logs from the primary pod only. This is the default when pod_selector is unset.
	PrimaryPod bool `protobuf:"varint,6,opt,name=primary_pod,json=primaryPod,proto3,oneof"`
}

type TailLogsResponse added in v2.0.12 

type TailLogsResponse struct {

	// One or more batches of logs.
	Logs []*TailLogsResponse_Logs `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

Reponse message for tailing logs.

func (*TailLogsResponse) Descriptor deprecated added in v2.0.12 

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

Deprecated: Use TailLogsResponse.ProtoReflect.Descriptor instead.

func (*TailLogsResponse) GetLogs added in v2.0.12 

func (x *TailLogsResponse) GetLogs() []*TailLogsResponse_Logs

func (*TailLogsResponse) ProtoMessage added in v2.0.12 

func (*TailLogsResponse) ProtoMessage()

func (*TailLogsResponse) ProtoReflect added in v2.0.12 

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

func (*TailLogsResponse) Reset added in v2.0.12 

func (x *TailLogsResponse) Reset()

func (*TailLogsResponse) String added in v2.0.12 

func (x *TailLogsResponse) String() string

func (*TailLogsResponse) Validate added in v2.0.12 

func (m *TailLogsResponse) Validate() error

Validate checks the field values on TailLogsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TailLogsResponse) ValidateAll added in v2.0.12 

func (m *TailLogsResponse) ValidateAll() error

ValidateAll checks the field values on TailLogsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TailLogsResponseMultiError, or nil if none found.

type TailLogsResponseMultiError added in v2.0.12 

type TailLogsResponseMultiError []error

TailLogsResponseMultiError is an error wrapping multiple validation errors returned by TailLogsResponse.ValidateAll() if the designated constraints aren't met.

func (TailLogsResponseMultiError) AllErrors added in v2.0.12 

func (m TailLogsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TailLogsResponseMultiError) Error added in v2.0.12 

func (m TailLogsResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TailLogsResponseValidationError added in v2.0.12 

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

TailLogsResponseValidationError is the validation error returned by TailLogsResponse.Validate if the designated constraints aren't met.

func (TailLogsResponseValidationError) Cause added in v2.0.12 

func (e TailLogsResponseValidationError) Cause() error

Cause function returns cause value.

func (TailLogsResponseValidationError) Error added in v2.0.12 

func (e TailLogsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (TailLogsResponseValidationError) ErrorName added in v2.0.12 

func (e TailLogsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (TailLogsResponseValidationError) Field added in v2.0.12 

func (e TailLogsResponseValidationError) Field() string

Field function returns field value.

func (TailLogsResponseValidationError) Key added in v2.0.12 

func (e TailLogsResponseValidationError) Key() bool

Key function returns key value.

func (TailLogsResponseValidationError) Reason added in v2.0.12 

func (e TailLogsResponseValidationError) Reason() string

Reason function returns reason value.

type TailLogsResponse_Logs added in v2.0.12 

type TailLogsResponse_Logs struct {

	// Structured log lines.
	Lines []*dataplane.LogLine `protobuf:"bytes,1,rep,name=lines,proto3" json:"lines,omitempty"`
	// Which container these lines are from.
	Container *dataplane.ContainerIdentifier `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"`
	// contains filtered or unexported fields
}

A batch of logs.

func (*TailLogsResponse_Logs) Descriptor deprecated added in v2.0.12 

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

Deprecated: Use TailLogsResponse_Logs.ProtoReflect.Descriptor instead.

func (*TailLogsResponse_Logs) GetContainer added in v2.0.18 

func (x *TailLogsResponse_Logs) GetContainer() *dataplane.ContainerIdentifier

func (*TailLogsResponse_Logs) GetLines added in v2.0.12 

func (x *TailLogsResponse_Logs) GetLines() []*dataplane.LogLine

func (*TailLogsResponse_Logs) ProtoMessage added in v2.0.12 

func (*TailLogsResponse_Logs) ProtoMessage()

func (*TailLogsResponse_Logs) ProtoReflect added in v2.0.12 

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

func (*TailLogsResponse_Logs) Reset added in v2.0.12 

func (x *TailLogsResponse_Logs) Reset()

func (*TailLogsResponse_Logs) String added in v2.0.12 

func (x *TailLogsResponse_Logs) String() string

func (*TailLogsResponse_Logs) Validate added in v2.0.12 

func (m *TailLogsResponse_Logs) Validate() error

Validate checks the field values on TailLogsResponse_Logs with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TailLogsResponse_Logs) ValidateAll added in v2.0.12 

func (m *TailLogsResponse_Logs) ValidateAll() error

ValidateAll checks the field values on TailLogsResponse_Logs with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TailLogsResponse_LogsMultiError, or nil if none found.

type TailLogsResponse_LogsMultiError added in v2.0.12 

type TailLogsResponse_LogsMultiError []error

TailLogsResponse_LogsMultiError is an error wrapping multiple validation errors returned by TailLogsResponse_Logs.ValidateAll() if the designated constraints aren't met.

func (TailLogsResponse_LogsMultiError) AllErrors added in v2.0.12 

func (m TailLogsResponse_LogsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TailLogsResponse_LogsMultiError) Error added in v2.0.12 

func (m TailLogsResponse_LogsMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TailLogsResponse_LogsValidationError added in v2.0.12 

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

TailLogsResponse_LogsValidationError is the validation error returned by TailLogsResponse_Logs.Validate if the designated constraints aren't met.

func (TailLogsResponse_LogsValidationError) Cause added in v2.0.12 

func (e TailLogsResponse_LogsValidationError) Cause() error

Cause function returns cause value.

func (TailLogsResponse_LogsValidationError) Error added in v2.0.12 

func (e TailLogsResponse_LogsValidationError) Error() string

Error satisfies the builtin error interface

func (TailLogsResponse_LogsValidationError) ErrorName added in v2.0.12 

func (e TailLogsResponse_LogsValidationError) ErrorName() string

ErrorName returns error name.

func (TailLogsResponse_LogsValidationError) Field added in v2.0.12 

func (e TailLogsResponse_LogsValidationError) Field() string

Field function returns field value.

func (TailLogsResponse_LogsValidationError) Key added in v2.0.12 

func (e TailLogsResponse_LogsValidationError) Key() bool

Key function returns key value.

func (TailLogsResponse_LogsValidationError) Reason added in v2.0.12 

func (e TailLogsResponse_LogsValidationError) Reason() string

Reason function returns reason value.

type UnimplementedDataProxyServiceServer 

type UnimplementedDataProxyServiceServer struct {
}

UnimplementedDataProxyServiceServer should be embedded to have forward compatible implementations. 

func (UnimplementedDataProxyServiceServer) CreateDownloadLink(context.Context, *CreateDownloadLinkRequest) (*CreateDownloadLinkResponse, error)

func (UnimplementedDataProxyServiceServer) CreateUploadLocation 

func (UnimplementedDataProxyServiceServer) CreateUploadLocation(context.Context, *CreateUploadLocationRequest) (*CreateUploadLocationResponse, error)

func (UnimplementedDataProxyServiceServer) GetActionData added in v2.0.12 

func (UnimplementedDataProxyServiceServer) GetActionData(context.Context, *GetActionDataRequest) (*GetActionDataResponse, error)

func (UnimplementedDataProxyServiceServer) TailLogs added in v2.0.12 

func (UnimplementedDataProxyServiceServer) TailLogs(*TailLogsRequest, DataProxyService_TailLogsServer) error

func (UnimplementedDataProxyServiceServer) UploadInputs added in v2.0.10 

func (UnimplementedDataProxyServiceServer) UploadInputs(context.Context, *UploadInputsRequest) (*UploadInputsResponse, error)

type UnsafeDataProxyServiceServer 

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

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

type UploadInputsRequest added in v2.0.10 

type UploadInputsRequest struct {

	// Types that are assignable to Id:
	//
	//	*UploadInputsRequest_RunId
	//	*UploadInputsRequest_ProjectId
	Id isUploadInputsRequest_Id `protobuf_oneof:"id"`
	// The task these inputs are used for.
	// This is used to determine which inputs can be excluded from the hash used for cache key computation in a subsequent CreateRun call.
	//
	// Types that are assignable to Task:
	//
	//	*UploadInputsRequest_TaskId
	//	*UploadInputsRequest_TaskSpec
	//	*UploadInputsRequest_TriggerName
	Task isUploadInputsRequest_Task `protobuf_oneof:"task"`
	// The actual inputs.
	Inputs *task.Inputs `protobuf:"bytes,6,opt,name=inputs,proto3" json:"inputs,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadInputsRequest) Descriptor deprecated added in v2.0.10 

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

Deprecated: Use UploadInputsRequest.ProtoReflect.Descriptor instead.

func (*UploadInputsRequest) GetId added in v2.0.10 

func (m *UploadInputsRequest) GetId() isUploadInputsRequest_Id

func (*UploadInputsRequest) GetInputs added in v2.0.10 

func (x *UploadInputsRequest) GetInputs() *task.Inputs

func (*UploadInputsRequest) GetProjectId added in v2.0.10 

func (x *UploadInputsRequest) GetProjectId() *common.ProjectIdentifier

func (*UploadInputsRequest) GetRunId added in v2.0.10 

func (x *UploadInputsRequest) GetRunId() *common.RunIdentifier

func (*UploadInputsRequest) GetTask added in v2.0.10 

func (m *UploadInputsRequest) GetTask() isUploadInputsRequest_Task

func (*UploadInputsRequest) GetTaskId added in v2.0.10 

func (x *UploadInputsRequest) GetTaskId() *task.TaskIdentifier

func (*UploadInputsRequest) GetTaskSpec added in v2.0.10 

func (x *UploadInputsRequest) GetTaskSpec() *task.TaskSpec

func (*UploadInputsRequest) GetTriggerName added in v2.0.10 

func (x *UploadInputsRequest) GetTriggerName() *common.TriggerName

func (*UploadInputsRequest) ProtoMessage added in v2.0.10 

func (*UploadInputsRequest) ProtoMessage()

func (*UploadInputsRequest) ProtoReflect added in v2.0.10 

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

func (*UploadInputsRequest) Reset added in v2.0.10 

func (x *UploadInputsRequest) Reset()

func (*UploadInputsRequest) String added in v2.0.10 

func (x *UploadInputsRequest) String() string

func (*UploadInputsRequest) Validate added in v2.0.10 

func (m *UploadInputsRequest) Validate() error

Validate checks the field values on UploadInputsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*UploadInputsRequest) ValidateAll added in v2.0.10 

func (m *UploadInputsRequest) ValidateAll() error

ValidateAll checks the field values on UploadInputsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in UploadInputsRequestMultiError, or nil if none found.

type UploadInputsRequestMultiError added in v2.0.10 

type UploadInputsRequestMultiError []error

UploadInputsRequestMultiError is an error wrapping multiple validation errors returned by UploadInputsRequest.ValidateAll() if the designated constraints aren't met.

func (UploadInputsRequestMultiError) AllErrors added in v2.0.10 

func (m UploadInputsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UploadInputsRequestMultiError) Error added in v2.0.10 

func (m UploadInputsRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type UploadInputsRequestValidationError added in v2.0.10 

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

UploadInputsRequestValidationError is the validation error returned by UploadInputsRequest.Validate if the designated constraints aren't met.

func (UploadInputsRequestValidationError) Cause added in v2.0.10 

func (e UploadInputsRequestValidationError) Cause() error

Cause function returns cause value.

func (UploadInputsRequestValidationError) Error added in v2.0.10 

func (e UploadInputsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (UploadInputsRequestValidationError) ErrorName added in v2.0.10 

func (e UploadInputsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (UploadInputsRequestValidationError) Field added in v2.0.10 

func (e UploadInputsRequestValidationError) Field() string

Field function returns field value.

func (UploadInputsRequestValidationError) Key added in v2.0.10 

func (e UploadInputsRequestValidationError) Key() bool

Key function returns key value.

func (UploadInputsRequestValidationError) Reason added in v2.0.10 

func (e UploadInputsRequestValidationError) Reason() string

Reason function returns reason value.

type UploadInputsRequest_ProjectId added in v2.0.10 

type UploadInputsRequest_ProjectId struct {
	// The project id for this run. Run name will be generated.
	ProjectId *common.ProjectIdentifier `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3,oneof"`
}

type UploadInputsRequest_RunId added in v2.0.10 

type UploadInputsRequest_RunId struct {
	// The user provided run id.
	RunId *common.RunIdentifier `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3,oneof"`
}

type UploadInputsRequest_TaskId added in v2.0.10 

type UploadInputsRequest_TaskId struct {
	// The task id to use.
	TaskId *task.TaskIdentifier `protobuf:"bytes,3,opt,name=task_id,json=taskId,proto3,oneof"`
}

type UploadInputsRequest_TaskSpec added in v2.0.10 

type UploadInputsRequest_TaskSpec struct {
	// The task spec to use.
	TaskSpec *task.TaskSpec `protobuf:"bytes,4,opt,name=task_spec,json=taskSpec,proto3,oneof"`
}

type UploadInputsRequest_TriggerName added in v2.0.10 

type UploadInputsRequest_TriggerName struct {
	// The trigger name to use.
	TriggerName *common.TriggerName `protobuf:"bytes,5,opt,name=trigger_name,json=triggerName,proto3,oneof"`
}

type UploadInputsResponse added in v2.0.10 

type UploadInputsResponse struct {
	OffloadedInputData *common.OffloadedInputData `protobuf:"bytes,1,opt,name=offloaded_input_data,json=offloadedInputData,proto3" json:"offloaded_input_data,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadInputsResponse) Descriptor deprecated added in v2.0.10 

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

Deprecated: Use UploadInputsResponse.ProtoReflect.Descriptor instead.

func (*UploadInputsResponse) GetOffloadedInputData added in v2.0.10 

func (x *UploadInputsResponse) GetOffloadedInputData() *common.OffloadedInputData

func (*UploadInputsResponse) ProtoMessage added in v2.0.10 

func (*UploadInputsResponse) ProtoMessage()

func (*UploadInputsResponse) ProtoReflect added in v2.0.10 

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

func (*UploadInputsResponse) Reset added in v2.0.10 

func (x *UploadInputsResponse) Reset()

func (*UploadInputsResponse) String added in v2.0.10 

func (x *UploadInputsResponse) String() string

func (*UploadInputsResponse) Validate added in v2.0.10 

func (m *UploadInputsResponse) Validate() error

Validate checks the field values on UploadInputsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*UploadInputsResponse) ValidateAll added in v2.0.10 

func (m *UploadInputsResponse) ValidateAll() error

ValidateAll checks the field values on UploadInputsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in UploadInputsResponseMultiError, or nil if none found.

type UploadInputsResponseMultiError added in v2.0.10 

type UploadInputsResponseMultiError []error

UploadInputsResponseMultiError is an error wrapping multiple validation errors returned by UploadInputsResponse.ValidateAll() if the designated constraints aren't met.

func (UploadInputsResponseMultiError) AllErrors added in v2.0.10 

func (m UploadInputsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UploadInputsResponseMultiError) Error added in v2.0.10 

func (m UploadInputsResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type UploadInputsResponseValidationError added in v2.0.10 

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

UploadInputsResponseValidationError is the validation error returned by UploadInputsResponse.Validate if the designated constraints aren't met.

func (UploadInputsResponseValidationError) Cause added in v2.0.10 

func (e UploadInputsResponseValidationError) Cause() error

Cause function returns cause value.

func (UploadInputsResponseValidationError) Error added in v2.0.10 

func (e UploadInputsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (UploadInputsResponseValidationError) ErrorName added in v2.0.10 

func (e UploadInputsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (UploadInputsResponseValidationError) Field added in v2.0.10 

func (e UploadInputsResponseValidationError) Field() string

Field function returns field value.

func (UploadInputsResponseValidationError) Key added in v2.0.10 

func (e UploadInputsResponseValidationError) Key() bool

Key function returns key value.

func (UploadInputsResponseValidationError) Reason added in v2.0.10 

func (e UploadInputsResponseValidationError) Reason() string

Reason function returns reason value.

Source Files

View all Source files

Directories

Path Synopsis

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.