org_apache_beam_fn_v1

Documentation

Overview

Package org_apache_beam_fn_v1 is a generated protocol buffer package.

It is generated from these files:

beam_provision_api.proto

It has these top-level messages:

GetProvisionInfoRequest
GetProvisionInfoResponse
ProvisionInfo

Index

• func RegisterProvisionServiceServer(s *grpc.Server, srv ProvisionServiceServer)
• type GetProvisionInfoRequest
  • func (*GetProvisionInfoRequest) Descriptor() ([]byte, []int)
  • func (*GetProvisionInfoRequest) ProtoMessage()
  • func (m *GetProvisionInfoRequest) Reset()
  • func (m *GetProvisionInfoRequest) String() string
• type GetProvisionInfoResponse
  • func (*GetProvisionInfoResponse) Descriptor() ([]byte, []int)
  • func (m *GetProvisionInfoResponse) GetInfo() *ProvisionInfo
  • func (*GetProvisionInfoResponse) ProtoMessage()
  • func (m *GetProvisionInfoResponse) Reset()
  • func (m *GetProvisionInfoResponse) String() string
• type ProvisionInfo
  • func (*ProvisionInfo) Descriptor() ([]byte, []int)
  • func (m *ProvisionInfo) GetJobId() string
  • func (m *ProvisionInfo) GetJobName() string
  • func (m *ProvisionInfo) GetPipelineOptions() *google_protobuf.Struct
  • func (*ProvisionInfo) ProtoMessage()
  • func (m *ProvisionInfo) Reset()
  • func (m *ProvisionInfo) String() string
• type ProvisionServiceClient
  • func NewProvisionServiceClient(cc *grpc.ClientConn) ProvisionServiceClient
• type ProvisionServiceServer

Functions

func RegisterProvisionServiceServer

func RegisterProvisionServiceServer(s *grpc.Server, srv ProvisionServiceServer)

Types

type GetProvisionInfoRequest

type GetProvisionInfoRequest struct {
}

A request to get the provision info of a SDK harness worker instance.

func (*GetProvisionInfoRequest) Descriptor

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

func (*GetProvisionInfoRequest) ProtoMessage

func (*GetProvisionInfoRequest) ProtoMessage()

func (*GetProvisionInfoRequest) Reset

func (m *GetProvisionInfoRequest) Reset()

func (*GetProvisionInfoRequest) String

func (m *GetProvisionInfoRequest) String() string

type GetProvisionInfoResponse

type GetProvisionInfoResponse struct {
	Info *ProvisionInfo `protobuf:"bytes,1,opt,name=info" json:"info,omitempty"`
}

A response containing the provision info of a SDK harness worker instance.

func (*GetProvisionInfoResponse) Descriptor

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

func (*GetProvisionInfoResponse) GetInfo

func (m *GetProvisionInfoResponse) GetInfo() *ProvisionInfo

func (*GetProvisionInfoResponse) ProtoMessage

func (*GetProvisionInfoResponse) ProtoMessage()

func (*GetProvisionInfoResponse) Reset

func (m *GetProvisionInfoResponse) Reset()

func (*GetProvisionInfoResponse) String

func (m *GetProvisionInfoResponse) String() string

type ProvisionInfo

type ProvisionInfo struct {
	// (required) The job ID.
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId" json:"job_id,omitempty"`
	// (required) The job name.
	JobName string `protobuf:"bytes,2,opt,name=job_name,json=jobName" json:"job_name,omitempty"`
	// (required) Pipeline options. For non-template jobs, the options are
	// identical to what is passed to job submission.
	PipelineOptions *google_protobuf.Struct `protobuf:"bytes,3,opt,name=pipeline_options,json=pipelineOptions" json:"pipeline_options,omitempty"`
}

Runtime provisioning information for a SDK harness worker instance, such as pipeline options, resource constraints and other job metadata

func (*ProvisionInfo) Descriptor

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

func (*ProvisionInfo) GetJobId

func (m *ProvisionInfo) GetJobId() string

func (*ProvisionInfo) GetJobName

func (m *ProvisionInfo) GetJobName() string

func (*ProvisionInfo) GetPipelineOptions

func (m *ProvisionInfo) GetPipelineOptions() *google_protobuf.Struct

func (*ProvisionInfo) ProtoMessage

func (*ProvisionInfo) ProtoMessage()

func (*ProvisionInfo) Reset

func (m *ProvisionInfo) Reset()

func (*ProvisionInfo) String

func (m *ProvisionInfo) String() string

type ProvisionServiceClient

type ProvisionServiceClient interface {
	// Get provision information for the SDK harness worker instance.
	GetProvisionInfo(ctx context.Context, in *GetProvisionInfoRequest, opts ...grpc.CallOption) (*GetProvisionInfoResponse, error)
}

func NewProvisionServiceClient

func NewProvisionServiceClient(cc *grpc.ClientConn) ProvisionServiceClient

type ProvisionServiceServer

type ProvisionServiceServer interface {
	// Get provision information for the SDK harness worker instance.
	GetProvisionInfo(context.Context, *GetProvisionInfoRequest) (*GetProvisionInfoResponse, error)
}