beam: github.com/apache/beam/sdks/go/pkg/beam/model/jobmanagement_v1 Index | Files

package jobmanagement_v1

import "github.com/apache/beam/sdks/go/pkg/beam/model/jobmanagement_v1"

Index

Package Files

beam_artifact_api.pb.go beam_expansion_api.pb.go beam_job_api.pb.go

Variables

var CommitManifestResponse_Constants_name = map[int32]string{
    0: "NO_ARTIFACTS_STAGED_TOKEN",
}
var CommitManifestResponse_Constants_value = map[string]int32{
    "NO_ARTIFACTS_STAGED_TOKEN": 0,
}
var JobMessage_MessageImportance_name = map[int32]string{
    0:  "MESSAGE_IMPORTANCE_UNSPECIFIED",
    1:  "JOB_MESSAGE_DEBUG",
    2:  "JOB_MESSAGE_DETAILED",
    3:  "JOB_MESSAGE_BASIC",
    4:  "JOB_MESSAGE_WARNING",
    5:  "JOB_MESSAGE_ERROR",
}
var JobMessage_MessageImportance_value = map[string]int32{
    "MESSAGE_IMPORTANCE_UNSPECIFIED": 0,
    "JOB_MESSAGE_DEBUG":              1,
    "JOB_MESSAGE_DETAILED":           2,
    "JOB_MESSAGE_BASIC":              3,
    "JOB_MESSAGE_WARNING":            4,
    "JOB_MESSAGE_ERROR":              5,
}
var JobState_Enum_name = map[int32]string{
    0:  "UNSPECIFIED",
    1:  "STOPPED",
    2:  "RUNNING",
    3:  "DONE",
    4:  "FAILED",
    5:  "CANCELLED",
    6:  "UPDATED",
    7:  "DRAINING",
    8:  "DRAINED",
    9:  "STARTING",
    10: "CANCELLING",
    11: "UPDATING",
}
var JobState_Enum_value = map[string]int32{
    "UNSPECIFIED": 0,
    "STOPPED":     1,
    "RUNNING":     2,
    "DONE":        3,
    "FAILED":      4,
    "CANCELLED":   5,
    "UPDATED":     6,
    "DRAINING":    7,
    "DRAINED":     8,
    "STARTING":    9,
    "CANCELLING":  10,
    "UPDATING":    11,
}
var PipelineOptionType_Enum_name = map[int32]string{
    0:  "STRING",
    1:  "BOOLEAN",
    2:  "INTEGER",
    3:  "NUMBER",
    4:  "ARRAY",
    5:  "OBJECT",
}
var PipelineOptionType_Enum_value = map[string]int32{
    "STRING":  0,
    "BOOLEAN": 1,
    "INTEGER": 2,
    "NUMBER":  3,
    "ARRAY":   4,
    "OBJECT":  5,
}

func RegisterArtifactRetrievalServiceServer Uses

func RegisterArtifactRetrievalServiceServer(s *grpc.Server, srv ArtifactRetrievalServiceServer)

func RegisterArtifactStagingServiceServer Uses

func RegisterArtifactStagingServiceServer(s *grpc.Server, srv ArtifactStagingServiceServer)

func RegisterExpansionServiceServer Uses

func RegisterExpansionServiceServer(s *grpc.Server, srv ExpansionServiceServer)

func RegisterJobServiceServer Uses

func RegisterJobServiceServer(s *grpc.Server, srv JobServiceServer)

func RegisterLegacyArtifactRetrievalServiceServer Uses

func RegisterLegacyArtifactRetrievalServiceServer(s *grpc.Server, srv LegacyArtifactRetrievalServiceServer)

func RegisterLegacyArtifactStagingServiceServer Uses

func RegisterLegacyArtifactStagingServiceServer(s *grpc.Server, srv LegacyArtifactStagingServiceServer)

type ArtifactChunk Uses

type ArtifactChunk struct {
    Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Part of an artifact.

func (*ArtifactChunk) Descriptor Uses

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

func (*ArtifactChunk) GetData Uses

func (m *ArtifactChunk) GetData() []byte

func (*ArtifactChunk) ProtoMessage Uses

func (*ArtifactChunk) ProtoMessage()

func (*ArtifactChunk) Reset Uses

func (m *ArtifactChunk) Reset()

func (*ArtifactChunk) String Uses

func (m *ArtifactChunk) String() string

func (*ArtifactChunk) XXX_DiscardUnknown Uses

func (m *ArtifactChunk) XXX_DiscardUnknown()

func (*ArtifactChunk) XXX_Marshal Uses

func (m *ArtifactChunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ArtifactChunk) XXX_Merge Uses

func (m *ArtifactChunk) XXX_Merge(src proto.Message)

func (*ArtifactChunk) XXX_Size Uses

func (m *ArtifactChunk) XXX_Size() int

func (*ArtifactChunk) XXX_Unmarshal Uses

func (m *ArtifactChunk) XXX_Unmarshal(b []byte) error

type ArtifactMetadata Uses

type ArtifactMetadata struct {
    // (Required) The name of the artifact.
    Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // (Optional) The Unix-like permissions of the artifact
    Permissions uint32 `protobuf:"varint,2,opt,name=permissions,proto3" json:"permissions,omitempty"`
    // (Optional) The hex-encoded sha256 checksum of the artifact. Used, among other things, by
    // harness boot code to validate the integrity of the artifact.
    Sha256               string   `protobuf:"bytes,4,opt,name=sha256,proto3" json:"sha256,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

An artifact identifier and associated metadata.

func (*ArtifactMetadata) Descriptor Uses

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

func (*ArtifactMetadata) GetName Uses

func (m *ArtifactMetadata) GetName() string

func (*ArtifactMetadata) GetPermissions Uses

func (m *ArtifactMetadata) GetPermissions() uint32

func (*ArtifactMetadata) GetSha256 Uses

func (m *ArtifactMetadata) GetSha256() string

func (*ArtifactMetadata) ProtoMessage Uses

func (*ArtifactMetadata) ProtoMessage()

func (*ArtifactMetadata) Reset Uses

func (m *ArtifactMetadata) Reset()

func (*ArtifactMetadata) String Uses

func (m *ArtifactMetadata) String() string

func (*ArtifactMetadata) XXX_DiscardUnknown Uses

func (m *ArtifactMetadata) XXX_DiscardUnknown()

func (*ArtifactMetadata) XXX_Marshal Uses

func (m *ArtifactMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ArtifactMetadata) XXX_Merge Uses

func (m *ArtifactMetadata) XXX_Merge(src proto.Message)

func (*ArtifactMetadata) XXX_Size Uses

func (m *ArtifactMetadata) XXX_Size() int

func (*ArtifactMetadata) XXX_Unmarshal Uses

func (m *ArtifactMetadata) XXX_Unmarshal(b []byte) error

type ArtifactRequestWrapper Uses

type ArtifactRequestWrapper struct {
    // Types that are valid to be assigned to Request:
    //	*ArtifactRequestWrapper_ResolveArtifact
    //	*ArtifactRequestWrapper_GetArtifact
    Request              isArtifactRequestWrapper_Request `protobuf_oneof:"request"`
    XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
    XXX_unrecognized     []byte                           `json:"-"`
    XXX_sizecache        int32                            `json:"-"`
}

Wraps an ArtifactRetrievalService request for use in ReverseArtifactRetrievalService.

func (*ArtifactRequestWrapper) Descriptor Uses

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

func (*ArtifactRequestWrapper) GetGetArtifact Uses

func (m *ArtifactRequestWrapper) GetGetArtifact() *GetArtifactRequest

func (*ArtifactRequestWrapper) GetRequest Uses

func (m *ArtifactRequestWrapper) GetRequest() isArtifactRequestWrapper_Request

func (*ArtifactRequestWrapper) GetResolveArtifact Uses

func (m *ArtifactRequestWrapper) GetResolveArtifact() *ResolveArtifactsRequest

func (*ArtifactRequestWrapper) ProtoMessage Uses

func (*ArtifactRequestWrapper) ProtoMessage()

func (*ArtifactRequestWrapper) Reset Uses

func (m *ArtifactRequestWrapper) Reset()

func (*ArtifactRequestWrapper) String Uses

func (m *ArtifactRequestWrapper) String() string

func (*ArtifactRequestWrapper) XXX_DiscardUnknown Uses

func (m *ArtifactRequestWrapper) XXX_DiscardUnknown()

func (*ArtifactRequestWrapper) XXX_Marshal Uses

func (m *ArtifactRequestWrapper) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ArtifactRequestWrapper) XXX_Merge Uses

func (m *ArtifactRequestWrapper) XXX_Merge(src proto.Message)

func (*ArtifactRequestWrapper) XXX_OneofWrappers Uses

func (*ArtifactRequestWrapper) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ArtifactRequestWrapper) XXX_Size Uses

func (m *ArtifactRequestWrapper) XXX_Size() int

func (*ArtifactRequestWrapper) XXX_Unmarshal Uses

func (m *ArtifactRequestWrapper) XXX_Unmarshal(b []byte) error

type ArtifactRequestWrapper_GetArtifact Uses

type ArtifactRequestWrapper_GetArtifact struct {
    GetArtifact *GetArtifactRequest `protobuf:"bytes,1001,opt,name=get_artifact,json=getArtifact,proto3,oneof"`
}

type ArtifactRequestWrapper_ResolveArtifact Uses

type ArtifactRequestWrapper_ResolveArtifact struct {
    ResolveArtifact *ResolveArtifactsRequest `protobuf:"bytes,1000,opt,name=resolve_artifact,json=resolveArtifact,proto3,oneof"`
}

type ArtifactResponseWrapper Uses

type ArtifactResponseWrapper struct {
    // A token indicating which job these artifacts are being staged for.
    StagingToken string `protobuf:"bytes,1,opt,name=staging_token,json=stagingToken,proto3" json:"staging_token,omitempty"`
    // Whether this is the last response for this request (for those responses that
    // would typically be terminated by the end of the response stream.)
    IsLast bool `protobuf:"varint,2,opt,name=is_last,json=isLast,proto3" json:"is_last,omitempty"`
    // The response itself.
    //
    // Types that are valid to be assigned to Response:
    //	*ArtifactResponseWrapper_ResolveArtifactResponse
    //	*ArtifactResponseWrapper_GetArtifactResponse
    Response             isArtifactResponseWrapper_Response `protobuf_oneof:"response"`
    XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
    XXX_unrecognized     []byte                             `json:"-"`
    XXX_sizecache        int32                              `json:"-"`
}

Wraps an ArtifactRetrievalService response for use in ReverseArtifactRetrievalService.

func (*ArtifactResponseWrapper) Descriptor Uses

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

func (*ArtifactResponseWrapper) GetGetArtifactResponse Uses

func (m *ArtifactResponseWrapper) GetGetArtifactResponse() *GetArtifactResponse

func (*ArtifactResponseWrapper) GetIsLast Uses

func (m *ArtifactResponseWrapper) GetIsLast() bool

func (*ArtifactResponseWrapper) GetResolveArtifactResponse Uses

func (m *ArtifactResponseWrapper) GetResolveArtifactResponse() *ResolveArtifactsResponse

func (*ArtifactResponseWrapper) GetResponse Uses

func (m *ArtifactResponseWrapper) GetResponse() isArtifactResponseWrapper_Response

func (*ArtifactResponseWrapper) GetStagingToken Uses

func (m *ArtifactResponseWrapper) GetStagingToken() string

func (*ArtifactResponseWrapper) ProtoMessage Uses

func (*ArtifactResponseWrapper) ProtoMessage()

func (*ArtifactResponseWrapper) Reset Uses

func (m *ArtifactResponseWrapper) Reset()

func (*ArtifactResponseWrapper) String Uses

func (m *ArtifactResponseWrapper) String() string

func (*ArtifactResponseWrapper) XXX_DiscardUnknown Uses

func (m *ArtifactResponseWrapper) XXX_DiscardUnknown()

func (*ArtifactResponseWrapper) XXX_Marshal Uses

func (m *ArtifactResponseWrapper) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ArtifactResponseWrapper) XXX_Merge Uses

func (m *ArtifactResponseWrapper) XXX_Merge(src proto.Message)

func (*ArtifactResponseWrapper) XXX_OneofWrappers Uses

func (*ArtifactResponseWrapper) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ArtifactResponseWrapper) XXX_Size Uses

func (m *ArtifactResponseWrapper) XXX_Size() int

func (*ArtifactResponseWrapper) XXX_Unmarshal Uses

func (m *ArtifactResponseWrapper) XXX_Unmarshal(b []byte) error

type ArtifactResponseWrapper_GetArtifactResponse Uses

type ArtifactResponseWrapper_GetArtifactResponse struct {
    GetArtifactResponse *GetArtifactResponse `protobuf:"bytes,1001,opt,name=get_artifact_response,json=getArtifactResponse,proto3,oneof"`
}

type ArtifactResponseWrapper_ResolveArtifactResponse Uses

type ArtifactResponseWrapper_ResolveArtifactResponse struct {
    ResolveArtifactResponse *ResolveArtifactsResponse `protobuf:"bytes,1000,opt,name=resolve_artifact_response,json=resolveArtifactResponse,proto3,oneof"`
}

type ArtifactRetrievalServiceClient Uses

type ArtifactRetrievalServiceClient interface {
    // Resolves the given artifact references into one or more replacement
    // artifact references (e.g. a Maven dependency into a (transitive) set
    // of jars.
    ResolveArtifacts(ctx context.Context, in *ResolveArtifactsRequest, opts ...grpc.CallOption) (*ResolveArtifactsResponse, error)
    // Retrieves the given artifact as a stream of bytes.
    GetArtifact(ctx context.Context, in *GetArtifactRequest, opts ...grpc.CallOption) (ArtifactRetrievalService_GetArtifactClient, error)
}

ArtifactRetrievalServiceClient is the client API for ArtifactRetrievalService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewArtifactRetrievalServiceClient Uses

func NewArtifactRetrievalServiceClient(cc *grpc.ClientConn) ArtifactRetrievalServiceClient

type ArtifactRetrievalServiceServer Uses

type ArtifactRetrievalServiceServer interface {
    // Resolves the given artifact references into one or more replacement
    // artifact references (e.g. a Maven dependency into a (transitive) set
    // of jars.
    ResolveArtifacts(context.Context, *ResolveArtifactsRequest) (*ResolveArtifactsResponse, error)
    // Retrieves the given artifact as a stream of bytes.
    GetArtifact(*GetArtifactRequest, ArtifactRetrievalService_GetArtifactServer) error
}

ArtifactRetrievalServiceServer is the server API for ArtifactRetrievalService service.

type ArtifactRetrievalService_GetArtifactClient Uses

type ArtifactRetrievalService_GetArtifactClient interface {
    Recv() (*GetArtifactResponse, error)
    grpc.ClientStream
}

type ArtifactRetrievalService_GetArtifactServer Uses

type ArtifactRetrievalService_GetArtifactServer interface {
    Send(*GetArtifactResponse) error
    grpc.ServerStream
}

type ArtifactStagingServiceClient Uses

type ArtifactStagingServiceClient interface {
    ReverseArtifactRetrievalService(ctx context.Context, opts ...grpc.CallOption) (ArtifactStagingService_ReverseArtifactRetrievalServiceClient, error)
}

ArtifactStagingServiceClient is the client API for ArtifactStagingService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewArtifactStagingServiceClient Uses

func NewArtifactStagingServiceClient(cc *grpc.ClientConn) ArtifactStagingServiceClient

type ArtifactStagingServiceServer Uses

type ArtifactStagingServiceServer interface {
    ReverseArtifactRetrievalService(ArtifactStagingService_ReverseArtifactRetrievalServiceServer) error
}

ArtifactStagingServiceServer is the server API for ArtifactStagingService service.

type ArtifactStagingService_ReverseArtifactRetrievalServiceClient Uses

type ArtifactStagingService_ReverseArtifactRetrievalServiceClient interface {
    Send(*ArtifactResponseWrapper) error
    Recv() (*ArtifactRequestWrapper, error)
    grpc.ClientStream
}

type ArtifactStagingService_ReverseArtifactRetrievalServiceServer Uses

type ArtifactStagingService_ReverseArtifactRetrievalServiceServer interface {
    Send(*ArtifactRequestWrapper) error
    Recv() (*ArtifactResponseWrapper, error)
    grpc.ServerStream
}

type CancelJobRequest Uses

type CancelJobRequest struct {
    JobId                string   `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Cancel is a synchronus request that returns a job state back Throws error GRPC_STATUS_UNAVAILABLE if server is down Throws error NOT_FOUND if the jobId is not found

func (*CancelJobRequest) Descriptor Uses

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

func (*CancelJobRequest) GetJobId Uses

func (m *CancelJobRequest) GetJobId() string

func (*CancelJobRequest) ProtoMessage Uses

func (*CancelJobRequest) ProtoMessage()

func (*CancelJobRequest) Reset Uses

func (m *CancelJobRequest) Reset()

func (*CancelJobRequest) String Uses

func (m *CancelJobRequest) String() string

func (*CancelJobRequest) XXX_DiscardUnknown Uses

func (m *CancelJobRequest) XXX_DiscardUnknown()

func (*CancelJobRequest) XXX_Marshal Uses

func (m *CancelJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CancelJobRequest) XXX_Merge Uses

func (m *CancelJobRequest) XXX_Merge(src proto.Message)

func (*CancelJobRequest) XXX_Size Uses

func (m *CancelJobRequest) XXX_Size() int

func (*CancelJobRequest) XXX_Unmarshal Uses

func (m *CancelJobRequest) XXX_Unmarshal(b []byte) error

type CancelJobResponse Uses

type CancelJobResponse struct {
    State                JobState_Enum `protobuf:"varint,1,opt,name=state,proto3,enum=org.apache.beam.model.job_management.v1.JobState_Enum" json:"state,omitempty"`
    XXX_NoUnkeyedLiteral struct{}      `json:"-"`
    XXX_unrecognized     []byte        `json:"-"`
    XXX_sizecache        int32         `json:"-"`
}

Valid responses include any terminal state or CANCELLING

func (*CancelJobResponse) Descriptor Uses

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

func (*CancelJobResponse) GetState Uses

func (m *CancelJobResponse) GetState() JobState_Enum

func (*CancelJobResponse) ProtoMessage Uses

func (*CancelJobResponse) ProtoMessage()

func (*CancelJobResponse) Reset Uses

func (m *CancelJobResponse) Reset()

func (*CancelJobResponse) String Uses

func (m *CancelJobResponse) String() string

func (*CancelJobResponse) XXX_DiscardUnknown Uses

func (m *CancelJobResponse) XXX_DiscardUnknown()

func (*CancelJobResponse) XXX_Marshal Uses

func (m *CancelJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CancelJobResponse) XXX_Merge Uses

func (m *CancelJobResponse) XXX_Merge(src proto.Message)

func (*CancelJobResponse) XXX_Size Uses

func (m *CancelJobResponse) XXX_Size() int

func (*CancelJobResponse) XXX_Unmarshal Uses

func (m *CancelJobResponse) XXX_Unmarshal(b []byte) error

type CommitManifestRequest Uses

type CommitManifestRequest struct {
    // (Required) The manifest to commit.
    Manifest *Manifest `protobuf:"bytes,1,opt,name=manifest,proto3" json:"manifest,omitempty"`
    // (Required) A token for artifact staging session. This token can be obtained
    // from PrepareJob request in JobService
    StagingSessionToken  string   `protobuf:"bytes,2,opt,name=staging_session_token,json=stagingSessionToken,proto3" json:"staging_session_token,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A request to commit the manifest for a Job. All artifacts must have been successfully uploaded before this call is made.

func (*CommitManifestRequest) Descriptor Uses

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

func (*CommitManifestRequest) GetManifest Uses

func (m *CommitManifestRequest) GetManifest() *Manifest

func (*CommitManifestRequest) GetStagingSessionToken Uses

func (m *CommitManifestRequest) GetStagingSessionToken() string

func (*CommitManifestRequest) ProtoMessage Uses

func (*CommitManifestRequest) ProtoMessage()

func (*CommitManifestRequest) Reset Uses

func (m *CommitManifestRequest) Reset()

func (*CommitManifestRequest) String Uses

func (m *CommitManifestRequest) String() string

func (*CommitManifestRequest) XXX_DiscardUnknown Uses

func (m *CommitManifestRequest) XXX_DiscardUnknown()

func (*CommitManifestRequest) XXX_Marshal Uses

func (m *CommitManifestRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitManifestRequest) XXX_Merge Uses

func (m *CommitManifestRequest) XXX_Merge(src proto.Message)

func (*CommitManifestRequest) XXX_Size Uses

func (m *CommitManifestRequest) XXX_Size() int

func (*CommitManifestRequest) XXX_Unmarshal Uses

func (m *CommitManifestRequest) XXX_Unmarshal(b []byte) error

type CommitManifestResponse Uses

type CommitManifestResponse struct {
    // (Required) An opaque token representing the entirety of the staged artifacts.
    // This can be used to retrieve the manifest and artifacts from an associated
    // LegacyArtifactRetrievalService.
    RetrievalToken       string   `protobuf:"bytes,1,opt,name=retrieval_token,json=retrievalToken,proto3" json:"retrieval_token,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

The result of committing a manifest.

func (*CommitManifestResponse) Descriptor Uses

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

func (*CommitManifestResponse) GetRetrievalToken Uses

func (m *CommitManifestResponse) GetRetrievalToken() string

func (*CommitManifestResponse) ProtoMessage Uses

func (*CommitManifestResponse) ProtoMessage()

func (*CommitManifestResponse) Reset Uses

func (m *CommitManifestResponse) Reset()

func (*CommitManifestResponse) String Uses

func (m *CommitManifestResponse) String() string

func (*CommitManifestResponse) XXX_DiscardUnknown Uses

func (m *CommitManifestResponse) XXX_DiscardUnknown()

func (*CommitManifestResponse) XXX_Marshal Uses

func (m *CommitManifestResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitManifestResponse) XXX_Merge Uses

func (m *CommitManifestResponse) XXX_Merge(src proto.Message)

func (*CommitManifestResponse) XXX_Size Uses

func (m *CommitManifestResponse) XXX_Size() int

func (*CommitManifestResponse) XXX_Unmarshal Uses

func (m *CommitManifestResponse) XXX_Unmarshal(b []byte) error

type CommitManifestResponse_Constants Uses

type CommitManifestResponse_Constants int32
const (
    // Token indicating that no artifacts were staged and therefore no retrieval attempt is necessary.
    CommitManifestResponse_NO_ARTIFACTS_STAGED_TOKEN CommitManifestResponse_Constants = 0
)

func (CommitManifestResponse_Constants) EnumDescriptor Uses

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

func (CommitManifestResponse_Constants) String Uses

func (x CommitManifestResponse_Constants) String() string

type DescribePipelineOptionsRequest Uses

type DescribePipelineOptionsRequest struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

DescribePipelineOptions provides metadata about the options supported by a runner. It will be used by the SDK client to validate the options specified by or list available options to the user. Throws error GRPC_STATUS_UNAVAILABLE if server is down

func (*DescribePipelineOptionsRequest) Descriptor Uses

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

func (*DescribePipelineOptionsRequest) ProtoMessage Uses

func (*DescribePipelineOptionsRequest) ProtoMessage()

func (*DescribePipelineOptionsRequest) Reset Uses

func (m *DescribePipelineOptionsRequest) Reset()

func (*DescribePipelineOptionsRequest) String Uses

func (m *DescribePipelineOptionsRequest) String() string

func (*DescribePipelineOptionsRequest) XXX_DiscardUnknown Uses

func (m *DescribePipelineOptionsRequest) XXX_DiscardUnknown()

func (*DescribePipelineOptionsRequest) XXX_Marshal Uses

func (m *DescribePipelineOptionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribePipelineOptionsRequest) XXX_Merge Uses

func (m *DescribePipelineOptionsRequest) XXX_Merge(src proto.Message)

func (*DescribePipelineOptionsRequest) XXX_Size Uses

func (m *DescribePipelineOptionsRequest) XXX_Size() int

func (*DescribePipelineOptionsRequest) XXX_Unmarshal Uses

func (m *DescribePipelineOptionsRequest) XXX_Unmarshal(b []byte) error

type DescribePipelineOptionsResponse Uses

type DescribePipelineOptionsResponse struct {
    // List of pipeline option descriptors.
    Options              []*PipelineOptionDescriptor `protobuf:"bytes,1,rep,name=options,proto3" json:"options,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
    XXX_unrecognized     []byte                      `json:"-"`
    XXX_sizecache        int32                       `json:"-"`
}

func (*DescribePipelineOptionsResponse) Descriptor Uses

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

func (*DescribePipelineOptionsResponse) GetOptions Uses

func (m *DescribePipelineOptionsResponse) GetOptions() []*PipelineOptionDescriptor

func (*DescribePipelineOptionsResponse) ProtoMessage Uses

func (*DescribePipelineOptionsResponse) ProtoMessage()

func (*DescribePipelineOptionsResponse) Reset Uses

func (m *DescribePipelineOptionsResponse) Reset()

func (*DescribePipelineOptionsResponse) String Uses

func (m *DescribePipelineOptionsResponse) String() string

func (*DescribePipelineOptionsResponse) XXX_DiscardUnknown Uses

func (m *DescribePipelineOptionsResponse) XXX_DiscardUnknown()

func (*DescribePipelineOptionsResponse) XXX_Marshal Uses

func (m *DescribePipelineOptionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribePipelineOptionsResponse) XXX_Merge Uses

func (m *DescribePipelineOptionsResponse) XXX_Merge(src proto.Message)

func (*DescribePipelineOptionsResponse) XXX_Size Uses

func (m *DescribePipelineOptionsResponse) XXX_Size() int

func (*DescribePipelineOptionsResponse) XXX_Unmarshal Uses

func (m *DescribePipelineOptionsResponse) XXX_Unmarshal(b []byte) error

type ExpansionRequest Uses

type ExpansionRequest struct {
    // Set of components needed to interpret the transform, or which
    // may be useful for its expansion.  This includes the input
    // PCollections (if any) to the to-be-expanded transform, along
    // with their coders and windowing strategies.
    Components *pipeline_v1.Components `protobuf:"bytes,1,opt,name=components,proto3" json:"components,omitempty"`
    // The actual PTransform to be expaneded according to its spec.
    // Its input should be set, but its subtransforms and outputs
    // should not be.
    Transform *pipeline_v1.PTransform `protobuf:"bytes,2,opt,name=transform,proto3" json:"transform,omitempty"`
    // A namespace (prefix) to use for the id of any newly created
    // components.
    Namespace            string   `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ExpansionRequest) Descriptor Uses

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

func (*ExpansionRequest) GetComponents Uses

func (m *ExpansionRequest) GetComponents() *pipeline_v1.Components

func (*ExpansionRequest) GetNamespace Uses

func (m *ExpansionRequest) GetNamespace() string

func (*ExpansionRequest) GetTransform Uses

func (m *ExpansionRequest) GetTransform() *pipeline_v1.PTransform

func (*ExpansionRequest) ProtoMessage Uses

func (*ExpansionRequest) ProtoMessage()

func (*ExpansionRequest) Reset Uses

func (m *ExpansionRequest) Reset()

func (*ExpansionRequest) String Uses

func (m *ExpansionRequest) String() string

func (*ExpansionRequest) XXX_DiscardUnknown Uses

func (m *ExpansionRequest) XXX_DiscardUnknown()

func (*ExpansionRequest) XXX_Marshal Uses

func (m *ExpansionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExpansionRequest) XXX_Merge Uses

func (m *ExpansionRequest) XXX_Merge(src proto.Message)

func (*ExpansionRequest) XXX_Size Uses

func (m *ExpansionRequest) XXX_Size() int

func (*ExpansionRequest) XXX_Unmarshal Uses

func (m *ExpansionRequest) XXX_Unmarshal(b []byte) error

type ExpansionResponse Uses

type ExpansionResponse struct {
    // Set of components needed to execute the expanded transform,
    // including the (original) inputs, outputs, and subtransforms.
    Components *pipeline_v1.Components `protobuf:"bytes,1,opt,name=components,proto3" json:"components,omitempty"`
    // The expanded transform itself, with references to its outputs
    // and subtransforms.
    Transform *pipeline_v1.PTransform `protobuf:"bytes,2,opt,name=transform,proto3" json:"transform,omitempty"`
    // A set of requirements that must be appended to this pipeline's
    // requirements.
    Requirements []string `protobuf:"bytes,3,rep,name=requirements,proto3" json:"requirements,omitempty"`
    // (Optional) An string representation of any error encountered while
    // attempting to expand this transform.
    Error                string   `protobuf:"bytes,10,opt,name=error,proto3" json:"error,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ExpansionResponse) Descriptor Uses

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

func (*ExpansionResponse) GetComponents Uses

func (m *ExpansionResponse) GetComponents() *pipeline_v1.Components

func (*ExpansionResponse) GetError Uses

func (m *ExpansionResponse) GetError() string

func (*ExpansionResponse) GetRequirements Uses

func (m *ExpansionResponse) GetRequirements() []string

func (*ExpansionResponse) GetTransform Uses

func (m *ExpansionResponse) GetTransform() *pipeline_v1.PTransform

func (*ExpansionResponse) ProtoMessage Uses

func (*ExpansionResponse) ProtoMessage()

func (*ExpansionResponse) Reset Uses

func (m *ExpansionResponse) Reset()

func (*ExpansionResponse) String Uses

func (m *ExpansionResponse) String() string

func (*ExpansionResponse) XXX_DiscardUnknown Uses

func (m *ExpansionResponse) XXX_DiscardUnknown()

func (*ExpansionResponse) XXX_Marshal Uses

func (m *ExpansionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExpansionResponse) XXX_Merge Uses

func (m *ExpansionResponse) XXX_Merge(src proto.Message)

func (*ExpansionResponse) XXX_Size Uses

func (m *ExpansionResponse) XXX_Size() int

func (*ExpansionResponse) XXX_Unmarshal Uses

func (m *ExpansionResponse) XXX_Unmarshal(b []byte) error

type ExpansionServiceClient Uses

type ExpansionServiceClient interface {
    Expand(ctx context.Context, in *ExpansionRequest, opts ...grpc.CallOption) (*ExpansionResponse, error)
}

ExpansionServiceClient is the client API for ExpansionService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewExpansionServiceClient Uses

func NewExpansionServiceClient(cc *grpc.ClientConn) ExpansionServiceClient

type ExpansionServiceServer Uses

type ExpansionServiceServer interface {
    Expand(context.Context, *ExpansionRequest) (*ExpansionResponse, error)
}

ExpansionServiceServer is the server API for ExpansionService service.

type GetArtifactRequest Uses

type GetArtifactRequest struct {
    Artifact             *pipeline_v1.ArtifactInformation `protobuf:"bytes,1,opt,name=artifact,proto3" json:"artifact,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
    XXX_unrecognized     []byte                           `json:"-"`
    XXX_sizecache        int32                            `json:"-"`
}

A request to get an artifact.

func (*GetArtifactRequest) Descriptor Uses

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

func (*GetArtifactRequest) GetArtifact Uses

func (m *GetArtifactRequest) GetArtifact() *pipeline_v1.ArtifactInformation

func (*GetArtifactRequest) ProtoMessage Uses

func (*GetArtifactRequest) ProtoMessage()

func (*GetArtifactRequest) Reset Uses

func (m *GetArtifactRequest) Reset()

func (*GetArtifactRequest) String Uses

func (m *GetArtifactRequest) String() string

func (*GetArtifactRequest) XXX_DiscardUnknown Uses

func (m *GetArtifactRequest) XXX_DiscardUnknown()

func (*GetArtifactRequest) XXX_Marshal Uses

func (m *GetArtifactRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetArtifactRequest) XXX_Merge Uses

func (m *GetArtifactRequest) XXX_Merge(src proto.Message)

func (*GetArtifactRequest) XXX_Size Uses

func (m *GetArtifactRequest) XXX_Size() int

func (*GetArtifactRequest) XXX_Unmarshal Uses

func (m *GetArtifactRequest) XXX_Unmarshal(b []byte) error

type GetArtifactResponse Uses

type GetArtifactResponse struct {
    Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Part of a response to getting an artifact.

func (*GetArtifactResponse) Descriptor Uses

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

func (*GetArtifactResponse) GetData Uses

func (m *GetArtifactResponse) GetData() []byte

func (*GetArtifactResponse) ProtoMessage Uses

func (*GetArtifactResponse) ProtoMessage()

func (*GetArtifactResponse) Reset Uses

func (m *GetArtifactResponse) Reset()

func (*GetArtifactResponse) String Uses

func (m *GetArtifactResponse) String() string

func (*GetArtifactResponse) XXX_DiscardUnknown Uses

func (m *GetArtifactResponse) XXX_DiscardUnknown()

func (*GetArtifactResponse) XXX_Marshal Uses

func (m *GetArtifactResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetArtifactResponse) XXX_Merge Uses

func (m *GetArtifactResponse) XXX_Merge(src proto.Message)

func (*GetArtifactResponse) XXX_Size Uses

func (m *GetArtifactResponse) XXX_Size() int

func (*GetArtifactResponse) XXX_Unmarshal Uses

func (m *GetArtifactResponse) XXX_Unmarshal(b []byte) error

type GetJobMetricsRequest Uses

type GetJobMetricsRequest struct {
    JobId                string   `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*GetJobMetricsRequest) Descriptor Uses

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

func (*GetJobMetricsRequest) GetJobId Uses

func (m *GetJobMetricsRequest) GetJobId() string

func (*GetJobMetricsRequest) ProtoMessage Uses

func (*GetJobMetricsRequest) ProtoMessage()

func (*GetJobMetricsRequest) Reset Uses

func (m *GetJobMetricsRequest) Reset()

func (*GetJobMetricsRequest) String Uses

func (m *GetJobMetricsRequest) String() string

func (*GetJobMetricsRequest) XXX_DiscardUnknown Uses

func (m *GetJobMetricsRequest) XXX_DiscardUnknown()

func (*GetJobMetricsRequest) XXX_Marshal Uses

func (m *GetJobMetricsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetJobMetricsRequest) XXX_Merge Uses

func (m *GetJobMetricsRequest) XXX_Merge(src proto.Message)

func (*GetJobMetricsRequest) XXX_Size Uses

func (m *GetJobMetricsRequest) XXX_Size() int

func (*GetJobMetricsRequest) XXX_Unmarshal Uses

func (m *GetJobMetricsRequest) XXX_Unmarshal(b []byte) error

type GetJobMetricsResponse Uses

type GetJobMetricsResponse struct {
    Metrics              *MetricResults `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"`
    XXX_NoUnkeyedLiteral struct{}       `json:"-"`
    XXX_unrecognized     []byte         `json:"-"`
    XXX_sizecache        int32          `json:"-"`
}

func (*GetJobMetricsResponse) Descriptor Uses

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

func (*GetJobMetricsResponse) GetMetrics Uses

func (m *GetJobMetricsResponse) GetMetrics() *MetricResults

func (*GetJobMetricsResponse) ProtoMessage Uses

func (*GetJobMetricsResponse) ProtoMessage()

func (*GetJobMetricsResponse) Reset Uses

func (m *GetJobMetricsResponse) Reset()

func (*GetJobMetricsResponse) String Uses

func (m *GetJobMetricsResponse) String() string

func (*GetJobMetricsResponse) XXX_DiscardUnknown Uses

func (m *GetJobMetricsResponse) XXX_DiscardUnknown()

func (*GetJobMetricsResponse) XXX_Marshal Uses

func (m *GetJobMetricsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetJobMetricsResponse) XXX_Merge Uses

func (m *GetJobMetricsResponse) XXX_Merge(src proto.Message)

func (*GetJobMetricsResponse) XXX_Size Uses

func (m *GetJobMetricsResponse) XXX_Size() int

func (*GetJobMetricsResponse) XXX_Unmarshal Uses

func (m *GetJobMetricsResponse) XXX_Unmarshal(b []byte) error

type GetJobPipelineRequest Uses

type GetJobPipelineRequest struct {
    JobId                string   `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

GetPipeline is a synchronus request that returns a pipeline back Throws error GRPC_STATUS_UNAVAILABLE if server is down Throws error NOT_FOUND if the jobId is not found

func (*GetJobPipelineRequest) Descriptor Uses

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

func (*GetJobPipelineRequest) GetJobId Uses

func (m *GetJobPipelineRequest) GetJobId() string

func (*GetJobPipelineRequest) ProtoMessage Uses

func (*GetJobPipelineRequest) ProtoMessage()

func (*GetJobPipelineRequest) Reset Uses

func (m *GetJobPipelineRequest) Reset()

func (*GetJobPipelineRequest) String Uses

func (m *GetJobPipelineRequest) String() string

func (*GetJobPipelineRequest) XXX_DiscardUnknown Uses

func (m *GetJobPipelineRequest) XXX_DiscardUnknown()

func (*GetJobPipelineRequest) XXX_Marshal Uses

func (m *GetJobPipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetJobPipelineRequest) XXX_Merge Uses

func (m *GetJobPipelineRequest) XXX_Merge(src proto.Message)

func (*GetJobPipelineRequest) XXX_Size Uses

func (m *GetJobPipelineRequest) XXX_Size() int

func (*GetJobPipelineRequest) XXX_Unmarshal Uses

func (m *GetJobPipelineRequest) XXX_Unmarshal(b []byte) error

type GetJobPipelineResponse Uses

type GetJobPipelineResponse struct {
    Pipeline             *pipeline_v1.Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
    XXX_NoUnkeyedLiteral struct{}              `json:"-"`
    XXX_unrecognized     []byte                `json:"-"`
    XXX_sizecache        int32                 `json:"-"`
}

func (*GetJobPipelineResponse) Descriptor Uses

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

func (*GetJobPipelineResponse) GetPipeline Uses

func (m *GetJobPipelineResponse) GetPipeline() *pipeline_v1.Pipeline

func (*GetJobPipelineResponse) ProtoMessage Uses

func (*GetJobPipelineResponse) ProtoMessage()

func (*GetJobPipelineResponse) Reset Uses

func (m *GetJobPipelineResponse) Reset()

func (*GetJobPipelineResponse) String Uses

func (m *GetJobPipelineResponse) String() string

func (*GetJobPipelineResponse) XXX_DiscardUnknown Uses

func (m *GetJobPipelineResponse) XXX_DiscardUnknown()

func (*GetJobPipelineResponse) XXX_Marshal Uses

func (m *GetJobPipelineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetJobPipelineResponse) XXX_Merge Uses

func (m *GetJobPipelineResponse) XXX_Merge(src proto.Message)

func (*GetJobPipelineResponse) XXX_Size Uses

func (m *GetJobPipelineResponse) XXX_Size() int

func (*GetJobPipelineResponse) XXX_Unmarshal Uses

func (m *GetJobPipelineResponse) XXX_Unmarshal(b []byte) error

type GetJobStateRequest Uses

type GetJobStateRequest struct {
    JobId                string   `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

GetState is a synchronus request that returns a job state back Throws error GRPC_STATUS_UNAVAILABLE if server is down Throws error NOT_FOUND if the jobId is not found

func (*GetJobStateRequest) Descriptor Uses

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

func (*GetJobStateRequest) GetJobId Uses

func (m *GetJobStateRequest) GetJobId() string

func (*GetJobStateRequest) ProtoMessage Uses

func (*GetJobStateRequest) ProtoMessage()

func (*GetJobStateRequest) Reset Uses

func (m *GetJobStateRequest) Reset()

func (*GetJobStateRequest) String Uses

func (m *GetJobStateRequest) String() string

func (*GetJobStateRequest) XXX_DiscardUnknown Uses

func (m *GetJobStateRequest) XXX_DiscardUnknown()

func (*GetJobStateRequest) XXX_Marshal Uses

func (m *GetJobStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetJobStateRequest) XXX_Merge Uses

func (m *GetJobStateRequest) XXX_Merge(src proto.Message)

func (*GetJobStateRequest) XXX_Size Uses

func (m *GetJobStateRequest) XXX_Size() int

func (*GetJobStateRequest) XXX_Unmarshal Uses

func (m *GetJobStateRequest) XXX_Unmarshal(b []byte) error

type GetJobsRequest Uses

type GetJobsRequest struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

GetJobs is a synchronus request that returns a list of invoked jobs back Throws error GRPC_STATUS_UNAVAILABLE if server is down

func (*GetJobsRequest) Descriptor Uses

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

func (*GetJobsRequest) ProtoMessage Uses

func (*GetJobsRequest) ProtoMessage()

func (*GetJobsRequest) Reset Uses

func (m *GetJobsRequest) Reset()

func (*GetJobsRequest) String Uses

func (m *GetJobsRequest) String() string

func (*GetJobsRequest) XXX_DiscardUnknown Uses

func (m *GetJobsRequest) XXX_DiscardUnknown()

func (*GetJobsRequest) XXX_Marshal Uses

func (m *GetJobsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetJobsRequest) XXX_Merge Uses

func (m *GetJobsRequest) XXX_Merge(src proto.Message)

func (*GetJobsRequest) XXX_Size Uses

func (m *GetJobsRequest) XXX_Size() int

func (*GetJobsRequest) XXX_Unmarshal Uses

func (m *GetJobsRequest) XXX_Unmarshal(b []byte) error

type GetJobsResponse Uses

type GetJobsResponse struct {
    JobInfo              []*JobInfo `protobuf:"bytes,1,rep,name=job_info,json=jobInfo,proto3" json:"job_info,omitempty"`
    XXX_NoUnkeyedLiteral struct{}   `json:"-"`
    XXX_unrecognized     []byte     `json:"-"`
    XXX_sizecache        int32      `json:"-"`
}

func (*GetJobsResponse) Descriptor Uses

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

func (*GetJobsResponse) GetJobInfo Uses

func (m *GetJobsResponse) GetJobInfo() []*JobInfo

func (*GetJobsResponse) ProtoMessage Uses

func (*GetJobsResponse) ProtoMessage()

func (*GetJobsResponse) Reset Uses

func (m *GetJobsResponse) Reset()

func (*GetJobsResponse) String Uses

func (m *GetJobsResponse) String() string

func (*GetJobsResponse) XXX_DiscardUnknown Uses

func (m *GetJobsResponse) XXX_DiscardUnknown()

func (*GetJobsResponse) XXX_Marshal Uses

func (m *GetJobsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetJobsResponse) XXX_Merge Uses

func (m *GetJobsResponse) XXX_Merge(src proto.Message)

func (*GetJobsResponse) XXX_Size Uses

func (m *GetJobsResponse) XXX_Size() int

func (*GetJobsResponse) XXX_Unmarshal Uses

func (m *GetJobsResponse) XXX_Unmarshal(b []byte) error

type GetManifestRequest Uses

type GetManifestRequest struct {
    // (Required) An opaque token representing the entirety of the staged artifacts.
    // Returned in CommitManifestResponse.
    RetrievalToken       string   `protobuf:"bytes,1,opt,name=retrieval_token,json=retrievalToken,proto3" json:"retrieval_token,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A request to get the manifest of a Job.

func (*GetManifestRequest) Descriptor Uses

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

func (*GetManifestRequest) GetRetrievalToken Uses

func (m *GetManifestRequest) GetRetrievalToken() string

func (*GetManifestRequest) ProtoMessage Uses

func (*GetManifestRequest) ProtoMessage()

func (*GetManifestRequest) Reset Uses

func (m *GetManifestRequest) Reset()

func (*GetManifestRequest) String Uses

func (m *GetManifestRequest) String() string

func (*GetManifestRequest) XXX_DiscardUnknown Uses

func (m *GetManifestRequest) XXX_DiscardUnknown()

func (*GetManifestRequest) XXX_Marshal Uses

func (m *GetManifestRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetManifestRequest) XXX_Merge Uses

func (m *GetManifestRequest) XXX_Merge(src proto.Message)

func (*GetManifestRequest) XXX_Size Uses

func (m *GetManifestRequest) XXX_Size() int

func (*GetManifestRequest) XXX_Unmarshal Uses

func (m *GetManifestRequest) XXX_Unmarshal(b []byte) error

type GetManifestResponse Uses

type GetManifestResponse struct {
    Manifest             *Manifest `protobuf:"bytes,1,opt,name=manifest,proto3" json:"manifest,omitempty"`
    XXX_NoUnkeyedLiteral struct{}  `json:"-"`
    XXX_unrecognized     []byte    `json:"-"`
    XXX_sizecache        int32     `json:"-"`
}

A response containing a job manifest.

func (*GetManifestResponse) Descriptor Uses

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

func (*GetManifestResponse) GetManifest Uses

func (m *GetManifestResponse) GetManifest() *Manifest

func (*GetManifestResponse) ProtoMessage Uses

func (*GetManifestResponse) ProtoMessage()

func (*GetManifestResponse) Reset Uses

func (m *GetManifestResponse) Reset()

func (*GetManifestResponse) String Uses

func (m *GetManifestResponse) String() string

func (*GetManifestResponse) XXX_DiscardUnknown Uses

func (m *GetManifestResponse) XXX_DiscardUnknown()

func (*GetManifestResponse) XXX_Marshal Uses

func (m *GetManifestResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetManifestResponse) XXX_Merge Uses

func (m *GetManifestResponse) XXX_Merge(src proto.Message)

func (*GetManifestResponse) XXX_Size Uses

func (m *GetManifestResponse) XXX_Size() int

func (*GetManifestResponse) XXX_Unmarshal Uses

func (m *GetManifestResponse) XXX_Unmarshal(b []byte) error

type JobInfo Uses

type JobInfo struct {
    JobId                string          `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
    JobName              string          `protobuf:"bytes,2,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
    PipelineOptions      *_struct.Struct `protobuf:"bytes,3,opt,name=pipeline_options,json=pipelineOptions,proto3" json:"pipeline_options,omitempty"`
    State                JobState_Enum   `protobuf:"varint,4,opt,name=state,proto3,enum=org.apache.beam.model.job_management.v1.JobState_Enum" json:"state,omitempty"`
    XXX_NoUnkeyedLiteral struct{}        `json:"-"`
    XXX_unrecognized     []byte          `json:"-"`
    XXX_sizecache        int32           `json:"-"`
}

A subset of info provided by ProvisionApi.ProvisionInfo

func (*JobInfo) Descriptor Uses

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

func (*JobInfo) GetJobId Uses

func (m *JobInfo) GetJobId() string

func (*JobInfo) GetJobName Uses

func (m *JobInfo) GetJobName() string

func (*JobInfo) GetPipelineOptions Uses

func (m *JobInfo) GetPipelineOptions() *_struct.Struct

func (*JobInfo) GetState Uses

func (m *JobInfo) GetState() JobState_Enum

func (*JobInfo) ProtoMessage Uses

func (*JobInfo) ProtoMessage()

func (*JobInfo) Reset Uses

func (m *JobInfo) Reset()

func (*JobInfo) String Uses

func (m *JobInfo) String() string

func (*JobInfo) XXX_DiscardUnknown Uses

func (m *JobInfo) XXX_DiscardUnknown()

func (*JobInfo) XXX_Marshal Uses

func (m *JobInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobInfo) XXX_Merge Uses

func (m *JobInfo) XXX_Merge(src proto.Message)

func (*JobInfo) XXX_Size Uses

func (m *JobInfo) XXX_Size() int

func (*JobInfo) XXX_Unmarshal Uses

func (m *JobInfo) XXX_Unmarshal(b []byte) error

type JobMessage Uses

type JobMessage struct {
    MessageId            string                       `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
    Time                 string                       `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
    Importance           JobMessage_MessageImportance `protobuf:"varint,3,opt,name=importance,proto3,enum=org.apache.beam.model.job_management.v1.JobMessage_MessageImportance" json:"importance,omitempty"`
    MessageText          string                       `protobuf:"bytes,4,opt,name=message_text,json=messageText,proto3" json:"message_text,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
    XXX_unrecognized     []byte                       `json:"-"`
    XXX_sizecache        int32                        `json:"-"`
}

func (*JobMessage) Descriptor Uses

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

func (*JobMessage) GetImportance Uses

func (m *JobMessage) GetImportance() JobMessage_MessageImportance

func (*JobMessage) GetMessageId Uses

func (m *JobMessage) GetMessageId() string

func (*JobMessage) GetMessageText Uses

func (m *JobMessage) GetMessageText() string

func (*JobMessage) GetTime Uses

func (m *JobMessage) GetTime() string

func (*JobMessage) ProtoMessage Uses

func (*JobMessage) ProtoMessage()

func (*JobMessage) Reset Uses

func (m *JobMessage) Reset()

func (*JobMessage) String Uses

func (m *JobMessage) String() string

func (*JobMessage) XXX_DiscardUnknown Uses

func (m *JobMessage) XXX_DiscardUnknown()

func (*JobMessage) XXX_Marshal Uses

func (m *JobMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobMessage) XXX_Merge Uses

func (m *JobMessage) XXX_Merge(src proto.Message)

func (*JobMessage) XXX_Size Uses

func (m *JobMessage) XXX_Size() int

func (*JobMessage) XXX_Unmarshal Uses

func (m *JobMessage) XXX_Unmarshal(b []byte) error

type JobMessage_MessageImportance Uses

type JobMessage_MessageImportance int32
const (
    JobMessage_MESSAGE_IMPORTANCE_UNSPECIFIED JobMessage_MessageImportance = 0
    JobMessage_JOB_MESSAGE_DEBUG              JobMessage_MessageImportance = 1
    JobMessage_JOB_MESSAGE_DETAILED           JobMessage_MessageImportance = 2
    JobMessage_JOB_MESSAGE_BASIC              JobMessage_MessageImportance = 3
    JobMessage_JOB_MESSAGE_WARNING            JobMessage_MessageImportance = 4
    JobMessage_JOB_MESSAGE_ERROR              JobMessage_MessageImportance = 5
)

func (JobMessage_MessageImportance) EnumDescriptor Uses

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

func (JobMessage_MessageImportance) String Uses

func (x JobMessage_MessageImportance) String() string

type JobMessagesRequest Uses

type JobMessagesRequest struct {
    JobId                string   `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

GetJobMessages is a streaming api for streaming job messages from the service One request will connect you to the job and you'll get a stream of job state and job messages back; one is used for logging and the other for detecting the job ended.

func (*JobMessagesRequest) Descriptor Uses

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

func (*JobMessagesRequest) GetJobId Uses

func (m *JobMessagesRequest) GetJobId() string

func (*JobMessagesRequest) ProtoMessage Uses

func (*JobMessagesRequest) ProtoMessage()

func (*JobMessagesRequest) Reset Uses

func (m *JobMessagesRequest) Reset()

func (*JobMessagesRequest) String Uses

func (m *JobMessagesRequest) String() string

func (*JobMessagesRequest) XXX_DiscardUnknown Uses

func (m *JobMessagesRequest) XXX_DiscardUnknown()

func (*JobMessagesRequest) XXX_Marshal Uses

func (m *JobMessagesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobMessagesRequest) XXX_Merge Uses

func (m *JobMessagesRequest) XXX_Merge(src proto.Message)

func (*JobMessagesRequest) XXX_Size Uses

func (m *JobMessagesRequest) XXX_Size() int

func (*JobMessagesRequest) XXX_Unmarshal Uses

func (m *JobMessagesRequest) XXX_Unmarshal(b []byte) error

type JobMessagesResponse Uses

type JobMessagesResponse struct {
    // Types that are valid to be assigned to Response:
    //	*JobMessagesResponse_MessageResponse
    //	*JobMessagesResponse_StateResponse
    Response             isJobMessagesResponse_Response `protobuf_oneof:"response"`
    XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
    XXX_unrecognized     []byte                         `json:"-"`
    XXX_sizecache        int32                          `json:"-"`
}

func (*JobMessagesResponse) Descriptor Uses

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

func (*JobMessagesResponse) GetMessageResponse Uses

func (m *JobMessagesResponse) GetMessageResponse() *JobMessage

func (*JobMessagesResponse) GetResponse Uses

func (m *JobMessagesResponse) GetResponse() isJobMessagesResponse_Response

func (*JobMessagesResponse) GetStateResponse Uses

func (m *JobMessagesResponse) GetStateResponse() *JobStateEvent

func (*JobMessagesResponse) ProtoMessage Uses

func (*JobMessagesResponse) ProtoMessage()

func (*JobMessagesResponse) Reset Uses

func (m *JobMessagesResponse) Reset()

func (*JobMessagesResponse) String Uses

func (m *JobMessagesResponse) String() string

func (*JobMessagesResponse) XXX_DiscardUnknown Uses

func (m *JobMessagesResponse) XXX_DiscardUnknown()

func (*JobMessagesResponse) XXX_Marshal Uses

func (m *JobMessagesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobMessagesResponse) XXX_Merge Uses

func (m *JobMessagesResponse) XXX_Merge(src proto.Message)

func (*JobMessagesResponse) XXX_OneofWrappers Uses

func (*JobMessagesResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*JobMessagesResponse) XXX_Size Uses

func (m *JobMessagesResponse) XXX_Size() int

func (*JobMessagesResponse) XXX_Unmarshal Uses

func (m *JobMessagesResponse) XXX_Unmarshal(b []byte) error

type JobMessagesResponse_MessageResponse Uses

type JobMessagesResponse_MessageResponse struct {
    MessageResponse *JobMessage `protobuf:"bytes,1,opt,name=message_response,json=messageResponse,proto3,oneof"`
}

type JobMessagesResponse_StateResponse Uses

type JobMessagesResponse_StateResponse struct {
    StateResponse *JobStateEvent `protobuf:"bytes,2,opt,name=state_response,json=stateResponse,proto3,oneof"`
}

type JobServiceClient Uses

type JobServiceClient interface {
    // Prepare a job for execution. The job will not be executed until a call is made to run with the
    // returned preparationId.
    Prepare(ctx context.Context, in *PrepareJobRequest, opts ...grpc.CallOption) (*PrepareJobResponse, error)
    // Submit the job for execution
    Run(ctx context.Context, in *RunJobRequest, opts ...grpc.CallOption) (*RunJobResponse, error)
    // Get a list of all invoked jobs
    GetJobs(ctx context.Context, in *GetJobsRequest, opts ...grpc.CallOption) (*GetJobsResponse, error)
    // Get the current state of the job
    GetState(ctx context.Context, in *GetJobStateRequest, opts ...grpc.CallOption) (*JobStateEvent, error)
    // Get the job's pipeline
    GetPipeline(ctx context.Context, in *GetJobPipelineRequest, opts ...grpc.CallOption) (*GetJobPipelineResponse, error)
    // Cancel the job
    Cancel(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*CancelJobResponse, error)
    // Subscribe to a stream of state changes of the job, will immediately return the current state of the job as the first response.
    GetStateStream(ctx context.Context, in *GetJobStateRequest, opts ...grpc.CallOption) (JobService_GetStateStreamClient, error)
    // Subscribe to a stream of state changes and messages from the job
    GetMessageStream(ctx context.Context, in *JobMessagesRequest, opts ...grpc.CallOption) (JobService_GetMessageStreamClient, error)
    // Fetch metrics for a given job
    GetJobMetrics(ctx context.Context, in *GetJobMetricsRequest, opts ...grpc.CallOption) (*GetJobMetricsResponse, error)
    // Get the supported pipeline options of the runner
    DescribePipelineOptions(ctx context.Context, in *DescribePipelineOptionsRequest, opts ...grpc.CallOption) (*DescribePipelineOptionsResponse, error)
}

JobServiceClient is the client API for JobService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewJobServiceClient Uses

func NewJobServiceClient(cc *grpc.ClientConn) JobServiceClient

type JobServiceServer Uses

type JobServiceServer interface {
    // Prepare a job for execution. The job will not be executed until a call is made to run with the
    // returned preparationId.
    Prepare(context.Context, *PrepareJobRequest) (*PrepareJobResponse, error)
    // Submit the job for execution
    Run(context.Context, *RunJobRequest) (*RunJobResponse, error)
    // Get a list of all invoked jobs
    GetJobs(context.Context, *GetJobsRequest) (*GetJobsResponse, error)
    // Get the current state of the job
    GetState(context.Context, *GetJobStateRequest) (*JobStateEvent, error)
    // Get the job's pipeline
    GetPipeline(context.Context, *GetJobPipelineRequest) (*GetJobPipelineResponse, error)
    // Cancel the job
    Cancel(context.Context, *CancelJobRequest) (*CancelJobResponse, error)
    // Subscribe to a stream of state changes of the job, will immediately return the current state of the job as the first response.
    GetStateStream(*GetJobStateRequest, JobService_GetStateStreamServer) error
    // Subscribe to a stream of state changes and messages from the job
    GetMessageStream(*JobMessagesRequest, JobService_GetMessageStreamServer) error
    // Fetch metrics for a given job
    GetJobMetrics(context.Context, *GetJobMetricsRequest) (*GetJobMetricsResponse, error)
    // Get the supported pipeline options of the runner
    DescribePipelineOptions(context.Context, *DescribePipelineOptionsRequest) (*DescribePipelineOptionsResponse, error)
}

JobServiceServer is the server API for JobService service.

type JobService_GetMessageStreamClient Uses

type JobService_GetMessageStreamClient interface {
    Recv() (*JobMessagesResponse, error)
    grpc.ClientStream
}

type JobService_GetMessageStreamServer Uses

type JobService_GetMessageStreamServer interface {
    Send(*JobMessagesResponse) error
    grpc.ServerStream
}

type JobService_GetStateStreamClient Uses

type JobService_GetStateStreamClient interface {
    Recv() (*JobStateEvent, error)
    grpc.ClientStream
}

type JobService_GetStateStreamServer Uses

type JobService_GetStateStreamServer interface {
    Send(*JobStateEvent) error
    grpc.ServerStream
}

type JobState Uses

type JobState struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Enumeration of all JobStates

The state transition diagram is:

STOPPED -> STARTING -> RUNNING -> DONE
                               \> FAILED
                               \> CANCELLING -> CANCELLED
                               \> UPDATING -> UPDATED
                               \> DRAINING -> DRAINED

Transitions are optional such that a job may go from STOPPED to RUNNING without needing to pass through STARTING.

func (*JobState) Descriptor Uses

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

func (*JobState) ProtoMessage Uses

func (*JobState) ProtoMessage()

func (*JobState) Reset Uses

func (m *JobState) Reset()

func (*JobState) String Uses

func (m *JobState) String() string

func (*JobState) XXX_DiscardUnknown Uses

func (m *JobState) XXX_DiscardUnknown()

func (*JobState) XXX_Marshal Uses

func (m *JobState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobState) XXX_Merge Uses

func (m *JobState) XXX_Merge(src proto.Message)

func (*JobState) XXX_Size Uses

func (m *JobState) XXX_Size() int

func (*JobState) XXX_Unmarshal Uses

func (m *JobState) XXX_Unmarshal(b []byte) error

type JobStateEvent Uses

type JobStateEvent struct {
    State                JobState_Enum        `protobuf:"varint,1,opt,name=state,proto3,enum=org.apache.beam.model.job_management.v1.JobState_Enum" json:"state,omitempty"`
    Timestamp            *timestamp.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
    XXX_NoUnkeyedLiteral struct{}             `json:"-"`
    XXX_unrecognized     []byte               `json:"-"`
    XXX_sizecache        int32                `json:"-"`
}

func (*JobStateEvent) Descriptor Uses

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

func (*JobStateEvent) GetState Uses

func (m *JobStateEvent) GetState() JobState_Enum

func (*JobStateEvent) GetTimestamp Uses

func (m *JobStateEvent) GetTimestamp() *timestamp.Timestamp

func (*JobStateEvent) ProtoMessage Uses

func (*JobStateEvent) ProtoMessage()

func (*JobStateEvent) Reset Uses

func (m *JobStateEvent) Reset()

func (*JobStateEvent) String Uses

func (m *JobStateEvent) String() string

func (*JobStateEvent) XXX_DiscardUnknown Uses

func (m *JobStateEvent) XXX_DiscardUnknown()

func (*JobStateEvent) XXX_Marshal Uses

func (m *JobStateEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobStateEvent) XXX_Merge Uses

func (m *JobStateEvent) XXX_Merge(src proto.Message)

func (*JobStateEvent) XXX_Size Uses

func (m *JobStateEvent) XXX_Size() int

func (*JobStateEvent) XXX_Unmarshal Uses

func (m *JobStateEvent) XXX_Unmarshal(b []byte) error

type JobState_Enum Uses

type JobState_Enum int32
const (
    // The job state reported by a runner cannot be interpreted by the SDK.
    JobState_UNSPECIFIED JobState_Enum = 0
    // The job has not yet started.
    JobState_STOPPED JobState_Enum = 1
    // The job is currently running.
    JobState_RUNNING JobState_Enum = 2
    // The job has successfully completed. (terminal)
    JobState_DONE JobState_Enum = 3
    // The job has failed. (terminal)
    JobState_FAILED JobState_Enum = 4
    // The job has been explicitly cancelled. (terminal)
    JobState_CANCELLED JobState_Enum = 5
    // The job has been updated. (terminal)
    JobState_UPDATED JobState_Enum = 6
    // The job is draining its data. (optional)
    JobState_DRAINING JobState_Enum = 7
    // The job has completed draining its data. (terminal)
    JobState_DRAINED JobState_Enum = 8
    // The job is starting up.
    JobState_STARTING JobState_Enum = 9
    // The job is cancelling. (optional)
    JobState_CANCELLING JobState_Enum = 10
    // The job is in the process of being updated. (optional)
    JobState_UPDATING JobState_Enum = 11
)

func (JobState_Enum) EnumDescriptor Uses

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

func (JobState_Enum) String Uses

func (x JobState_Enum) String() string

type LegacyArtifactRetrievalServiceClient Uses

type LegacyArtifactRetrievalServiceClient interface {
    // Get the manifest for the job
    GetManifest(ctx context.Context, in *GetManifestRequest, opts ...grpc.CallOption) (*GetManifestResponse, error)
    // Get an artifact staged for the job. The requested artifact must be within the manifest
    GetArtifact(ctx context.Context, in *LegacyGetArtifactRequest, opts ...grpc.CallOption) (LegacyArtifactRetrievalService_GetArtifactClient, error)
}

LegacyArtifactRetrievalServiceClient is the client API for LegacyArtifactRetrievalService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewLegacyArtifactRetrievalServiceClient Uses

func NewLegacyArtifactRetrievalServiceClient(cc *grpc.ClientConn) LegacyArtifactRetrievalServiceClient

type LegacyArtifactRetrievalServiceServer Uses

type LegacyArtifactRetrievalServiceServer interface {
    // Get the manifest for the job
    GetManifest(context.Context, *GetManifestRequest) (*GetManifestResponse, error)
    // Get an artifact staged for the job. The requested artifact must be within the manifest
    GetArtifact(*LegacyGetArtifactRequest, LegacyArtifactRetrievalService_GetArtifactServer) error
}

LegacyArtifactRetrievalServiceServer is the server API for LegacyArtifactRetrievalService service.

type LegacyArtifactRetrievalService_GetArtifactClient Uses

type LegacyArtifactRetrievalService_GetArtifactClient interface {
    Recv() (*ArtifactChunk, error)
    grpc.ClientStream
}

type LegacyArtifactRetrievalService_GetArtifactServer Uses

type LegacyArtifactRetrievalService_GetArtifactServer interface {
    Send(*ArtifactChunk) error
    grpc.ServerStream
}

type LegacyArtifactStagingServiceClient Uses

type LegacyArtifactStagingServiceClient interface {
    // Stage an artifact to be available during job execution. The first request must contain the
    // name of the artifact. All future requests must contain sequential chunks of the content of
    // the artifact.
    PutArtifact(ctx context.Context, opts ...grpc.CallOption) (LegacyArtifactStagingService_PutArtifactClient, error)
    // Commit the manifest for a Job. All artifacts must have been successfully uploaded
    // before this call is made.
    //
    // Throws error INVALID_ARGUMENT if not all of the members of the manifest are present
    CommitManifest(ctx context.Context, in *CommitManifestRequest, opts ...grpc.CallOption) (*CommitManifestResponse, error)
}

LegacyArtifactStagingServiceClient is the client API for LegacyArtifactStagingService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewLegacyArtifactStagingServiceClient Uses

func NewLegacyArtifactStagingServiceClient(cc *grpc.ClientConn) LegacyArtifactStagingServiceClient

type LegacyArtifactStagingServiceServer Uses

type LegacyArtifactStagingServiceServer interface {
    // Stage an artifact to be available during job execution. The first request must contain the
    // name of the artifact. All future requests must contain sequential chunks of the content of
    // the artifact.
    PutArtifact(LegacyArtifactStagingService_PutArtifactServer) error
    // Commit the manifest for a Job. All artifacts must have been successfully uploaded
    // before this call is made.
    //
    // Throws error INVALID_ARGUMENT if not all of the members of the manifest are present
    CommitManifest(context.Context, *CommitManifestRequest) (*CommitManifestResponse, error)
}

LegacyArtifactStagingServiceServer is the server API for LegacyArtifactStagingService service.

type LegacyArtifactStagingService_PutArtifactClient Uses

type LegacyArtifactStagingService_PutArtifactClient interface {
    Send(*PutArtifactRequest) error
    CloseAndRecv() (*PutArtifactResponse, error)
    grpc.ClientStream
}

type LegacyArtifactStagingService_PutArtifactServer Uses

type LegacyArtifactStagingService_PutArtifactServer interface {
    SendAndClose(*PutArtifactResponse) error
    Recv() (*PutArtifactRequest, error)
    grpc.ServerStream
}

type LegacyGetArtifactRequest Uses

type LegacyGetArtifactRequest struct {
    // (Required) The name of the artifact to retrieve.
    Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // (Required) An opaque token representing the entirety of the staged artifacts.
    // Returned in CommitManifestResponse.
    RetrievalToken       string   `protobuf:"bytes,2,opt,name=retrieval_token,json=retrievalToken,proto3" json:"retrieval_token,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A request to get an artifact. The artifact must be present in the manifest for the job.

func (*LegacyGetArtifactRequest) Descriptor Uses

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

func (*LegacyGetArtifactRequest) GetName Uses

func (m *LegacyGetArtifactRequest) GetName() string

func (*LegacyGetArtifactRequest) GetRetrievalToken Uses

func (m *LegacyGetArtifactRequest) GetRetrievalToken() string

func (*LegacyGetArtifactRequest) ProtoMessage Uses

func (*LegacyGetArtifactRequest) ProtoMessage()

func (*LegacyGetArtifactRequest) Reset Uses

func (m *LegacyGetArtifactRequest) Reset()

func (*LegacyGetArtifactRequest) String Uses

func (m *LegacyGetArtifactRequest) String() string

func (*LegacyGetArtifactRequest) XXX_DiscardUnknown Uses

func (m *LegacyGetArtifactRequest) XXX_DiscardUnknown()

func (*LegacyGetArtifactRequest) XXX_Marshal Uses

func (m *LegacyGetArtifactRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LegacyGetArtifactRequest) XXX_Merge Uses

func (m *LegacyGetArtifactRequest) XXX_Merge(src proto.Message)

func (*LegacyGetArtifactRequest) XXX_Size Uses

func (m *LegacyGetArtifactRequest) XXX_Size() int

func (*LegacyGetArtifactRequest) XXX_Unmarshal Uses

func (m *LegacyGetArtifactRequest) XXX_Unmarshal(b []byte) error

type Manifest Uses

type Manifest struct {
    Artifact             []*ArtifactMetadata `protobuf:"bytes,1,rep,name=artifact,proto3" json:"artifact,omitempty"`
    XXX_NoUnkeyedLiteral struct{}            `json:"-"`
    XXX_unrecognized     []byte              `json:"-"`
    XXX_sizecache        int32               `json:"-"`
}

A collection of artifacts.

func (*Manifest) Descriptor Uses

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

func (*Manifest) GetArtifact Uses

func (m *Manifest) GetArtifact() []*ArtifactMetadata

func (*Manifest) ProtoMessage Uses

func (*Manifest) ProtoMessage()

func (*Manifest) Reset Uses

func (m *Manifest) Reset()

func (*Manifest) String Uses

func (m *Manifest) String() string

func (*Manifest) XXX_DiscardUnknown Uses

func (m *Manifest) XXX_DiscardUnknown()

func (*Manifest) XXX_Marshal Uses

func (m *Manifest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Manifest) XXX_Merge Uses

func (m *Manifest) XXX_Merge(src proto.Message)

func (*Manifest) XXX_Size Uses

func (m *Manifest) XXX_Size() int

func (*Manifest) XXX_Unmarshal Uses

func (m *Manifest) XXX_Unmarshal(b []byte) error

type MetricResults Uses

type MetricResults struct {
    Attempted            []*pipeline_v1.MonitoringInfo `protobuf:"bytes,1,rep,name=attempted,proto3" json:"attempted,omitempty"`
    Committed            []*pipeline_v1.MonitoringInfo `protobuf:"bytes,2,rep,name=committed,proto3" json:"committed,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
    XXX_unrecognized     []byte                        `json:"-"`
    XXX_sizecache        int32                         `json:"-"`
}

All metrics for a given job. Runners may support one or the other or both.

func (*MetricResults) Descriptor Uses

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

func (*MetricResults) GetAttempted Uses

func (m *MetricResults) GetAttempted() []*pipeline_v1.MonitoringInfo

func (*MetricResults) GetCommitted Uses

func (m *MetricResults) GetCommitted() []*pipeline_v1.MonitoringInfo

func (*MetricResults) ProtoMessage Uses

func (*MetricResults) ProtoMessage()

func (*MetricResults) Reset Uses

func (m *MetricResults) Reset()

func (*MetricResults) String Uses

func (m *MetricResults) String() string

func (*MetricResults) XXX_DiscardUnknown Uses

func (m *MetricResults) XXX_DiscardUnknown()

func (*MetricResults) XXX_Marshal Uses

func (m *MetricResults) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricResults) XXX_Merge Uses

func (m *MetricResults) XXX_Merge(src proto.Message)

func (*MetricResults) XXX_Size Uses

func (m *MetricResults) XXX_Size() int

func (*MetricResults) XXX_Unmarshal Uses

func (m *MetricResults) XXX_Unmarshal(b []byte) error

type PipelineOptionDescriptor Uses

type PipelineOptionDescriptor struct {
    // (Required) The option name.
    Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // (Required) Type of option.
    Type PipelineOptionType_Enum `protobuf:"varint,2,opt,name=type,proto3,enum=org.apache.beam.model.job_management.v1.PipelineOptionType_Enum" json:"type,omitempty"`
    // (Optional) Description suitable for display / help text.
    Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
    // (Optional) Default value.
    DefaultValue string `protobuf:"bytes,4,opt,name=default_value,json=defaultValue,proto3" json:"default_value,omitempty"`
    // (Required) The group this option belongs to.
    Group                string   `protobuf:"bytes,5,opt,name=group,proto3" json:"group,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Metadata for a pipeline option.

func (*PipelineOptionDescriptor) Descriptor Uses

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

func (*PipelineOptionDescriptor) GetDefaultValue Uses

func (m *PipelineOptionDescriptor) GetDefaultValue() string

func (*PipelineOptionDescriptor) GetDescription Uses

func (m *PipelineOptionDescriptor) GetDescription() string

func (*PipelineOptionDescriptor) GetGroup Uses

func (m *PipelineOptionDescriptor) GetGroup() string

func (*PipelineOptionDescriptor) GetName Uses

func (m *PipelineOptionDescriptor) GetName() string

func (*PipelineOptionDescriptor) GetType Uses

func (m *PipelineOptionDescriptor) GetType() PipelineOptionType_Enum

func (*PipelineOptionDescriptor) ProtoMessage Uses

func (*PipelineOptionDescriptor) ProtoMessage()

func (*PipelineOptionDescriptor) Reset Uses

func (m *PipelineOptionDescriptor) Reset()

func (*PipelineOptionDescriptor) String Uses

func (m *PipelineOptionDescriptor) String() string

func (*PipelineOptionDescriptor) XXX_DiscardUnknown Uses

func (m *PipelineOptionDescriptor) XXX_DiscardUnknown()

func (*PipelineOptionDescriptor) XXX_Marshal Uses

func (m *PipelineOptionDescriptor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PipelineOptionDescriptor) XXX_Merge Uses

func (m *PipelineOptionDescriptor) XXX_Merge(src proto.Message)

func (*PipelineOptionDescriptor) XXX_Size Uses

func (m *PipelineOptionDescriptor) XXX_Size() int

func (*PipelineOptionDescriptor) XXX_Unmarshal Uses

func (m *PipelineOptionDescriptor) XXX_Unmarshal(b []byte) error

type PipelineOptionType Uses

type PipelineOptionType struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Type for pipeline options. Types mirror those of JSON, since that's how pipeline options are serialized.

func (*PipelineOptionType) Descriptor Uses

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

func (*PipelineOptionType) ProtoMessage Uses

func (*PipelineOptionType) ProtoMessage()

func (*PipelineOptionType) Reset Uses

func (m *PipelineOptionType) Reset()

func (*PipelineOptionType) String Uses

func (m *PipelineOptionType) String() string

func (*PipelineOptionType) XXX_DiscardUnknown Uses

func (m *PipelineOptionType) XXX_DiscardUnknown()

func (*PipelineOptionType) XXX_Marshal Uses

func (m *PipelineOptionType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PipelineOptionType) XXX_Merge Uses

func (m *PipelineOptionType) XXX_Merge(src proto.Message)

func (*PipelineOptionType) XXX_Size Uses

func (m *PipelineOptionType) XXX_Size() int

func (*PipelineOptionType) XXX_Unmarshal Uses

func (m *PipelineOptionType) XXX_Unmarshal(b []byte) error

type PipelineOptionType_Enum Uses

type PipelineOptionType_Enum int32
const (
    PipelineOptionType_STRING  PipelineOptionType_Enum = 0
    PipelineOptionType_BOOLEAN PipelineOptionType_Enum = 1
    // whole numbers, see https://json-schema.org/understanding-json-schema/reference/numeric.html
    PipelineOptionType_INTEGER PipelineOptionType_Enum = 2
    PipelineOptionType_NUMBER  PipelineOptionType_Enum = 3
    PipelineOptionType_ARRAY   PipelineOptionType_Enum = 4
    PipelineOptionType_OBJECT  PipelineOptionType_Enum = 5
)

func (PipelineOptionType_Enum) EnumDescriptor Uses

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

func (PipelineOptionType_Enum) String Uses

func (x PipelineOptionType_Enum) String() string

type PrepareJobRequest Uses

type PrepareJobRequest struct {
    Pipeline             *pipeline_v1.Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
    PipelineOptions      *_struct.Struct       `protobuf:"bytes,2,opt,name=pipeline_options,json=pipelineOptions,proto3" json:"pipeline_options,omitempty"`
    JobName              string                `protobuf:"bytes,3,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
    XXX_NoUnkeyedLiteral struct{}              `json:"-"`
    XXX_unrecognized     []byte                `json:"-"`
    XXX_sizecache        int32                 `json:"-"`
}

Prepare is a synchronous request that returns a preparationId back Throws error GRPC_STATUS_UNAVAILABLE if server is down Throws error ALREADY_EXISTS if the jobName is reused. Runners are permitted to deduplicate based on the name of the job. Throws error UNKNOWN for all other issues

func (*PrepareJobRequest) Descriptor Uses

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

func (*PrepareJobRequest) GetJobName Uses

func (m *PrepareJobRequest) GetJobName() string

func (*PrepareJobRequest) GetPipeline Uses

func (m *PrepareJobRequest) GetPipeline() *pipeline_v1.Pipeline

func (*PrepareJobRequest) GetPipelineOptions Uses

func (m *PrepareJobRequest) GetPipelineOptions() *_struct.Struct

func (*PrepareJobRequest) ProtoMessage Uses

func (*PrepareJobRequest) ProtoMessage()

func (*PrepareJobRequest) Reset Uses

func (m *PrepareJobRequest) Reset()

func (*PrepareJobRequest) String Uses

func (m *PrepareJobRequest) String() string

func (*PrepareJobRequest) XXX_DiscardUnknown Uses

func (m *PrepareJobRequest) XXX_DiscardUnknown()

func (*PrepareJobRequest) XXX_Marshal Uses

func (m *PrepareJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrepareJobRequest) XXX_Merge Uses

func (m *PrepareJobRequest) XXX_Merge(src proto.Message)

func (*PrepareJobRequest) XXX_Size Uses

func (m *PrepareJobRequest) XXX_Size() int

func (*PrepareJobRequest) XXX_Unmarshal Uses

func (m *PrepareJobRequest) XXX_Unmarshal(b []byte) error

type PrepareJobResponse Uses

type PrepareJobResponse struct {
    // (required) The ID used to associate calls made while preparing the job. preparationId is used
    // to run the job.
    PreparationId string `protobuf:"bytes,1,opt,name=preparation_id,json=preparationId,proto3" json:"preparation_id,omitempty"`
    // An endpoint which exposes the Beam Artifact Staging API. Artifacts used by the job should be
    // staged to this endpoint, and will be available during job execution.
    ArtifactStagingEndpoint *pipeline_v1.ApiServiceDescriptor `protobuf:"bytes,2,opt,name=artifact_staging_endpoint,json=artifactStagingEndpoint,proto3" json:"artifact_staging_endpoint,omitempty"`
    // (required) Token for the artifact staging. This token also represent an artifact
    // staging session with the artifact staging service.
    StagingSessionToken  string   `protobuf:"bytes,3,opt,name=staging_session_token,json=stagingSessionToken,proto3" json:"staging_session_token,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*PrepareJobResponse) Descriptor Uses

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

func (*PrepareJobResponse) GetArtifactStagingEndpoint Uses

func (m *PrepareJobResponse) GetArtifactStagingEndpoint() *pipeline_v1.ApiServiceDescriptor

func (*PrepareJobResponse) GetPreparationId Uses

func (m *PrepareJobResponse) GetPreparationId() string

func (*PrepareJobResponse) GetStagingSessionToken Uses

func (m *PrepareJobResponse) GetStagingSessionToken() string

func (*PrepareJobResponse) ProtoMessage Uses

func (*PrepareJobResponse) ProtoMessage()

func (*PrepareJobResponse) Reset Uses

func (m *PrepareJobResponse) Reset()

func (*PrepareJobResponse) String Uses

func (m *PrepareJobResponse) String() string

func (*PrepareJobResponse) XXX_DiscardUnknown Uses

func (m *PrepareJobResponse) XXX_DiscardUnknown()

func (*PrepareJobResponse) XXX_Marshal Uses

func (m *PrepareJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrepareJobResponse) XXX_Merge Uses

func (m *PrepareJobResponse) XXX_Merge(src proto.Message)

func (*PrepareJobResponse) XXX_Size Uses

func (m *PrepareJobResponse) XXX_Size() int

func (*PrepareJobResponse) XXX_Unmarshal Uses

func (m *PrepareJobResponse) XXX_Unmarshal(b []byte) error

type ProxyManifest Uses

type ProxyManifest struct {
    Manifest             *Manifest                 `protobuf:"bytes,1,opt,name=manifest,proto3" json:"manifest,omitempty"`
    Location             []*ProxyManifest_Location `protobuf:"bytes,2,rep,name=location,proto3" json:"location,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
    XXX_unrecognized     []byte                    `json:"-"`
    XXX_sizecache        int32                     `json:"-"`
}

A manifest with location information.

func (*ProxyManifest) Descriptor Uses

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

func (*ProxyManifest) GetLocation Uses

func (m *ProxyManifest) GetLocation() []*ProxyManifest_Location

func (*ProxyManifest) GetManifest Uses

func (m *ProxyManifest) GetManifest() *Manifest

func (*ProxyManifest) ProtoMessage Uses

func (*ProxyManifest) ProtoMessage()

func (*ProxyManifest) Reset Uses

func (m *ProxyManifest) Reset()

func (*ProxyManifest) String Uses

func (m *ProxyManifest) String() string

func (*ProxyManifest) XXX_DiscardUnknown Uses

func (m *ProxyManifest) XXX_DiscardUnknown()

func (*ProxyManifest) XXX_Marshal Uses

func (m *ProxyManifest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProxyManifest) XXX_Merge Uses

func (m *ProxyManifest) XXX_Merge(src proto.Message)

func (*ProxyManifest) XXX_Size Uses

func (m *ProxyManifest) XXX_Size() int

func (*ProxyManifest) XXX_Unmarshal Uses

func (m *ProxyManifest) XXX_Unmarshal(b []byte) error

type ProxyManifest_Location Uses

type ProxyManifest_Location struct {
    Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    Uri                  string   `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ProxyManifest_Location) Descriptor Uses

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

func (*ProxyManifest_Location) GetName Uses

func (m *ProxyManifest_Location) GetName() string

func (*ProxyManifest_Location) GetUri Uses

func (m *ProxyManifest_Location) GetUri() string

func (*ProxyManifest_Location) ProtoMessage Uses

func (*ProxyManifest_Location) ProtoMessage()

func (*ProxyManifest_Location) Reset Uses

func (m *ProxyManifest_Location) Reset()

func (*ProxyManifest_Location) String Uses

func (m *ProxyManifest_Location) String() string

func (*ProxyManifest_Location) XXX_DiscardUnknown Uses

func (m *ProxyManifest_Location) XXX_DiscardUnknown()

func (*ProxyManifest_Location) XXX_Marshal Uses

func (m *ProxyManifest_Location) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProxyManifest_Location) XXX_Merge Uses

func (m *ProxyManifest_Location) XXX_Merge(src proto.Message)

func (*ProxyManifest_Location) XXX_Size Uses

func (m *ProxyManifest_Location) XXX_Size() int

func (*ProxyManifest_Location) XXX_Unmarshal Uses

func (m *ProxyManifest_Location) XXX_Unmarshal(b []byte) error

type PutArtifactMetadata Uses

type PutArtifactMetadata struct {
    // (Required) A token for artifact staging session. This token can be obtained
    // from PrepareJob request in JobService
    StagingSessionToken string `protobuf:"bytes,1,opt,name=staging_session_token,json=stagingSessionToken,proto3" json:"staging_session_token,omitempty"`
    // (Required) The Artifact metadata.
    Metadata             *ArtifactMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

func (*PutArtifactMetadata) Descriptor Uses

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

func (*PutArtifactMetadata) GetMetadata Uses

func (m *PutArtifactMetadata) GetMetadata() *ArtifactMetadata

func (*PutArtifactMetadata) GetStagingSessionToken Uses

func (m *PutArtifactMetadata) GetStagingSessionToken() string

func (*PutArtifactMetadata) ProtoMessage Uses

func (*PutArtifactMetadata) ProtoMessage()

func (*PutArtifactMetadata) Reset Uses

func (m *PutArtifactMetadata) Reset()

func (*PutArtifactMetadata) String Uses

func (m *PutArtifactMetadata) String() string

func (*PutArtifactMetadata) XXX_DiscardUnknown Uses

func (m *PutArtifactMetadata) XXX_DiscardUnknown()

func (*PutArtifactMetadata) XXX_Marshal Uses

func (m *PutArtifactMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PutArtifactMetadata) XXX_Merge Uses

func (m *PutArtifactMetadata) XXX_Merge(src proto.Message)

func (*PutArtifactMetadata) XXX_Size Uses

func (m *PutArtifactMetadata) XXX_Size() int

func (*PutArtifactMetadata) XXX_Unmarshal Uses

func (m *PutArtifactMetadata) XXX_Unmarshal(b []byte) error

type PutArtifactRequest Uses

type PutArtifactRequest struct {
    // (Required)
    //
    // Types that are valid to be assigned to Content:
    //	*PutArtifactRequest_Metadata
    //	*PutArtifactRequest_Data
    Content              isPutArtifactRequest_Content `protobuf_oneof:"content"`
    XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
    XXX_unrecognized     []byte                       `json:"-"`
    XXX_sizecache        int32                        `json:"-"`
}

A request to stage an artifact.

func (*PutArtifactRequest) Descriptor Uses

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

func (*PutArtifactRequest) GetContent Uses

func (m *PutArtifactRequest) GetContent() isPutArtifactRequest_Content

func (*PutArtifactRequest) GetData Uses

func (m *PutArtifactRequest) GetData() *ArtifactChunk

func (*PutArtifactRequest) GetMetadata Uses

func (m *PutArtifactRequest) GetMetadata() *PutArtifactMetadata

func (*PutArtifactRequest) ProtoMessage Uses

func (*PutArtifactRequest) ProtoMessage()

func (*PutArtifactRequest) Reset Uses

func (m *PutArtifactRequest) Reset()

func (*PutArtifactRequest) String Uses

func (m *PutArtifactRequest) String() string

func (*PutArtifactRequest) XXX_DiscardUnknown Uses

func (m *PutArtifactRequest) XXX_DiscardUnknown()

func (*PutArtifactRequest) XXX_Marshal Uses

func (m *PutArtifactRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PutArtifactRequest) XXX_Merge Uses

func (m *PutArtifactRequest) XXX_Merge(src proto.Message)

func (*PutArtifactRequest) XXX_OneofWrappers Uses

func (*PutArtifactRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*PutArtifactRequest) XXX_Size Uses

func (m *PutArtifactRequest) XXX_Size() int

func (*PutArtifactRequest) XXX_Unmarshal Uses

func (m *PutArtifactRequest) XXX_Unmarshal(b []byte) error

type PutArtifactRequest_Data Uses

type PutArtifactRequest_Data struct {
    Data *ArtifactChunk `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

type PutArtifactRequest_Metadata Uses

type PutArtifactRequest_Metadata struct {
    Metadata *PutArtifactMetadata `protobuf:"bytes,1,opt,name=metadata,proto3,oneof"`
}

type PutArtifactResponse Uses

type PutArtifactResponse struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*PutArtifactResponse) Descriptor Uses

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

func (*PutArtifactResponse) ProtoMessage Uses

func (*PutArtifactResponse) ProtoMessage()

func (*PutArtifactResponse) Reset Uses

func (m *PutArtifactResponse) Reset()

func (*PutArtifactResponse) String Uses

func (m *PutArtifactResponse) String() string

func (*PutArtifactResponse) XXX_DiscardUnknown Uses

func (m *PutArtifactResponse) XXX_DiscardUnknown()

func (*PutArtifactResponse) XXX_Marshal Uses

func (m *PutArtifactResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PutArtifactResponse) XXX_Merge Uses

func (m *PutArtifactResponse) XXX_Merge(src proto.Message)

func (*PutArtifactResponse) XXX_Size Uses

func (m *PutArtifactResponse) XXX_Size() int

func (*PutArtifactResponse) XXX_Unmarshal Uses

func (m *PutArtifactResponse) XXX_Unmarshal(b []byte) error

type ResolveArtifactsRequest Uses

type ResolveArtifactsRequest struct {
    // An (ordered) set of artifacts to (jointly) resolve.
    Artifacts []*pipeline_v1.ArtifactInformation `protobuf:"bytes,1,rep,name=artifacts,proto3" json:"artifacts,omitempty"`
    // A set of artifact type urns that are understood by the requester.
    // An attempt should be made to resolve the artifacts in terms of these URNs,
    // but other URNs may be used as well with the understanding that they must
    // be fetch-able as bytes via GetArtifact.
    PreferredUrns        []string `protobuf:"bytes,2,rep,name=preferred_urns,json=preferredUrns,proto3" json:"preferred_urns,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A request for artifact resolution.

func (*ResolveArtifactsRequest) Descriptor Uses

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

func (*ResolveArtifactsRequest) GetArtifacts Uses

func (m *ResolveArtifactsRequest) GetArtifacts() []*pipeline_v1.ArtifactInformation

func (*ResolveArtifactsRequest) GetPreferredUrns Uses

func (m *ResolveArtifactsRequest) GetPreferredUrns() []string

func (*ResolveArtifactsRequest) ProtoMessage Uses

func (*ResolveArtifactsRequest) ProtoMessage()

func (*ResolveArtifactsRequest) Reset Uses

func (m *ResolveArtifactsRequest) Reset()

func (*ResolveArtifactsRequest) String Uses

func (m *ResolveArtifactsRequest) String() string

func (*ResolveArtifactsRequest) XXX_DiscardUnknown Uses

func (m *ResolveArtifactsRequest) XXX_DiscardUnknown()

func (*ResolveArtifactsRequest) XXX_Marshal Uses

func (m *ResolveArtifactsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResolveArtifactsRequest) XXX_Merge Uses

func (m *ResolveArtifactsRequest) XXX_Merge(src proto.Message)

func (*ResolveArtifactsRequest) XXX_Size Uses

func (m *ResolveArtifactsRequest) XXX_Size() int

func (*ResolveArtifactsRequest) XXX_Unmarshal Uses

func (m *ResolveArtifactsRequest) XXX_Unmarshal(b []byte) error

type ResolveArtifactsResponse Uses

type ResolveArtifactsResponse struct {
    // A full (ordered) set of replacements for the set of requested artifacts,
    // preferably in terms of the requested type URNs.  If there is no better
    // resolution, the original list is returned.
    Replacements         []*pipeline_v1.ArtifactInformation `protobuf:"bytes,1,rep,name=replacements,proto3" json:"replacements,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
    XXX_unrecognized     []byte                             `json:"-"`
    XXX_sizecache        int32                              `json:"-"`
}

A response for artifact resolution.

func (*ResolveArtifactsResponse) Descriptor Uses

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

func (*ResolveArtifactsResponse) GetReplacements Uses

func (m *ResolveArtifactsResponse) GetReplacements() []*pipeline_v1.ArtifactInformation

func (*ResolveArtifactsResponse) ProtoMessage Uses

func (*ResolveArtifactsResponse) ProtoMessage()

func (*ResolveArtifactsResponse) Reset Uses

func (m *ResolveArtifactsResponse) Reset()

func (*ResolveArtifactsResponse) String Uses

func (m *ResolveArtifactsResponse) String() string

func (*ResolveArtifactsResponse) XXX_DiscardUnknown Uses

func (m *ResolveArtifactsResponse) XXX_DiscardUnknown()

func (*ResolveArtifactsResponse) XXX_Marshal Uses

func (m *ResolveArtifactsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResolveArtifactsResponse) XXX_Merge Uses

func (m *ResolveArtifactsResponse) XXX_Merge(src proto.Message)

func (*ResolveArtifactsResponse) XXX_Size Uses

func (m *ResolveArtifactsResponse) XXX_Size() int

func (*ResolveArtifactsResponse) XXX_Unmarshal Uses

func (m *ResolveArtifactsResponse) XXX_Unmarshal(b []byte) error

type RunJobRequest Uses

type RunJobRequest struct {
    // (required) The ID provided by an earlier call to prepare. Runs the job. All prerequisite tasks
    // must have been completed.
    PreparationId string `protobuf:"bytes,1,opt,name=preparation_id,json=preparationId,proto3" json:"preparation_id,omitempty"`
    // (optional) If any artifacts have been staged for this job, contains the retrieval_token returned
    // from the CommitManifestResponse.
    RetrievalToken       string   `protobuf:"bytes,2,opt,name=retrieval_token,json=retrievalToken,proto3" json:"retrieval_token,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Run is a synchronous request that returns a jobId back. Throws error GRPC_STATUS_UNAVAILABLE if server is down Throws error NOT_FOUND if the preparation ID does not exist Throws error UNKNOWN for all other issues

func (*RunJobRequest) Descriptor Uses

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

func (*RunJobRequest) GetPreparationId Uses

func (m *RunJobRequest) GetPreparationId() string

func (*RunJobRequest) GetRetrievalToken Uses

func (m *RunJobRequest) GetRetrievalToken() string

func (*RunJobRequest) ProtoMessage Uses

func (*RunJobRequest) ProtoMessage()

func (*RunJobRequest) Reset Uses

func (m *RunJobRequest) Reset()

func (*RunJobRequest) String Uses

func (m *RunJobRequest) String() string

func (*RunJobRequest) XXX_DiscardUnknown Uses

func (m *RunJobRequest) XXX_DiscardUnknown()

func (*RunJobRequest) XXX_Marshal Uses

func (m *RunJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RunJobRequest) XXX_Merge Uses

func (m *RunJobRequest) XXX_Merge(src proto.Message)

func (*RunJobRequest) XXX_Size Uses

func (m *RunJobRequest) XXX_Size() int

func (*RunJobRequest) XXX_Unmarshal Uses

func (m *RunJobRequest) XXX_Unmarshal(b []byte) error

type RunJobResponse Uses

type RunJobResponse struct {
    JobId                string   `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*RunJobResponse) Descriptor Uses

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

func (*RunJobResponse) GetJobId Uses

func (m *RunJobResponse) GetJobId() string

func (*RunJobResponse) ProtoMessage Uses

func (*RunJobResponse) ProtoMessage()

func (*RunJobResponse) Reset Uses

func (m *RunJobResponse) Reset()

func (*RunJobResponse) String Uses

func (m *RunJobResponse) String() string

func (*RunJobResponse) XXX_DiscardUnknown Uses

func (m *RunJobResponse) XXX_DiscardUnknown()

func (*RunJobResponse) XXX_Marshal Uses

func (m *RunJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RunJobResponse) XXX_Merge Uses

func (m *RunJobResponse) XXX_Merge(src proto.Message)

func (*RunJobResponse) XXX_Size Uses

func (m *RunJobResponse) XXX_Size() int

func (*RunJobResponse) XXX_Unmarshal Uses

func (m *RunJobResponse) XXX_Unmarshal(b []byte) error

type UnimplementedArtifactRetrievalServiceServer Uses

type UnimplementedArtifactRetrievalServiceServer struct {
}

UnimplementedArtifactRetrievalServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedArtifactRetrievalServiceServer) GetArtifact Uses

func (*UnimplementedArtifactRetrievalServiceServer) GetArtifact(req *GetArtifactRequest, srv ArtifactRetrievalService_GetArtifactServer) error

func (*UnimplementedArtifactRetrievalServiceServer) ResolveArtifacts Uses

func (*UnimplementedArtifactRetrievalServiceServer) ResolveArtifacts(ctx context.Context, req *ResolveArtifactsRequest) (*ResolveArtifactsResponse, error)

type UnimplementedArtifactStagingServiceServer Uses

type UnimplementedArtifactStagingServiceServer struct {
}

UnimplementedArtifactStagingServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedArtifactStagingServiceServer) ReverseArtifactRetrievalService Uses

func (*UnimplementedArtifactStagingServiceServer) ReverseArtifactRetrievalService(srv ArtifactStagingService_ReverseArtifactRetrievalServiceServer) error

type UnimplementedExpansionServiceServer Uses

type UnimplementedExpansionServiceServer struct {
}

UnimplementedExpansionServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedExpansionServiceServer) Expand Uses

func (*UnimplementedExpansionServiceServer) Expand(ctx context.Context, req *ExpansionRequest) (*ExpansionResponse, error)

type UnimplementedJobServiceServer Uses

type UnimplementedJobServiceServer struct {
}

UnimplementedJobServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedJobServiceServer) Cancel Uses

func (*UnimplementedJobServiceServer) Cancel(ctx context.Context, req *CancelJobRequest) (*CancelJobResponse, error)

func (*UnimplementedJobServiceServer) DescribePipelineOptions Uses

func (*UnimplementedJobServiceServer) DescribePipelineOptions(ctx context.Context, req *DescribePipelineOptionsRequest) (*DescribePipelineOptionsResponse, error)

func (*UnimplementedJobServiceServer) GetJobMetrics Uses

func (*UnimplementedJobServiceServer) GetJobMetrics(ctx context.Context, req *GetJobMetricsRequest) (*GetJobMetricsResponse, error)

func (*UnimplementedJobServiceServer) GetJobs Uses

func (*UnimplementedJobServiceServer) GetJobs(ctx context.Context, req *GetJobsRequest) (*GetJobsResponse, error)

func (*UnimplementedJobServiceServer) GetMessageStream Uses

func (*UnimplementedJobServiceServer) GetMessageStream(req *JobMessagesRequest, srv JobService_GetMessageStreamServer) error

func (*UnimplementedJobServiceServer) GetPipeline Uses

func (*UnimplementedJobServiceServer) GetPipeline(ctx context.Context, req *GetJobPipelineRequest) (*GetJobPipelineResponse, error)

func (*UnimplementedJobServiceServer) GetState Uses

func (*UnimplementedJobServiceServer) GetState(ctx context.Context, req *GetJobStateRequest) (*JobStateEvent, error)

func (*UnimplementedJobServiceServer) GetStateStream Uses

func (*UnimplementedJobServiceServer) GetStateStream(req *GetJobStateRequest, srv JobService_GetStateStreamServer) error

func (*UnimplementedJobServiceServer) Prepare Uses

func (*UnimplementedJobServiceServer) Prepare(ctx context.Context, req *PrepareJobRequest) (*PrepareJobResponse, error)

func (*UnimplementedJobServiceServer) Run Uses

func (*UnimplementedJobServiceServer) Run(ctx context.Context, req *RunJobRequest) (*RunJobResponse, error)

type UnimplementedLegacyArtifactRetrievalServiceServer Uses

type UnimplementedLegacyArtifactRetrievalServiceServer struct {
}

UnimplementedLegacyArtifactRetrievalServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedLegacyArtifactRetrievalServiceServer) GetArtifact Uses

func (*UnimplementedLegacyArtifactRetrievalServiceServer) GetArtifact(req *LegacyGetArtifactRequest, srv LegacyArtifactRetrievalService_GetArtifactServer) error

func (*UnimplementedLegacyArtifactRetrievalServiceServer) GetManifest Uses

func (*UnimplementedLegacyArtifactRetrievalServiceServer) GetManifest(ctx context.Context, req *GetManifestRequest) (*GetManifestResponse, error)

type UnimplementedLegacyArtifactStagingServiceServer Uses

type UnimplementedLegacyArtifactStagingServiceServer struct {
}

UnimplementedLegacyArtifactStagingServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedLegacyArtifactStagingServiceServer) CommitManifest Uses

func (*UnimplementedLegacyArtifactStagingServiceServer) CommitManifest(ctx context.Context, req *CommitManifestRequest) (*CommitManifestResponse, error)

func (*UnimplementedLegacyArtifactStagingServiceServer) PutArtifact Uses

func (*UnimplementedLegacyArtifactStagingServiceServer) PutArtifact(srv LegacyArtifactStagingService_PutArtifactServer) error

Package jobmanagement_v1 imports 10 packages (graph) and is imported by 6 packages. Updated 2020-05-30. Refresh now. Tools for package owners.