jobmanagement_v1

package
v2.6.0-RC2+incompatible Latest Latest
Warning

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

 Go to latest Published: Aug 3, 2018 License: Apache-2.0, BSD-3-Clause, MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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",
}
View Source 
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,
}
View Source 
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",
}
View Source 
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,
}

Functions

func RegisterArtifactRetrievalServiceServer 

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

func RegisterArtifactStagingServiceServer 

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

func RegisterJobServiceServer 

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

Types

type ArtifactChunk 

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 

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

func (*ArtifactChunk) GetData 

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

func (*ArtifactChunk) ProtoMessage 

func (*ArtifactChunk) ProtoMessage()

func (*ArtifactChunk) Reset 

func (m *ArtifactChunk) Reset()

func (*ArtifactChunk) String 

func (m *ArtifactChunk) String() string

func (*ArtifactChunk) XXX_DiscardUnknown 

func (m *ArtifactChunk) XXX_DiscardUnknown()

func (*ArtifactChunk) XXX_Marshal 

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

func (*ArtifactChunk) XXX_Merge 

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

func (*ArtifactChunk) XXX_Size 

func (m *ArtifactChunk) XXX_Size() int

func (*ArtifactChunk) XXX_Unmarshal 

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

type ArtifactMetadata 

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 base64-encoded md5 checksum of the artifact. Used, among other things, by
	// harness boot code to validate the integrity of the artifact.
	Md5                  string   `protobuf:"bytes,3,opt,name=md5,proto3" json:"md5,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

An artifact identifier and associated metadata.

func (*ArtifactMetadata) Descriptor 

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

func (*ArtifactMetadata) GetMd5 

func (m *ArtifactMetadata) GetMd5() string

func (*ArtifactMetadata) GetName 

func (m *ArtifactMetadata) GetName() string

func (*ArtifactMetadata) GetPermissions 

func (m *ArtifactMetadata) GetPermissions() uint32

func (*ArtifactMetadata) ProtoMessage 

func (*ArtifactMetadata) ProtoMessage()

func (*ArtifactMetadata) Reset 

func (m *ArtifactMetadata) Reset()

func (*ArtifactMetadata) String 

func (m *ArtifactMetadata) String() string

func (*ArtifactMetadata) XXX_DiscardUnknown 

func (m *ArtifactMetadata) XXX_DiscardUnknown()

func (*ArtifactMetadata) XXX_Marshal 

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

func (*ArtifactMetadata) XXX_Merge 

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

func (*ArtifactMetadata) XXX_Size 

func (m *ArtifactMetadata) XXX_Size() int

func (*ArtifactMetadata) XXX_Unmarshal 

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

type ArtifactRetrievalServiceClient 

type ArtifactRetrievalServiceClient 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 *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 

func NewArtifactRetrievalServiceClient(cc *grpc.ClientConn) ArtifactRetrievalServiceClient

type ArtifactRetrievalServiceServer 

type ArtifactRetrievalServiceServer 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(*GetArtifactRequest, ArtifactRetrievalService_GetArtifactServer) error
}

ArtifactRetrievalServiceServer is the server API for ArtifactRetrievalService service.

type ArtifactRetrievalService_GetArtifactClient 

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

type ArtifactRetrievalService_GetArtifactServer 

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

type ArtifactStagingServiceClient 

type ArtifactStagingServiceClient 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) (ArtifactStagingService_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)
}

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 

func NewArtifactStagingServiceClient(cc *grpc.ClientConn) ArtifactStagingServiceClient

type ArtifactStagingServiceServer 

type ArtifactStagingServiceServer 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(ArtifactStagingService_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)
}

ArtifactStagingServiceServer is the server API for ArtifactStagingService service.

type ArtifactStagingService_PutArtifactClient 

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

type ArtifactStagingService_PutArtifactServer 

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

type CancelJobRequest 

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 

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

func (*CancelJobRequest) GetJobId 

func (m *CancelJobRequest) GetJobId() string

func (*CancelJobRequest) ProtoMessage 

func (*CancelJobRequest) ProtoMessage()

func (*CancelJobRequest) Reset 

func (m *CancelJobRequest) Reset()

func (*CancelJobRequest) String 

func (m *CancelJobRequest) String() string

func (*CancelJobRequest) XXX_DiscardUnknown 

func (m *CancelJobRequest) XXX_DiscardUnknown()

func (*CancelJobRequest) XXX_Marshal 

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

func (*CancelJobRequest) XXX_Merge 

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

func (*CancelJobRequest) XXX_Size 

func (m *CancelJobRequest) XXX_Size() int

func (*CancelJobRequest) XXX_Unmarshal 

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

type CancelJobResponse 

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 

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

func (*CancelJobResponse) GetState 

func (m *CancelJobResponse) GetState() JobState_Enum

func (*CancelJobResponse) ProtoMessage 

func (*CancelJobResponse) ProtoMessage()

func (*CancelJobResponse) Reset 

func (m *CancelJobResponse) Reset()

func (*CancelJobResponse) String 

func (m *CancelJobResponse) String() string

func (*CancelJobResponse) XXX_DiscardUnknown 

func (m *CancelJobResponse) XXX_DiscardUnknown()

func (*CancelJobResponse) XXX_Marshal 

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

func (*CancelJobResponse) XXX_Merge 

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

func (*CancelJobResponse) XXX_Size 

func (m *CancelJobResponse) XXX_Size() int

func (*CancelJobResponse) XXX_Unmarshal 

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

type CommitManifestRequest 

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 

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

func (*CommitManifestRequest) GetManifest 

func (m *CommitManifestRequest) GetManifest() *Manifest

func (*CommitManifestRequest) GetStagingSessionToken 

func (m *CommitManifestRequest) GetStagingSessionToken() string

func (*CommitManifestRequest) ProtoMessage 

func (*CommitManifestRequest) ProtoMessage()

func (*CommitManifestRequest) Reset 

func (m *CommitManifestRequest) Reset()

func (*CommitManifestRequest) String 

func (m *CommitManifestRequest) String() string

func (*CommitManifestRequest) XXX_DiscardUnknown 

func (m *CommitManifestRequest) XXX_DiscardUnknown()

func (*CommitManifestRequest) XXX_Marshal 

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

func (*CommitManifestRequest) XXX_Merge 

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

func (*CommitManifestRequest) XXX_Size 

func (m *CommitManifestRequest) XXX_Size() int

func (*CommitManifestRequest) XXX_Unmarshal 

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

type CommitManifestResponse 

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
	// ArtifactRetrievalService.
	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 

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

func (*CommitManifestResponse) GetRetrievalToken 

func (m *CommitManifestResponse) GetRetrievalToken() string

func (*CommitManifestResponse) ProtoMessage 

func (*CommitManifestResponse) ProtoMessage()

func (*CommitManifestResponse) Reset 

func (m *CommitManifestResponse) Reset()

func (*CommitManifestResponse) String 

func (m *CommitManifestResponse) String() string

func (*CommitManifestResponse) XXX_DiscardUnknown 

func (m *CommitManifestResponse) XXX_DiscardUnknown()

func (*CommitManifestResponse) XXX_Marshal 

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

func (*CommitManifestResponse) XXX_Merge 

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

func (*CommitManifestResponse) XXX_Size 

func (m *CommitManifestResponse) XXX_Size() int

func (*CommitManifestResponse) XXX_Unmarshal 

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

type GetArtifactRequest 

type GetArtifactRequest 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 (*GetArtifactRequest) Descriptor 

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

func (*GetArtifactRequest) GetName 

func (m *GetArtifactRequest) GetName() string

func (*GetArtifactRequest) GetRetrievalToken 

func (m *GetArtifactRequest) GetRetrievalToken() string

func (*GetArtifactRequest) ProtoMessage 

func (*GetArtifactRequest) ProtoMessage()

func (*GetArtifactRequest) Reset 

func (m *GetArtifactRequest) Reset()

func (*GetArtifactRequest) String 

func (m *GetArtifactRequest) String() string

func (*GetArtifactRequest) XXX_DiscardUnknown 

func (m *GetArtifactRequest) XXX_DiscardUnknown()

func (*GetArtifactRequest) XXX_Marshal 

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

func (*GetArtifactRequest) XXX_Merge 

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

func (*GetArtifactRequest) XXX_Size 

func (m *GetArtifactRequest) XXX_Size() int

func (*GetArtifactRequest) XXX_Unmarshal 

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

type GetJobStateRequest 

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 

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

func (*GetJobStateRequest) GetJobId 

func (m *GetJobStateRequest) GetJobId() string

func (*GetJobStateRequest) ProtoMessage 

func (*GetJobStateRequest) ProtoMessage()

func (*GetJobStateRequest) Reset 

func (m *GetJobStateRequest) Reset()

func (*GetJobStateRequest) String 

func (m *GetJobStateRequest) String() string

func (*GetJobStateRequest) XXX_DiscardUnknown 

func (m *GetJobStateRequest) XXX_DiscardUnknown()

func (*GetJobStateRequest) XXX_Marshal 

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

func (*GetJobStateRequest) XXX_Merge 

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

func (*GetJobStateRequest) XXX_Size 

func (m *GetJobStateRequest) XXX_Size() int

func (*GetJobStateRequest) XXX_Unmarshal 

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

type GetJobStateResponse 

type GetJobStateResponse 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:"-"`
}

func (*GetJobStateResponse) Descriptor 

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

func (*GetJobStateResponse) GetState 

func (m *GetJobStateResponse) GetState() JobState_Enum

func (*GetJobStateResponse) ProtoMessage 

func (*GetJobStateResponse) ProtoMessage()

func (*GetJobStateResponse) Reset 

func (m *GetJobStateResponse) Reset()

func (*GetJobStateResponse) String 

func (m *GetJobStateResponse) String() string

func (*GetJobStateResponse) XXX_DiscardUnknown 

func (m *GetJobStateResponse) XXX_DiscardUnknown()

func (*GetJobStateResponse) XXX_Marshal 

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

func (*GetJobStateResponse) XXX_Merge 

func (dst *GetJobStateResponse) XXX_Merge(src proto.Message)

func (*GetJobStateResponse) XXX_Size 

func (m *GetJobStateResponse) XXX_Size() int

func (*GetJobStateResponse) XXX_Unmarshal 

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

type GetManifestRequest 

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 

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

func (*GetManifestRequest) GetRetrievalToken 

func (m *GetManifestRequest) GetRetrievalToken() string

func (*GetManifestRequest) ProtoMessage 

func (*GetManifestRequest) ProtoMessage()

func (*GetManifestRequest) Reset 

func (m *GetManifestRequest) Reset()

func (*GetManifestRequest) String 

func (m *GetManifestRequest) String() string

func (*GetManifestRequest) XXX_DiscardUnknown 

func (m *GetManifestRequest) XXX_DiscardUnknown()

func (*GetManifestRequest) XXX_Marshal 

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

func (*GetManifestRequest) XXX_Merge 

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

func (*GetManifestRequest) XXX_Size 

func (m *GetManifestRequest) XXX_Size() int

func (*GetManifestRequest) XXX_Unmarshal 

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

type GetManifestResponse 

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 

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

func (*GetManifestResponse) GetManifest 

func (m *GetManifestResponse) GetManifest() *Manifest

func (*GetManifestResponse) ProtoMessage 

func (*GetManifestResponse) ProtoMessage()

func (*GetManifestResponse) Reset 

func (m *GetManifestResponse) Reset()

func (*GetManifestResponse) String 

func (m *GetManifestResponse) String() string

func (*GetManifestResponse) XXX_DiscardUnknown 

func (m *GetManifestResponse) XXX_DiscardUnknown()

func (*GetManifestResponse) XXX_Marshal 

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

func (*GetManifestResponse) XXX_Merge 

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

func (*GetManifestResponse) XXX_Size 

func (m *GetManifestResponse) XXX_Size() int

func (*GetManifestResponse) XXX_Unmarshal 

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

type JobMessage 

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 `` /* 148-byte string literal not displayed */
	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 

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

func (*JobMessage) GetImportance 

func (m *JobMessage) GetImportance() JobMessage_MessageImportance

func (*JobMessage) GetMessageId 

func (m *JobMessage) GetMessageId() string

func (*JobMessage) GetMessageText 

func (m *JobMessage) GetMessageText() string

func (*JobMessage) GetTime 

func (m *JobMessage) GetTime() string

func (*JobMessage) ProtoMessage 

func (*JobMessage) ProtoMessage()

func (*JobMessage) Reset 

func (m *JobMessage) Reset()

func (*JobMessage) String 

func (m *JobMessage) String() string

func (*JobMessage) XXX_DiscardUnknown 

func (m *JobMessage) XXX_DiscardUnknown()

func (*JobMessage) XXX_Marshal 

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

func (*JobMessage) XXX_Merge 

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

func (*JobMessage) XXX_Size 

func (m *JobMessage) XXX_Size() int

func (*JobMessage) XXX_Unmarshal 

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

type JobMessage_MessageImportance 

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 

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

func (JobMessage_MessageImportance) String 

func (x JobMessage_MessageImportance) String() string

type JobMessagesRequest 

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 

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

func (*JobMessagesRequest) GetJobId 

func (m *JobMessagesRequest) GetJobId() string

func (*JobMessagesRequest) ProtoMessage 

func (*JobMessagesRequest) ProtoMessage()

func (*JobMessagesRequest) Reset 

func (m *JobMessagesRequest) Reset()

func (*JobMessagesRequest) String 

func (m *JobMessagesRequest) String() string

func (*JobMessagesRequest) XXX_DiscardUnknown 

func (m *JobMessagesRequest) XXX_DiscardUnknown()

func (*JobMessagesRequest) XXX_Marshal 

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

func (*JobMessagesRequest) XXX_Merge 

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

func (*JobMessagesRequest) XXX_Size 

func (m *JobMessagesRequest) XXX_Size() int

func (*JobMessagesRequest) XXX_Unmarshal 

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

type JobMessagesResponse 

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 

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

func (*JobMessagesResponse) GetMessageResponse 

func (m *JobMessagesResponse) GetMessageResponse() *JobMessage

func (*JobMessagesResponse) GetResponse 

func (m *JobMessagesResponse) GetResponse() isJobMessagesResponse_Response

func (*JobMessagesResponse) GetStateResponse 

func (m *JobMessagesResponse) GetStateResponse() *GetJobStateResponse

func (*JobMessagesResponse) ProtoMessage 

func (*JobMessagesResponse) ProtoMessage()

func (*JobMessagesResponse) Reset 

func (m *JobMessagesResponse) Reset()

func (*JobMessagesResponse) String 

func (m *JobMessagesResponse) String() string

func (*JobMessagesResponse) XXX_DiscardUnknown 

func (m *JobMessagesResponse) XXX_DiscardUnknown()

func (*JobMessagesResponse) XXX_Marshal 

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

func (*JobMessagesResponse) XXX_Merge 

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

func (*JobMessagesResponse) XXX_OneofFuncs 

func (*JobMessagesResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*JobMessagesResponse) XXX_Size 

func (m *JobMessagesResponse) XXX_Size() int

func (*JobMessagesResponse) XXX_Unmarshal 

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

type JobMessagesResponse_MessageResponse 

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

type JobMessagesResponse_StateResponse 

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

type JobServiceClient 

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 the current state of the job
	GetState(ctx context.Context, in *GetJobStateRequest, opts ...grpc.CallOption) (*GetJobStateResponse, 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)
}

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 

func NewJobServiceClient(cc *grpc.ClientConn) JobServiceClient

type JobServiceServer 

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 the current state of the job
	GetState(context.Context, *GetJobStateRequest) (*GetJobStateResponse, 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
}

JobServiceServer is the server API for JobService service.

type JobService_GetMessageStreamClient 

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

type JobService_GetMessageStreamServer 

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

type JobService_GetStateStreamClient 

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

type JobService_GetStateStreamServer 

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

type JobState 

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

Enumeration of all JobStates

func (*JobState) Descriptor 

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

func (*JobState) ProtoMessage 

func (*JobState) ProtoMessage()

func (*JobState) Reset 

func (m *JobState) Reset()

func (*JobState) String 

func (m *JobState) String() string

func (*JobState) XXX_DiscardUnknown 

func (m *JobState) XXX_DiscardUnknown()

func (*JobState) XXX_Marshal 

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

func (*JobState) XXX_Merge 

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

func (*JobState) XXX_Size 

func (m *JobState) XXX_Size() int

func (*JobState) XXX_Unmarshal 

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

type JobState_Enum 

type JobState_Enum int32
const (
	JobState_UNSPECIFIED JobState_Enum = 0
	JobState_STOPPED     JobState_Enum = 1
	JobState_RUNNING     JobState_Enum = 2
	JobState_DONE        JobState_Enum = 3
	JobState_FAILED      JobState_Enum = 4
	JobState_CANCELLED   JobState_Enum = 5
	JobState_UPDATED     JobState_Enum = 6
	JobState_DRAINING    JobState_Enum = 7
	JobState_DRAINED     JobState_Enum = 8
	JobState_STARTING    JobState_Enum = 9
	JobState_CANCELLING  JobState_Enum = 10
)

func (JobState_Enum) EnumDescriptor 

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

func (JobState_Enum) String 

func (x JobState_Enum) String() string

type Manifest 

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 

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

func (*Manifest) GetArtifact 

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

func (*Manifest) ProtoMessage 

func (*Manifest) ProtoMessage()

func (*Manifest) Reset 

func (m *Manifest) Reset()

func (*Manifest) String 

func (m *Manifest) String() string

func (*Manifest) XXX_DiscardUnknown 

func (m *Manifest) XXX_DiscardUnknown()

func (*Manifest) XXX_Marshal 

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

func (*Manifest) XXX_Merge 

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

func (*Manifest) XXX_Size 

func (m *Manifest) XXX_Size() int

func (*Manifest) XXX_Unmarshal 

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

type PrepareJobRequest 

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 

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

func (*PrepareJobRequest) GetJobName 

func (m *PrepareJobRequest) GetJobName() string

func (*PrepareJobRequest) GetPipeline 

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

func (*PrepareJobRequest) GetPipelineOptions 

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

func (*PrepareJobRequest) ProtoMessage 

func (*PrepareJobRequest) ProtoMessage()

func (*PrepareJobRequest) Reset 

func (m *PrepareJobRequest) Reset()

func (*PrepareJobRequest) String 

func (m *PrepareJobRequest) String() string

func (*PrepareJobRequest) XXX_DiscardUnknown 

func (m *PrepareJobRequest) XXX_DiscardUnknown()

func (*PrepareJobRequest) XXX_Marshal 

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

func (*PrepareJobRequest) XXX_Merge 

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

func (*PrepareJobRequest) XXX_Size 

func (m *PrepareJobRequest) XXX_Size() int

func (*PrepareJobRequest) XXX_Unmarshal 

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

type PrepareJobResponse 

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 `` /* 132-byte string literal not displayed */
	// (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 

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

func (*PrepareJobResponse) GetArtifactStagingEndpoint 

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

func (*PrepareJobResponse) GetPreparationId 

func (m *PrepareJobResponse) GetPreparationId() string

func (*PrepareJobResponse) GetStagingSessionToken 

func (m *PrepareJobResponse) GetStagingSessionToken() string

func (*PrepareJobResponse) ProtoMessage 

func (*PrepareJobResponse) ProtoMessage()

func (*PrepareJobResponse) Reset 

func (m *PrepareJobResponse) Reset()

func (*PrepareJobResponse) String 

func (m *PrepareJobResponse) String() string

func (*PrepareJobResponse) XXX_DiscardUnknown 

func (m *PrepareJobResponse) XXX_DiscardUnknown()

func (*PrepareJobResponse) XXX_Marshal 

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

func (*PrepareJobResponse) XXX_Merge 

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

func (*PrepareJobResponse) XXX_Size 

func (m *PrepareJobResponse) XXX_Size() int

func (*PrepareJobResponse) XXX_Unmarshal 

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

type ProxyManifest 

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 

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

func (*ProxyManifest) GetLocation 

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

func (*ProxyManifest) GetManifest 

func (m *ProxyManifest) GetManifest() *Manifest

func (*ProxyManifest) ProtoMessage 

func (*ProxyManifest) ProtoMessage()

func (*ProxyManifest) Reset 

func (m *ProxyManifest) Reset()

func (*ProxyManifest) String 

func (m *ProxyManifest) String() string

func (*ProxyManifest) XXX_DiscardUnknown 

func (m *ProxyManifest) XXX_DiscardUnknown()

func (*ProxyManifest) XXX_Marshal 

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

func (*ProxyManifest) XXX_Merge 

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

func (*ProxyManifest) XXX_Size 

func (m *ProxyManifest) XXX_Size() int

func (*ProxyManifest) XXX_Unmarshal 

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

type ProxyManifest_Location 

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 

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

func (*ProxyManifest_Location) GetName 

func (m *ProxyManifest_Location) GetName() string

func (*ProxyManifest_Location) GetUri 

func (m *ProxyManifest_Location) GetUri() string

func (*ProxyManifest_Location) ProtoMessage 

func (*ProxyManifest_Location) ProtoMessage()

func (*ProxyManifest_Location) Reset 

func (m *ProxyManifest_Location) Reset()

func (*ProxyManifest_Location) String 

func (m *ProxyManifest_Location) String() string

func (*ProxyManifest_Location) XXX_DiscardUnknown 

func (m *ProxyManifest_Location) XXX_DiscardUnknown()

func (*ProxyManifest_Location) XXX_Marshal 

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

func (*ProxyManifest_Location) XXX_Merge 

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

func (*ProxyManifest_Location) XXX_Size 

func (m *ProxyManifest_Location) XXX_Size() int

func (*ProxyManifest_Location) XXX_Unmarshal 

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

type PutArtifactMetadata 

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 

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

func (*PutArtifactMetadata) GetMetadata 

func (m *PutArtifactMetadata) GetMetadata() *ArtifactMetadata

func (*PutArtifactMetadata) GetStagingSessionToken 

func (m *PutArtifactMetadata) GetStagingSessionToken() string

func (*PutArtifactMetadata) ProtoMessage 

func (*PutArtifactMetadata) ProtoMessage()

func (*PutArtifactMetadata) Reset 

func (m *PutArtifactMetadata) Reset()

func (*PutArtifactMetadata) String 

func (m *PutArtifactMetadata) String() string

func (*PutArtifactMetadata) XXX_DiscardUnknown 

func (m *PutArtifactMetadata) XXX_DiscardUnknown()

func (*PutArtifactMetadata) XXX_Marshal 

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

func (*PutArtifactMetadata) XXX_Merge 

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

func (*PutArtifactMetadata) XXX_Size 

func (m *PutArtifactMetadata) XXX_Size() int

func (*PutArtifactMetadata) XXX_Unmarshal 

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

type PutArtifactRequest 

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 

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

func (*PutArtifactRequest) GetContent 

func (m *PutArtifactRequest) GetContent() isPutArtifactRequest_Content

func (*PutArtifactRequest) GetData 

func (m *PutArtifactRequest) GetData() *ArtifactChunk

func (*PutArtifactRequest) GetMetadata 

func (m *PutArtifactRequest) GetMetadata() *PutArtifactMetadata

func (*PutArtifactRequest) ProtoMessage 

func (*PutArtifactRequest) ProtoMessage()

func (*PutArtifactRequest) Reset 

func (m *PutArtifactRequest) Reset()

func (*PutArtifactRequest) String 

func (m *PutArtifactRequest) String() string

func (*PutArtifactRequest) XXX_DiscardUnknown 

func (m *PutArtifactRequest) XXX_DiscardUnknown()

func (*PutArtifactRequest) XXX_Marshal 

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

func (*PutArtifactRequest) XXX_Merge 

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

func (*PutArtifactRequest) XXX_OneofFuncs 

func (*PutArtifactRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*PutArtifactRequest) XXX_Size 

func (m *PutArtifactRequest) XXX_Size() int

func (*PutArtifactRequest) XXX_Unmarshal 

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

type PutArtifactRequest_Data 

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

type PutArtifactRequest_Metadata 

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

type PutArtifactResponse 

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

func (*PutArtifactResponse) Descriptor 

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

func (*PutArtifactResponse) ProtoMessage 

func (*PutArtifactResponse) ProtoMessage()

func (*PutArtifactResponse) Reset 

func (m *PutArtifactResponse) Reset()

func (*PutArtifactResponse) String 

func (m *PutArtifactResponse) String() string

func (*PutArtifactResponse) XXX_DiscardUnknown 

func (m *PutArtifactResponse) XXX_DiscardUnknown()

func (*PutArtifactResponse) XXX_Marshal 

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

func (*PutArtifactResponse) XXX_Merge 

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

func (*PutArtifactResponse) XXX_Size 

func (m *PutArtifactResponse) XXX_Size() int

func (*PutArtifactResponse) XXX_Unmarshal 

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

type RunJobRequest 

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 

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

func (*RunJobRequest) GetPreparationId 

func (m *RunJobRequest) GetPreparationId() string

func (*RunJobRequest) GetRetrievalToken 

func (m *RunJobRequest) GetRetrievalToken() string

func (*RunJobRequest) ProtoMessage 

func (*RunJobRequest) ProtoMessage()

func (*RunJobRequest) Reset 

func (m *RunJobRequest) Reset()

func (*RunJobRequest) String 

func (m *RunJobRequest) String() string

func (*RunJobRequest) XXX_DiscardUnknown 

func (m *RunJobRequest) XXX_DiscardUnknown()

func (*RunJobRequest) XXX_Marshal 

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

func (*RunJobRequest) XXX_Merge 

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

func (*RunJobRequest) XXX_Size 

func (m *RunJobRequest) XXX_Size() int

func (*RunJobRequest) XXX_Unmarshal 

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

type RunJobResponse 

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 

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

func (*RunJobResponse) GetJobId 

func (m *RunJobResponse) GetJobId() string

func (*RunJobResponse) ProtoMessage 

func (*RunJobResponse) ProtoMessage()

func (*RunJobResponse) Reset 

func (m *RunJobResponse) Reset()

func (*RunJobResponse) String 

func (m *RunJobResponse) String() string

func (*RunJobResponse) XXX_DiscardUnknown 

func (m *RunJobResponse) XXX_DiscardUnknown()

func (*RunJobResponse) XXX_Marshal 

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

func (*RunJobResponse) XXX_Merge 

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

func (*RunJobResponse) XXX_Size 

func (m *RunJobResponse) XXX_Size() int

func (*RunJobResponse) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.