fnexecution_v1

package
v2.5.0+incompatible Latest Latest
Warning

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

 Go to latest Published: Jun 16, 2018 License: Apache-2.0, BSD-3-Clause, MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var LogEntry_Severity_Enum_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "TRACE",
	2: "DEBUG",
	3: "INFO",
	4: "NOTICE",
	5: "WARN",
	6: "ERROR",
	7: "CRITICAL",
}
View Source 
var LogEntry_Severity_Enum_value = map[string]int32{
	"UNSPECIFIED": 0,
	"TRACE":       1,
	"DEBUG":       2,
	"INFO":        3,
	"NOTICE":      4,
	"WARN":        5,
	"ERROR":       6,
	"CRITICAL":    7,
}

Functions

func RegisterBeamFnControlServer 

func RegisterBeamFnControlServer(s *grpc.Server, srv BeamFnControlServer)

func RegisterBeamFnDataServer 

func RegisterBeamFnDataServer(s *grpc.Server, srv BeamFnDataServer)

func RegisterBeamFnLoggingServer 

func RegisterBeamFnLoggingServer(s *grpc.Server, srv BeamFnLoggingServer)

func RegisterBeamFnStateServer 

func RegisterBeamFnStateServer(s *grpc.Server, srv BeamFnStateServer)

func RegisterProvisionServiceServer 

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

Types

type BeamFnControlClient 

type BeamFnControlClient interface {
	// Instructions sent by the runner to the SDK requesting different types
	// of work.
	Control(ctx context.Context, opts ...grpc.CallOption) (BeamFnControl_ControlClient, error)
}

BeamFnControlClient is the client API for BeamFnControl service.

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

func NewBeamFnControlClient 

func NewBeamFnControlClient(cc *grpc.ClientConn) BeamFnControlClient

type BeamFnControlServer 

type BeamFnControlServer interface {
	// Instructions sent by the runner to the SDK requesting different types
	// of work.
	Control(BeamFnControl_ControlServer) error
}

BeamFnControlServer is the server API for BeamFnControl service.

type BeamFnControl_ControlClient 

type BeamFnControl_ControlClient interface {
	Send(*InstructionResponse) error
	Recv() (*InstructionRequest, error)
	grpc.ClientStream
}

type BeamFnControl_ControlServer 

type BeamFnControl_ControlServer interface {
	Send(*InstructionRequest) error
	Recv() (*InstructionResponse, error)
	grpc.ServerStream
}

type BeamFnDataClient 

type BeamFnDataClient interface {
	// Used to send data between harnesses.
	Data(ctx context.Context, opts ...grpc.CallOption) (BeamFnData_DataClient, error)
}

BeamFnDataClient is the client API for BeamFnData service.

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

func NewBeamFnDataClient 

func NewBeamFnDataClient(cc *grpc.ClientConn) BeamFnDataClient

type BeamFnDataServer 

type BeamFnDataServer interface {
	// Used to send data between harnesses.
	Data(BeamFnData_DataServer) error
}

BeamFnDataServer is the server API for BeamFnData service.

type BeamFnData_DataClient 

type BeamFnData_DataClient interface {
	Send(*Elements) error
	Recv() (*Elements, error)
	grpc.ClientStream
}

type BeamFnData_DataServer 

type BeamFnData_DataServer interface {
	Send(*Elements) error
	Recv() (*Elements, error)
	grpc.ServerStream
}

type BeamFnLoggingClient 

type BeamFnLoggingClient interface {
	// Allows for the SDK to emit log entries which the runner can
	// associate with the active job.
	Logging(ctx context.Context, opts ...grpc.CallOption) (BeamFnLogging_LoggingClient, error)
}

BeamFnLoggingClient is the client API for BeamFnLogging service.

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

func NewBeamFnLoggingClient 

func NewBeamFnLoggingClient(cc *grpc.ClientConn) BeamFnLoggingClient

type BeamFnLoggingServer 

type BeamFnLoggingServer interface {
	// Allows for the SDK to emit log entries which the runner can
	// associate with the active job.
	Logging(BeamFnLogging_LoggingServer) error
}

BeamFnLoggingServer is the server API for BeamFnLogging service.

type BeamFnLogging_LoggingClient 

type BeamFnLogging_LoggingClient interface {
	Send(*LogEntry_List) error
	Recv() (*LogControl, error)
	grpc.ClientStream
}

type BeamFnLogging_LoggingServer 

type BeamFnLogging_LoggingServer interface {
	Send(*LogControl) error
	Recv() (*LogEntry_List, error)
	grpc.ServerStream
}

type BeamFnStateClient 

type BeamFnStateClient interface {
	// Used to get/append/clear state stored by the runner on behalf of the SDK.
	State(ctx context.Context, opts ...grpc.CallOption) (BeamFnState_StateClient, error)
}

BeamFnStateClient is the client API for BeamFnState service.

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

func NewBeamFnStateClient 

func NewBeamFnStateClient(cc *grpc.ClientConn) BeamFnStateClient

type BeamFnStateServer 

type BeamFnStateServer interface {
	// Used to get/append/clear state stored by the runner on behalf of the SDK.
	State(BeamFnState_StateServer) error
}

BeamFnStateServer is the server API for BeamFnState service.

type BeamFnState_StateClient 

type BeamFnState_StateClient interface {
	Send(*StateRequest) error
	Recv() (*StateResponse, error)
	grpc.ClientStream
}

type BeamFnState_StateServer 

type BeamFnState_StateServer interface {
	Send(*StateResponse) error
	Recv() (*StateRequest, error)
	grpc.ServerStream
}

type BundleSplit 

type BundleSplit struct {
	// Root applications that should replace the current bundle.
	PrimaryRoots []*BundleSplit_Application `protobuf:"bytes,1,rep,name=primary_roots,json=primaryRoots" json:"primary_roots,omitempty"`
	// Root applications that have been removed from the current bundle and
	// have to be executed in a separate bundle (e.g. in parallel on a different
	// worker, or after the current bundle completes, etc.)
	ResidualRoots        []*BundleSplit_Application `protobuf:"bytes,2,rep,name=residual_roots,json=residualRoots" json:"residual_roots,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

Represents a partition of the bundle into two bundles: a "primary" and a "residual", with the following properties:

  • The work in primary and residual doesn't overlap, and combined, adds up to the work in the current bundle if the split hadn't happened.
  • The current bundle, if it keeps executing, will have done none of the work under residual roots.
  • The current bundle, if no further splits happen, will have done exactly the work under primary_roots.

For more rigorous definitions see https://s.apache.org/beam-breaking-fusion

func (*BundleSplit) Descriptor 

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

func (*BundleSplit) GetPrimaryRoots 

func (m *BundleSplit) GetPrimaryRoots() []*BundleSplit_Application

func (*BundleSplit) GetResidualRoots 

func (m *BundleSplit) GetResidualRoots() []*BundleSplit_Application

func (*BundleSplit) ProtoMessage 

func (*BundleSplit) ProtoMessage()

func (*BundleSplit) Reset 

func (m *BundleSplit) Reset()

func (*BundleSplit) String 

func (m *BundleSplit) String() string

func (*BundleSplit) XXX_DiscardUnknown 

func (m *BundleSplit) XXX_DiscardUnknown()

func (*BundleSplit) XXX_Marshal 

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

func (*BundleSplit) XXX_Merge 

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

func (*BundleSplit) XXX_Size 

func (m *BundleSplit) XXX_Size() int

func (*BundleSplit) XXX_Unmarshal 

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

type BundleSplit_Application 

type BundleSplit_Application struct {
	// (Required) The primitive transform to which to pass the element
	PtransformId string `protobuf:"bytes,1,opt,name=ptransform_id,json=ptransformId" json:"ptransform_id,omitempty"`
	// (Required) Name of the transform's input to which to pass the element.
	InputId string `protobuf:"bytes,2,opt,name=input_id,json=inputId" json:"input_id,omitempty"`
	// (Required) The encoded element to pass to the transform.
	Element []byte `protobuf:"bytes,3,opt,name=element,proto3" json:"element,omitempty"`
	// Approximate lower bounds on timestamps of elements that this PTransform
	// will produce into each of its output PCollections, when invoked on this
	// element. Keyed by the transform's local output name.
	OutputWatermarks map[string]int64 `` /* 177-byte string literal not displayed */
	// Approximate fraction of all work of the current bundle (before split)
	// represented by invoking this Application and its downstream applications.
	// The sum of fraction_of_work between all primary_roots and residual_roots
	// must add up to approximately 1.0.
	FractionOfWork       *wrappers.DoubleValue `protobuf:"bytes,5,opt,name=fraction_of_work,json=fractionOfWork" json:"fraction_of_work,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

One of the root applications specifying the scope of work for a bundle.

func (*BundleSplit_Application) Descriptor 

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

func (*BundleSplit_Application) GetElement 

func (m *BundleSplit_Application) GetElement() []byte

func (*BundleSplit_Application) GetFractionOfWork 

func (m *BundleSplit_Application) GetFractionOfWork() *wrappers.DoubleValue

func (*BundleSplit_Application) GetInputId 

func (m *BundleSplit_Application) GetInputId() string

func (*BundleSplit_Application) GetOutputWatermarks 

func (m *BundleSplit_Application) GetOutputWatermarks() map[string]int64

func (*BundleSplit_Application) GetPtransformId 

func (m *BundleSplit_Application) GetPtransformId() string

func (*BundleSplit_Application) ProtoMessage 

func (*BundleSplit_Application) ProtoMessage()

func (*BundleSplit_Application) Reset 

func (m *BundleSplit_Application) Reset()

func (*BundleSplit_Application) String 

func (m *BundleSplit_Application) String() string

func (*BundleSplit_Application) XXX_DiscardUnknown 

func (m *BundleSplit_Application) XXX_DiscardUnknown()

func (*BundleSplit_Application) XXX_Marshal 

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

func (*BundleSplit_Application) XXX_Merge 

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

func (*BundleSplit_Application) XXX_Size 

func (m *BundleSplit_Application) XXX_Size() int

func (*BundleSplit_Application) XXX_Unmarshal 

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

type Elements 

type Elements struct {
	// (Required) A list containing parts of logical byte streams.
	Data                 []*Elements_Data `protobuf:"bytes,1,rep,name=data" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

Messages used to represent logical byte streams. Stable

func (*Elements) Descriptor 

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

func (*Elements) GetData 

func (m *Elements) GetData() []*Elements_Data

func (*Elements) ProtoMessage 

func (*Elements) ProtoMessage()

func (*Elements) Reset 

func (m *Elements) Reset()

func (*Elements) String 

func (m *Elements) String() string

func (*Elements) XXX_DiscardUnknown 

func (m *Elements) XXX_DiscardUnknown()

func (*Elements) XXX_Marshal 

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

func (*Elements) XXX_Merge 

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

func (*Elements) XXX_Size 

func (m *Elements) XXX_Size() int

func (*Elements) XXX_Unmarshal 

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

type Elements_Data 

type Elements_Data struct {
	// (Required) A reference to an active instruction request with the given
	// instruction id.
	InstructionReference string `protobuf:"bytes,1,opt,name=instruction_reference,json=instructionReference" json:"instruction_reference,omitempty"`
	// (Required) A definition representing a consumer or producer of this data.
	// If received by a harness, this represents the consumer within that
	// harness that should consume these bytes. If sent by a harness, this
	// represents the producer of these bytes.
	//
	// Note that a single element may span multiple Data messages.
	//
	// Note that a sending/receiving pair should share the same target
	// identifier.
	Target *Target `protobuf:"bytes,2,opt,name=target" json:"target,omitempty"`
	// (Optional) Represents a part of a logical byte stream. Elements within
	// the logical byte stream are encoded in the nested context and
	// concatenated together.
	//
	// An empty data block represents the end of stream for the given
	// instruction and target.
	Data                 []byte   `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Represents multiple encoded elements in nested context for a given named instruction and target.

func (*Elements_Data) Descriptor 

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

func (*Elements_Data) GetData 

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

func (*Elements_Data) GetInstructionReference 

func (m *Elements_Data) GetInstructionReference() string

func (*Elements_Data) GetTarget 

func (m *Elements_Data) GetTarget() *Target

func (*Elements_Data) ProtoMessage 

func (*Elements_Data) ProtoMessage()

func (*Elements_Data) Reset 

func (m *Elements_Data) Reset()

func (*Elements_Data) String 

func (m *Elements_Data) String() string

func (*Elements_Data) XXX_DiscardUnknown 

func (m *Elements_Data) XXX_DiscardUnknown()

func (*Elements_Data) XXX_Marshal 

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

func (*Elements_Data) XXX_Merge 

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

func (*Elements_Data) XXX_Size 

func (m *Elements_Data) XXX_Size() int

func (*Elements_Data) XXX_Unmarshal 

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

type GetProvisionInfoRequest 

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

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

func (*GetProvisionInfoRequest) XXX_DiscardUnknown 

func (m *GetProvisionInfoRequest) XXX_DiscardUnknown()

func (*GetProvisionInfoRequest) XXX_Marshal 

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

func (*GetProvisionInfoRequest) XXX_Merge 

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

func (*GetProvisionInfoRequest) XXX_Size 

func (m *GetProvisionInfoRequest) XXX_Size() int

func (*GetProvisionInfoRequest) XXX_Unmarshal 

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

type GetProvisionInfoResponse 

type GetProvisionInfoResponse struct {
	Info                 *ProvisionInfo `protobuf:"bytes,1,opt,name=info" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*GetProvisionInfoResponse) XXX_DiscardUnknown 

func (m *GetProvisionInfoResponse) XXX_DiscardUnknown()

func (*GetProvisionInfoResponse) XXX_Marshal 

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

func (*GetProvisionInfoResponse) XXX_Merge 

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

func (*GetProvisionInfoResponse) XXX_Size 

func (m *GetProvisionInfoResponse) XXX_Size() int

func (*GetProvisionInfoResponse) XXX_Unmarshal 

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

type InstructionRequest 

type InstructionRequest struct {
	// (Required) An unique identifier provided by the runner which represents
	// this requests execution. The InstructionResponse MUST have the matching id.
	InstructionId string `protobuf:"bytes,1,opt,name=instruction_id,json=instructionId" json:"instruction_id,omitempty"`
	// (Required) A request that the SDK Harness needs to interpret.
	//
	// Types that are valid to be assigned to Request:
	//	*InstructionRequest_Register
	//	*InstructionRequest_ProcessBundle
	//	*InstructionRequest_ProcessBundleProgress
	//	*InstructionRequest_ProcessBundleSplit
	Request              isInstructionRequest_Request `protobuf_oneof:"request"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

A request sent by a runner which the SDK is asked to fulfill. For any unsupported request type, an error should be returned with a matching instruction id. Stable

func (*InstructionRequest) Descriptor 

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

func (*InstructionRequest) GetInstructionId 

func (m *InstructionRequest) GetInstructionId() string

func (*InstructionRequest) GetProcessBundle 

func (m *InstructionRequest) GetProcessBundle() *ProcessBundleRequest

func (*InstructionRequest) GetProcessBundleProgress 

func (m *InstructionRequest) GetProcessBundleProgress() *ProcessBundleProgressRequest

func (*InstructionRequest) GetProcessBundleSplit 

func (m *InstructionRequest) GetProcessBundleSplit() *ProcessBundleSplitRequest

func (*InstructionRequest) GetRegister 

func (m *InstructionRequest) GetRegister() *RegisterRequest

func (*InstructionRequest) GetRequest 

func (m *InstructionRequest) GetRequest() isInstructionRequest_Request

func (*InstructionRequest) ProtoMessage 

func (*InstructionRequest) ProtoMessage()

func (*InstructionRequest) Reset 

func (m *InstructionRequest) Reset()

func (*InstructionRequest) String 

func (m *InstructionRequest) String() string

func (*InstructionRequest) XXX_DiscardUnknown 

func (m *InstructionRequest) XXX_DiscardUnknown()

func (*InstructionRequest) XXX_Marshal 

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

func (*InstructionRequest) XXX_Merge 

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

func (*InstructionRequest) XXX_OneofFuncs 

func (*InstructionRequest) 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 (*InstructionRequest) XXX_Size 

func (m *InstructionRequest) XXX_Size() int

func (*InstructionRequest) XXX_Unmarshal 

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

type InstructionRequest_ProcessBundle 

type InstructionRequest_ProcessBundle struct {
	ProcessBundle *ProcessBundleRequest `protobuf:"bytes,1001,opt,name=process_bundle,json=processBundle,oneof"`
}

type InstructionRequest_ProcessBundleProgress 

type InstructionRequest_ProcessBundleProgress struct {
	ProcessBundleProgress *ProcessBundleProgressRequest `protobuf:"bytes,1002,opt,name=process_bundle_progress,json=processBundleProgress,oneof"`
}

type InstructionRequest_ProcessBundleSplit 

type InstructionRequest_ProcessBundleSplit struct {
	ProcessBundleSplit *ProcessBundleSplitRequest `protobuf:"bytes,1003,opt,name=process_bundle_split,json=processBundleSplit,oneof"`
}

type InstructionRequest_Register 

type InstructionRequest_Register struct {
	Register *RegisterRequest `protobuf:"bytes,1000,opt,name=register,oneof"`
}

type InstructionResponse 

type InstructionResponse struct {
	// (Required) A reference provided by the runner which represents a requests
	// execution. The InstructionResponse MUST have the matching id when
	// responding to the runner.
	InstructionId string `protobuf:"bytes,1,opt,name=instruction_id,json=instructionId" json:"instruction_id,omitempty"`
	// If this is specified, then this instruction has failed.
	// A human readable string representing the reason as to why processing has
	// failed.
	Error string `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	// If the instruction did not fail, it is required to return an equivalent
	// response type depending on the request this matches.
	//
	// Types that are valid to be assigned to Response:
	//	*InstructionResponse_Register
	//	*InstructionResponse_ProcessBundle
	//	*InstructionResponse_ProcessBundleProgress
	//	*InstructionResponse_ProcessBundleSplit
	Response             isInstructionResponse_Response `protobuf_oneof:"response"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

The response for an associated request the SDK had been asked to fulfill. Stable

func (*InstructionResponse) Descriptor 

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

func (*InstructionResponse) GetError 

func (m *InstructionResponse) GetError() string

func (*InstructionResponse) GetInstructionId 

func (m *InstructionResponse) GetInstructionId() string

func (*InstructionResponse) GetProcessBundle 

func (m *InstructionResponse) GetProcessBundle() *ProcessBundleResponse

func (*InstructionResponse) GetProcessBundleProgress 

func (m *InstructionResponse) GetProcessBundleProgress() *ProcessBundleProgressResponse

func (*InstructionResponse) GetProcessBundleSplit 

func (m *InstructionResponse) GetProcessBundleSplit() *ProcessBundleSplitResponse

func (*InstructionResponse) GetRegister 

func (m *InstructionResponse) GetRegister() *RegisterResponse

func (*InstructionResponse) GetResponse 

func (m *InstructionResponse) GetResponse() isInstructionResponse_Response

func (*InstructionResponse) ProtoMessage 

func (*InstructionResponse) ProtoMessage()

func (*InstructionResponse) Reset 

func (m *InstructionResponse) Reset()

func (*InstructionResponse) String 

func (m *InstructionResponse) String() string

func (*InstructionResponse) XXX_DiscardUnknown 

func (m *InstructionResponse) XXX_DiscardUnknown()

func (*InstructionResponse) XXX_Marshal 

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

func (*InstructionResponse) XXX_Merge 

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

func (*InstructionResponse) XXX_OneofFuncs 

func (*InstructionResponse) 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 (*InstructionResponse) XXX_Size 

func (m *InstructionResponse) XXX_Size() int

func (*InstructionResponse) XXX_Unmarshal 

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

type InstructionResponse_ProcessBundle 

type InstructionResponse_ProcessBundle struct {
	ProcessBundle *ProcessBundleResponse `protobuf:"bytes,1001,opt,name=process_bundle,json=processBundle,oneof"`
}

type InstructionResponse_ProcessBundleProgress 

type InstructionResponse_ProcessBundleProgress struct {
	ProcessBundleProgress *ProcessBundleProgressResponse `protobuf:"bytes,1002,opt,name=process_bundle_progress,json=processBundleProgress,oneof"`
}

type InstructionResponse_ProcessBundleSplit 

type InstructionResponse_ProcessBundleSplit struct {
	ProcessBundleSplit *ProcessBundleSplitResponse `protobuf:"bytes,1003,opt,name=process_bundle_split,json=processBundleSplit,oneof"`
}

type InstructionResponse_Register 

type InstructionResponse_Register struct {
	Register *RegisterResponse `protobuf:"bytes,1000,opt,name=register,oneof"`
}

type LogControl 

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

func (*LogControl) Descriptor 

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

func (*LogControl) ProtoMessage 

func (*LogControl) ProtoMessage()

func (*LogControl) Reset 

func (m *LogControl) Reset()

func (*LogControl) String 

func (m *LogControl) String() string

func (*LogControl) XXX_DiscardUnknown 

func (m *LogControl) XXX_DiscardUnknown()

func (*LogControl) XXX_Marshal 

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

func (*LogControl) XXX_Merge 

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

func (*LogControl) XXX_Size 

func (m *LogControl) XXX_Size() int

func (*LogControl) XXX_Unmarshal 

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

type LogEntry 

type LogEntry struct {
	// (Required) The severity of the log statement.
	Severity LogEntry_Severity_Enum `` /* 129-byte string literal not displayed */
	// (Required) The time at which this log statement occurred.
	Timestamp *timestamp.Timestamp `protobuf:"bytes,2,opt,name=timestamp" json:"timestamp,omitempty"`
	// (Required) A human readable message.
	Message string `protobuf:"bytes,3,opt,name=message" json:"message,omitempty"`
	// (Optional) An optional trace of the functions involved. For example, in
	// Java this can include multiple causes and multiple suppressed exceptions.
	Trace string `protobuf:"bytes,4,opt,name=trace" json:"trace,omitempty"`
	// (Optional) A reference to the instruction this log statement is associated
	// with.
	InstructionReference string `protobuf:"bytes,5,opt,name=instruction_reference,json=instructionReference" json:"instruction_reference,omitempty"`
	// (Optional) A reference to the primitive transform this log statement is
	// associated with.
	PrimitiveTransformReference string `` /* 137-byte string literal not displayed */
	// (Optional) Human-readable name of the function or method being invoked,
	// with optional context such as the class or package name. The format can
	// vary by language. For example:
	//   qual.if.ied.Class.method (Java)
	//   dir/package.func (Go)
	//   module.function (Python)
	//   file.cc:382 (C++)
	LogLocation string `protobuf:"bytes,7,opt,name=log_location,json=logLocation" json:"log_location,omitempty"`
	// (Optional) The name of the thread this log statement is associated with.
	Thread               string   `protobuf:"bytes,8,opt,name=thread" json:"thread,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A log entry

func (*LogEntry) Descriptor 

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

func (*LogEntry) GetInstructionReference 

func (m *LogEntry) GetInstructionReference() string

func (*LogEntry) GetLogLocation 

func (m *LogEntry) GetLogLocation() string

func (*LogEntry) GetMessage 

func (m *LogEntry) GetMessage() string

func (*LogEntry) GetPrimitiveTransformReference 

func (m *LogEntry) GetPrimitiveTransformReference() string

func (*LogEntry) GetSeverity 

func (m *LogEntry) GetSeverity() LogEntry_Severity_Enum

func (*LogEntry) GetThread 

func (m *LogEntry) GetThread() string

func (*LogEntry) GetTimestamp 

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

func (*LogEntry) GetTrace 

func (m *LogEntry) GetTrace() string

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) Reset 

func (m *LogEntry) Reset()

func (*LogEntry) String 

func (m *LogEntry) String() string

func (*LogEntry) XXX_DiscardUnknown 

func (m *LogEntry) XXX_DiscardUnknown()

func (*LogEntry) XXX_Marshal 

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

func (*LogEntry) XXX_Merge 

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

func (*LogEntry) XXX_Size 

func (m *LogEntry) XXX_Size() int

func (*LogEntry) XXX_Unmarshal 

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

type LogEntry_List 

type LogEntry_List struct {
	// (Required) One or or more log messages.
	LogEntries           []*LogEntry `protobuf:"bytes,1,rep,name=log_entries,json=logEntries" json:"log_entries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

A list of log entries, enables buffering and batching of multiple log messages using the logging API.

func (*LogEntry_List) Descriptor 

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

func (*LogEntry_List) GetLogEntries 

func (m *LogEntry_List) GetLogEntries() []*LogEntry

func (*LogEntry_List) ProtoMessage 

func (*LogEntry_List) ProtoMessage()

func (*LogEntry_List) Reset 

func (m *LogEntry_List) Reset()

func (*LogEntry_List) String 

func (m *LogEntry_List) String() string

func (*LogEntry_List) XXX_DiscardUnknown 

func (m *LogEntry_List) XXX_DiscardUnknown()

func (*LogEntry_List) XXX_Marshal 

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

func (*LogEntry_List) XXX_Merge 

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

func (*LogEntry_List) XXX_Size 

func (m *LogEntry_List) XXX_Size() int

func (*LogEntry_List) XXX_Unmarshal 

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

type LogEntry_Severity 

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

The severity of the event described in a log entry, expressed as one of the severity levels listed below. For your reference, the levels are assigned the listed numeric values. The effect of using numeric values other than those listed is undefined.

If you are writing log entries, you should map other severity encodings to one of these standard levels. For example, you might map all of Java's FINE, FINER, and FINEST levels to `Severity.DEBUG`.

This list is intentionally not comprehensive; the intent is to provide a common set of "good enough" severity levels so that logging front ends can provide filtering and searching across log types. Users of the API are free not to use all severity levels in their log messages.

func (*LogEntry_Severity) Descriptor 

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

func (*LogEntry_Severity) ProtoMessage 

func (*LogEntry_Severity) ProtoMessage()

func (*LogEntry_Severity) Reset 

func (m *LogEntry_Severity) Reset()

func (*LogEntry_Severity) String 

func (m *LogEntry_Severity) String() string

func (*LogEntry_Severity) XXX_DiscardUnknown 

func (m *LogEntry_Severity) XXX_DiscardUnknown()

func (*LogEntry_Severity) XXX_Marshal 

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

func (*LogEntry_Severity) XXX_Merge 

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

func (*LogEntry_Severity) XXX_Size 

func (m *LogEntry_Severity) XXX_Size() int

func (*LogEntry_Severity) XXX_Unmarshal 

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

type LogEntry_Severity_Enum 

type LogEntry_Severity_Enum int32
const (
	// Unspecified level information. Will be logged at the TRACE level.
	LogEntry_Severity_UNSPECIFIED LogEntry_Severity_Enum = 0
	// Trace level information.
	LogEntry_Severity_TRACE LogEntry_Severity_Enum = 1
	// Debugging information.
	LogEntry_Severity_DEBUG LogEntry_Severity_Enum = 2
	// Normal events.
	LogEntry_Severity_INFO LogEntry_Severity_Enum = 3
	// Normal but significant events, such as start up, shut down, or
	// configuration.
	LogEntry_Severity_NOTICE LogEntry_Severity_Enum = 4
	// Warning events might cause problems.
	LogEntry_Severity_WARN LogEntry_Severity_Enum = 5
	// Error events are likely to cause problems.
	LogEntry_Severity_ERROR LogEntry_Severity_Enum = 6
	// Critical events cause severe problems or brief outages and may
	// indicate that a person must take action.
	LogEntry_Severity_CRITICAL LogEntry_Severity_Enum = 7
)

func (LogEntry_Severity_Enum) EnumDescriptor 

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

func (LogEntry_Severity_Enum) String 

func (x LogEntry_Severity_Enum) String() string

type Metrics 

type Metrics struct {
	Ptransforms          map[string]*Metrics_PTransform `` /* 142-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*Metrics) Descriptor 

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

func (*Metrics) GetPtransforms 

func (m *Metrics) GetPtransforms() map[string]*Metrics_PTransform

func (*Metrics) ProtoMessage 

func (*Metrics) ProtoMessage()

func (*Metrics) Reset 

func (m *Metrics) Reset()

func (*Metrics) String 

func (m *Metrics) String() string

func (*Metrics) XXX_DiscardUnknown 

func (m *Metrics) XXX_DiscardUnknown()

func (*Metrics) XXX_Marshal 

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

func (*Metrics) XXX_Merge 

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

func (*Metrics) XXX_Size 

func (m *Metrics) XXX_Size() int

func (*Metrics) XXX_Unmarshal 

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

type Metrics_PTransform 

type Metrics_PTransform struct {
	// (Required): Metrics for processed elements.
	ProcessedElements *Metrics_PTransform_ProcessedElements `protobuf:"bytes,1,opt,name=processed_elements,json=processedElements" json:"processed_elements,omitempty"`
	// (Required): Metrics for active elements.
	ActiveElements *Metrics_PTransform_ActiveElements `protobuf:"bytes,2,opt,name=active_elements,json=activeElements" json:"active_elements,omitempty"`
	// (Optional): Map from local output name to its watermark.
	// The watermarks reported are tentative, to get a better sense of progress
	// while processing a bundle but before it is committed. At bundle commit
	// time, a Runner needs to also take into account the timers set to compute
	// the actual watermarks.
	Watermarks           map[string]int64 `` /* 141-byte string literal not displayed */
	User                 []*Metrics_User  `protobuf:"bytes,4,rep,name=user" json:"user,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

PTransform level metrics. These metrics are split into processed and active element groups for progress reporting purposes. This allows a Runner to see what is measured, what is estimated and what can be extrapolated to be able to accurately estimate the backlog of remaining work.

func (*Metrics_PTransform) Descriptor 

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

func (*Metrics_PTransform) GetActiveElements 

func (m *Metrics_PTransform) GetActiveElements() *Metrics_PTransform_ActiveElements

func (*Metrics_PTransform) GetProcessedElements 

func (m *Metrics_PTransform) GetProcessedElements() *Metrics_PTransform_ProcessedElements

func (*Metrics_PTransform) GetUser 

func (m *Metrics_PTransform) GetUser() []*Metrics_User

func (*Metrics_PTransform) GetWatermarks 

func (m *Metrics_PTransform) GetWatermarks() map[string]int64

func (*Metrics_PTransform) ProtoMessage 

func (*Metrics_PTransform) ProtoMessage()

func (*Metrics_PTransform) Reset 

func (m *Metrics_PTransform) Reset()

func (*Metrics_PTransform) String 

func (m *Metrics_PTransform) String() string

func (*Metrics_PTransform) XXX_DiscardUnknown 

func (m *Metrics_PTransform) XXX_DiscardUnknown()

func (*Metrics_PTransform) XXX_Marshal 

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

func (*Metrics_PTransform) XXX_Merge 

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

func (*Metrics_PTransform) XXX_Size 

func (m *Metrics_PTransform) XXX_Size() int

func (*Metrics_PTransform) XXX_Unmarshal 

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

type Metrics_PTransform_ActiveElements 

type Metrics_PTransform_ActiveElements struct {
	// (Required)
	Measured *Metrics_PTransform_Measured `protobuf:"bytes,1,opt,name=measured" json:"measured,omitempty"`
	// (Optional) Sum of estimated fraction of known work remaining for all
	// active elements, as reported by this transform.
	// If not reported, a Runner could extrapolate this from the processed
	// elements.
	// TODO: Handle the case when known work is infinite.
	FractionRemaining float64 `protobuf:"fixed64,2,opt,name=fraction_remaining,json=fractionRemaining" json:"fraction_remaining,omitempty"`
	// (Optional) Map from local output name to sum of estimated number
	// of elements remaining for this output from all active elements,
	// as reported by this transform.
	// If not reported, a Runner could extrapolate this from the processed
	// elements.
	OutputElementsRemaining map[string]int64 `` /* 200-byte string literal not displayed */
	XXX_NoUnkeyedLiteral    struct{}         `json:"-"`
	XXX_unrecognized        []byte           `json:"-"`
	XXX_sizecache           int32            `json:"-"`
}

Metrics for active elements. An element is considered active if the SDK has started but not finished processing it yet.

func (*Metrics_PTransform_ActiveElements) Descriptor 

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

func (*Metrics_PTransform_ActiveElements) GetFractionRemaining 

func (m *Metrics_PTransform_ActiveElements) GetFractionRemaining() float64

func (*Metrics_PTransform_ActiveElements) GetMeasured 

func (m *Metrics_PTransform_ActiveElements) GetMeasured() *Metrics_PTransform_Measured

func (*Metrics_PTransform_ActiveElements) GetOutputElementsRemaining 

func (m *Metrics_PTransform_ActiveElements) GetOutputElementsRemaining() map[string]int64

func (*Metrics_PTransform_ActiveElements) ProtoMessage 

func (*Metrics_PTransform_ActiveElements) ProtoMessage()

func (*Metrics_PTransform_ActiveElements) Reset 

func (m *Metrics_PTransform_ActiveElements) Reset()

func (*Metrics_PTransform_ActiveElements) String 

func (m *Metrics_PTransform_ActiveElements) String() string

func (*Metrics_PTransform_ActiveElements) XXX_DiscardUnknown 

func (m *Metrics_PTransform_ActiveElements) XXX_DiscardUnknown()

func (*Metrics_PTransform_ActiveElements) XXX_Marshal 

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

func (*Metrics_PTransform_ActiveElements) XXX_Merge 

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

func (*Metrics_PTransform_ActiveElements) XXX_Size 

func (m *Metrics_PTransform_ActiveElements) XXX_Size() int

func (*Metrics_PTransform_ActiveElements) XXX_Unmarshal 

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

type Metrics_PTransform_Measured 

type Metrics_PTransform_Measured struct {
	// (Optional) Map from local input name to number of elements processed
	// from this input.
	// If unset, assumed to be the sum of the outputs of all producers to
	// this transform (for ProcessedElements) and 0 (for ActiveElements).
	InputElementCounts map[string]int64 `` /* 185-byte string literal not displayed */
	// (Required) Map from local output name to number of elements produced
	// for this output.
	OutputElementCounts map[string]int64 `` /* 188-byte string literal not displayed */
	// (Optional) The total time spent so far in processing the elements in
	// this group, in seconds.
	TotalTimeSpent       float64  `protobuf:"fixed64,3,opt,name=total_time_spent,json=totalTimeSpent" json:"total_time_spent,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Metrics that are measured for processed and active element groups.

func (*Metrics_PTransform_Measured) Descriptor 

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

func (*Metrics_PTransform_Measured) GetInputElementCounts 

func (m *Metrics_PTransform_Measured) GetInputElementCounts() map[string]int64

func (*Metrics_PTransform_Measured) GetOutputElementCounts 

func (m *Metrics_PTransform_Measured) GetOutputElementCounts() map[string]int64

func (*Metrics_PTransform_Measured) GetTotalTimeSpent 

func (m *Metrics_PTransform_Measured) GetTotalTimeSpent() float64

func (*Metrics_PTransform_Measured) ProtoMessage 

func (*Metrics_PTransform_Measured) ProtoMessage()

func (*Metrics_PTransform_Measured) Reset 

func (m *Metrics_PTransform_Measured) Reset()

func (*Metrics_PTransform_Measured) String 

func (m *Metrics_PTransform_Measured) String() string

func (*Metrics_PTransform_Measured) XXX_DiscardUnknown 

func (m *Metrics_PTransform_Measured) XXX_DiscardUnknown()

func (*Metrics_PTransform_Measured) XXX_Marshal 

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

func (*Metrics_PTransform_Measured) XXX_Merge 

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

func (*Metrics_PTransform_Measured) XXX_Size 

func (m *Metrics_PTransform_Measured) XXX_Size() int

func (*Metrics_PTransform_Measured) XXX_Unmarshal 

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

type Metrics_PTransform_ProcessedElements 

type Metrics_PTransform_ProcessedElements struct {
	// (Required)
	Measured             *Metrics_PTransform_Measured `protobuf:"bytes,1,opt,name=measured" json:"measured,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

Metrics for fully processed elements.

func (*Metrics_PTransform_ProcessedElements) Descriptor 

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

func (*Metrics_PTransform_ProcessedElements) GetMeasured 

func (m *Metrics_PTransform_ProcessedElements) GetMeasured() *Metrics_PTransform_Measured

func (*Metrics_PTransform_ProcessedElements) ProtoMessage 

func (*Metrics_PTransform_ProcessedElements) ProtoMessage()

func (*Metrics_PTransform_ProcessedElements) Reset 

func (m *Metrics_PTransform_ProcessedElements) Reset()

func (*Metrics_PTransform_ProcessedElements) String 

func (m *Metrics_PTransform_ProcessedElements) String() string

func (*Metrics_PTransform_ProcessedElements) XXX_DiscardUnknown 

func (m *Metrics_PTransform_ProcessedElements) XXX_DiscardUnknown()

func (*Metrics_PTransform_ProcessedElements) XXX_Marshal 

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

func (*Metrics_PTransform_ProcessedElements) XXX_Merge 

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

func (*Metrics_PTransform_ProcessedElements) XXX_Size 

func (m *Metrics_PTransform_ProcessedElements) XXX_Size() int

func (*Metrics_PTransform_ProcessedElements) XXX_Unmarshal 

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

type Metrics_User 

type Metrics_User struct {
	// (Required) The identifier for this metric.
	MetricName *Metrics_User_MetricName `protobuf:"bytes,1,opt,name=metric_name,json=metricName" json:"metric_name,omitempty"`
	// (Required) The data for this metric.
	//
	// Types that are valid to be assigned to Data:
	//	*Metrics_User_CounterData_
	//	*Metrics_User_DistributionData_
	//	*Metrics_User_GaugeData_
	Data                 isMetrics_User_Data `protobuf_oneof:"data"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

User defined metrics

func (*Metrics_User) Descriptor 

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

func (*Metrics_User) GetCounterData 

func (m *Metrics_User) GetCounterData() *Metrics_User_CounterData

func (*Metrics_User) GetData 

func (m *Metrics_User) GetData() isMetrics_User_Data

func (*Metrics_User) GetDistributionData 

func (m *Metrics_User) GetDistributionData() *Metrics_User_DistributionData

func (*Metrics_User) GetGaugeData 

func (m *Metrics_User) GetGaugeData() *Metrics_User_GaugeData

func (*Metrics_User) GetMetricName 

func (m *Metrics_User) GetMetricName() *Metrics_User_MetricName

func (*Metrics_User) ProtoMessage 

func (*Metrics_User) ProtoMessage()

func (*Metrics_User) Reset 

func (m *Metrics_User) Reset()

func (*Metrics_User) String 

func (m *Metrics_User) String() string

func (*Metrics_User) XXX_DiscardUnknown 

func (m *Metrics_User) XXX_DiscardUnknown()

func (*Metrics_User) XXX_Marshal 

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

func (*Metrics_User) XXX_Merge 

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

func (*Metrics_User) XXX_OneofFuncs 

func (*Metrics_User) 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 (*Metrics_User) XXX_Size 

func (m *Metrics_User) XXX_Size() int

func (*Metrics_User) XXX_Unmarshal 

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

type Metrics_User_CounterData 

type Metrics_User_CounterData struct {
	Value                int64    `protobuf:"varint,1,opt,name=value" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Data associated with a counter metric.

func (*Metrics_User_CounterData) Descriptor 

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

func (*Metrics_User_CounterData) GetValue 

func (m *Metrics_User_CounterData) GetValue() int64

func (*Metrics_User_CounterData) ProtoMessage 

func (*Metrics_User_CounterData) ProtoMessage()

func (*Metrics_User_CounterData) Reset 

func (m *Metrics_User_CounterData) Reset()

func (*Metrics_User_CounterData) String 

func (m *Metrics_User_CounterData) String() string

func (*Metrics_User_CounterData) XXX_DiscardUnknown 

func (m *Metrics_User_CounterData) XXX_DiscardUnknown()

func (*Metrics_User_CounterData) XXX_Marshal 

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

func (*Metrics_User_CounterData) XXX_Merge 

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

func (*Metrics_User_CounterData) XXX_Size 

func (m *Metrics_User_CounterData) XXX_Size() int

func (*Metrics_User_CounterData) XXX_Unmarshal 

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

type Metrics_User_CounterData_ 

type Metrics_User_CounterData_ struct {
	CounterData *Metrics_User_CounterData `protobuf:"bytes,1001,opt,name=counter_data,json=counterData,oneof"`
}

type Metrics_User_DistributionData 

type Metrics_User_DistributionData struct {
	Count                int64    `protobuf:"varint,1,opt,name=count" json:"count,omitempty"`
	Sum                  int64    `protobuf:"varint,2,opt,name=sum" json:"sum,omitempty"`
	Min                  int64    `protobuf:"varint,3,opt,name=min" json:"min,omitempty"`
	Max                  int64    `protobuf:"varint,4,opt,name=max" json:"max,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Data associated with a distribution metric.

func (*Metrics_User_DistributionData) Descriptor 

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

func (*Metrics_User_DistributionData) GetCount 

func (m *Metrics_User_DistributionData) GetCount() int64

func (*Metrics_User_DistributionData) GetMax 

func (m *Metrics_User_DistributionData) GetMax() int64

func (*Metrics_User_DistributionData) GetMin 

func (m *Metrics_User_DistributionData) GetMin() int64

func (*Metrics_User_DistributionData) GetSum 

func (m *Metrics_User_DistributionData) GetSum() int64

func (*Metrics_User_DistributionData) ProtoMessage 

func (*Metrics_User_DistributionData) ProtoMessage()

func (*Metrics_User_DistributionData) Reset 

func (m *Metrics_User_DistributionData) Reset()

func (*Metrics_User_DistributionData) String 

func (m *Metrics_User_DistributionData) String() string

func (*Metrics_User_DistributionData) XXX_DiscardUnknown 

func (m *Metrics_User_DistributionData) XXX_DiscardUnknown()

func (*Metrics_User_DistributionData) XXX_Marshal 

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

func (*Metrics_User_DistributionData) XXX_Merge 

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

func (*Metrics_User_DistributionData) XXX_Size 

func (m *Metrics_User_DistributionData) XXX_Size() int

func (*Metrics_User_DistributionData) XXX_Unmarshal 

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

type Metrics_User_DistributionData_ 

type Metrics_User_DistributionData_ struct {
	DistributionData *Metrics_User_DistributionData `protobuf:"bytes,1002,opt,name=distribution_data,json=distributionData,oneof"`
}

type Metrics_User_GaugeData 

type Metrics_User_GaugeData struct {
	Value                int64                `protobuf:"varint,1,opt,name=value" json:"value,omitempty"`
	Timestamp            *timestamp.Timestamp `protobuf:"bytes,2,opt,name=timestamp" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Data associated with a Gauge metric.

func (*Metrics_User_GaugeData) Descriptor 

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

func (*Metrics_User_GaugeData) GetTimestamp 

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

func (*Metrics_User_GaugeData) GetValue 

func (m *Metrics_User_GaugeData) GetValue() int64

func (*Metrics_User_GaugeData) ProtoMessage 

func (*Metrics_User_GaugeData) ProtoMessage()

func (*Metrics_User_GaugeData) Reset 

func (m *Metrics_User_GaugeData) Reset()

func (*Metrics_User_GaugeData) String 

func (m *Metrics_User_GaugeData) String() string

func (*Metrics_User_GaugeData) XXX_DiscardUnknown 

func (m *Metrics_User_GaugeData) XXX_DiscardUnknown()

func (*Metrics_User_GaugeData) XXX_Marshal 

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

func (*Metrics_User_GaugeData) XXX_Merge 

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

func (*Metrics_User_GaugeData) XXX_Size 

func (m *Metrics_User_GaugeData) XXX_Size() int

func (*Metrics_User_GaugeData) XXX_Unmarshal 

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

type Metrics_User_GaugeData_ 

type Metrics_User_GaugeData_ struct {
	GaugeData *Metrics_User_GaugeData `protobuf:"bytes,1003,opt,name=gauge_data,json=gaugeData,oneof"`
}

type Metrics_User_MetricName 

type Metrics_User_MetricName struct {
	// (Required): The namespace of this metric.
	Namespace string `protobuf:"bytes,2,opt,name=namespace" json:"namespace,omitempty"`
	// (Required): The name of this metric.
	Name                 string   `protobuf:"bytes,3,opt,name=name" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A key for identifying a metric at the most granular level.

func (*Metrics_User_MetricName) Descriptor 

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

func (*Metrics_User_MetricName) GetName 

func (m *Metrics_User_MetricName) GetName() string

func (*Metrics_User_MetricName) GetNamespace 

func (m *Metrics_User_MetricName) GetNamespace() string

func (*Metrics_User_MetricName) ProtoMessage 

func (*Metrics_User_MetricName) ProtoMessage()

func (*Metrics_User_MetricName) Reset 

func (m *Metrics_User_MetricName) Reset()

func (*Metrics_User_MetricName) String 

func (m *Metrics_User_MetricName) String() string

func (*Metrics_User_MetricName) XXX_DiscardUnknown 

func (m *Metrics_User_MetricName) XXX_DiscardUnknown()

func (*Metrics_User_MetricName) XXX_Marshal 

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

func (*Metrics_User_MetricName) XXX_Merge 

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

func (*Metrics_User_MetricName) XXX_Size 

func (m *Metrics_User_MetricName) XXX_Size() int

func (*Metrics_User_MetricName) XXX_Unmarshal 

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

type ProcessBundleDescriptor 

type ProcessBundleDescriptor struct {
	// (Required) A pipeline level unique id which can be used as a reference to
	// refer to this.
	Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	// (Required) A map from pipeline-scoped id to PTransform.
	Transforms map[string]*pipeline_v1.PTransform `` /* 140-byte string literal not displayed */
	// (Required) A map from pipeline-scoped id to PCollection.
	Pcollections map[string]*pipeline_v1.PCollection `` /* 144-byte string literal not displayed */
	// (Required) A map from pipeline-scoped id to WindowingStrategy.
	WindowingStrategies map[string]*pipeline_v1.WindowingStrategy `` /* 185-byte string literal not displayed */
	// (Required) A map from pipeline-scoped id to Coder.
	Coders map[string]*pipeline_v1.Coder `` /* 132-byte string literal not displayed */
	// (Required) A map from pipeline-scoped id to Environment.
	Environments map[string]*pipeline_v1.Environment `` /* 144-byte string literal not displayed */
	// A descriptor describing the end point to use for State API
	// calls. Required if the Runner intends to send remote references over the
	// data plane or if any of the transforms rely on user state or side inputs.
	StateApiServiceDescriptor *pipeline_v1.ApiServiceDescriptor `` /* 133-byte string literal not displayed */
	XXX_NoUnkeyedLiteral      struct{}                          `json:"-"`
	XXX_unrecognized          []byte                            `json:"-"`
	XXX_sizecache             int32                             `json:"-"`
}

Definitions that should be used to construct the bundle processing graph.

func (*ProcessBundleDescriptor) Descriptor 

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

func (*ProcessBundleDescriptor) GetCoders 

func (m *ProcessBundleDescriptor) GetCoders() map[string]*pipeline_v1.Coder

func (*ProcessBundleDescriptor) GetEnvironments 

func (m *ProcessBundleDescriptor) GetEnvironments() map[string]*pipeline_v1.Environment

func (*ProcessBundleDescriptor) GetId 

func (m *ProcessBundleDescriptor) GetId() string

func (*ProcessBundleDescriptor) GetPcollections 

func (m *ProcessBundleDescriptor) GetPcollections() map[string]*pipeline_v1.PCollection

func (*ProcessBundleDescriptor) GetStateApiServiceDescriptor 

func (m *ProcessBundleDescriptor) GetStateApiServiceDescriptor() *pipeline_v1.ApiServiceDescriptor

func (*ProcessBundleDescriptor) GetTransforms 

func (m *ProcessBundleDescriptor) GetTransforms() map[string]*pipeline_v1.PTransform

func (*ProcessBundleDescriptor) GetWindowingStrategies 

func (m *ProcessBundleDescriptor) GetWindowingStrategies() map[string]*pipeline_v1.WindowingStrategy

func (*ProcessBundleDescriptor) ProtoMessage 

func (*ProcessBundleDescriptor) ProtoMessage()

func (*ProcessBundleDescriptor) Reset 

func (m *ProcessBundleDescriptor) Reset()

func (*ProcessBundleDescriptor) String 

func (m *ProcessBundleDescriptor) String() string

func (*ProcessBundleDescriptor) XXX_DiscardUnknown 

func (m *ProcessBundleDescriptor) XXX_DiscardUnknown()

func (*ProcessBundleDescriptor) XXX_Marshal 

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

func (*ProcessBundleDescriptor) XXX_Merge 

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

func (*ProcessBundleDescriptor) XXX_Size 

func (m *ProcessBundleDescriptor) XXX_Size() int

func (*ProcessBundleDescriptor) XXX_Unmarshal 

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

type ProcessBundleProgressRequest 

type ProcessBundleProgressRequest struct {
	// (Required) A reference to an active process bundle request with the given
	// instruction id.
	InstructionReference string   `protobuf:"bytes,1,opt,name=instruction_reference,json=instructionReference" json:"instruction_reference,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A request to report progress information for a given bundle. This is an optional request to be handled and is used to support advanced SDK features such as SplittableDoFn, user level metrics etc.

func (*ProcessBundleProgressRequest) Descriptor 

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

func (*ProcessBundleProgressRequest) GetInstructionReference 

func (m *ProcessBundleProgressRequest) GetInstructionReference() string

func (*ProcessBundleProgressRequest) ProtoMessage 

func (*ProcessBundleProgressRequest) ProtoMessage()

func (*ProcessBundleProgressRequest) Reset 

func (m *ProcessBundleProgressRequest) Reset()

func (*ProcessBundleProgressRequest) String 

func (m *ProcessBundleProgressRequest) String() string

func (*ProcessBundleProgressRequest) XXX_DiscardUnknown 

func (m *ProcessBundleProgressRequest) XXX_DiscardUnknown()

func (*ProcessBundleProgressRequest) XXX_Marshal 

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

func (*ProcessBundleProgressRequest) XXX_Merge 

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

func (*ProcessBundleProgressRequest) XXX_Size 

func (m *ProcessBundleProgressRequest) XXX_Size() int

func (*ProcessBundleProgressRequest) XXX_Unmarshal 

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

type ProcessBundleProgressResponse 

type ProcessBundleProgressResponse struct {
	// (Required)
	Metrics *Metrics `protobuf:"bytes,1,opt,name=metrics" json:"metrics,omitempty"`
	// (Optional) Specifies that the bundle has been split since the last
	// ProcessBundleProgressResponse was sent.
	Split                *BundleSplit `protobuf:"bytes,2,opt,name=split" json:"split,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ProcessBundleProgressResponse) Descriptor 

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

func (*ProcessBundleProgressResponse) GetMetrics 

func (m *ProcessBundleProgressResponse) GetMetrics() *Metrics

func (*ProcessBundleProgressResponse) GetSplit 

func (m *ProcessBundleProgressResponse) GetSplit() *BundleSplit

func (*ProcessBundleProgressResponse) ProtoMessage 

func (*ProcessBundleProgressResponse) ProtoMessage()

func (*ProcessBundleProgressResponse) Reset 

func (m *ProcessBundleProgressResponse) Reset()

func (*ProcessBundleProgressResponse) String 

func (m *ProcessBundleProgressResponse) String() string

func (*ProcessBundleProgressResponse) XXX_DiscardUnknown 

func (m *ProcessBundleProgressResponse) XXX_DiscardUnknown()

func (*ProcessBundleProgressResponse) XXX_Marshal 

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

func (*ProcessBundleProgressResponse) XXX_Merge 

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

func (*ProcessBundleProgressResponse) XXX_Size 

func (m *ProcessBundleProgressResponse) XXX_Size() int

func (*ProcessBundleProgressResponse) XXX_Unmarshal 

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

type ProcessBundleRequest 

type ProcessBundleRequest struct {
	// (Required) A reference to the process bundle descriptor that must be
	// instantiated and executed by the SDK harness.
	ProcessBundleDescriptorReference string `` /* 154-byte string literal not displayed */
	// (Optional) A list of cache tokens that can be used by an SDK to reuse
	// cached data returned by the State API across multiple bundles.
	CacheTokens          [][]byte `protobuf:"bytes,2,rep,name=cache_tokens,json=cacheTokens,proto3" json:"cache_tokens,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A request to process a given bundle. Stable

func (*ProcessBundleRequest) Descriptor 

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

func (*ProcessBundleRequest) GetCacheTokens 

func (m *ProcessBundleRequest) GetCacheTokens() [][]byte

func (*ProcessBundleRequest) GetProcessBundleDescriptorReference 

func (m *ProcessBundleRequest) GetProcessBundleDescriptorReference() string

func (*ProcessBundleRequest) ProtoMessage 

func (*ProcessBundleRequest) ProtoMessage()

func (*ProcessBundleRequest) Reset 

func (m *ProcessBundleRequest) Reset()

func (*ProcessBundleRequest) String 

func (m *ProcessBundleRequest) String() string

func (*ProcessBundleRequest) XXX_DiscardUnknown 

func (m *ProcessBundleRequest) XXX_DiscardUnknown()

func (*ProcessBundleRequest) XXX_Marshal 

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

func (*ProcessBundleRequest) XXX_Merge 

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

func (*ProcessBundleRequest) XXX_Size 

func (m *ProcessBundleRequest) XXX_Size() int

func (*ProcessBundleRequest) XXX_Unmarshal 

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

type ProcessBundleResponse 

type ProcessBundleResponse struct {
	// (Optional) If metrics reporting is supported by the SDK, this represents
	// the final metrics to record for this bundle.
	Metrics *Metrics `protobuf:"bytes,1,opt,name=metrics" json:"metrics,omitempty"`
	// (Optional) Specifies that the bundle has been split since the last
	// ProcessBundleProgressResponse was sent.
	Split                *BundleSplit `protobuf:"bytes,2,opt,name=split" json:"split,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Stable

func (*ProcessBundleResponse) Descriptor 

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

func (*ProcessBundleResponse) GetMetrics 

func (m *ProcessBundleResponse) GetMetrics() *Metrics

func (*ProcessBundleResponse) GetSplit 

func (m *ProcessBundleResponse) GetSplit() *BundleSplit

func (*ProcessBundleResponse) ProtoMessage 

func (*ProcessBundleResponse) ProtoMessage()

func (*ProcessBundleResponse) Reset 

func (m *ProcessBundleResponse) Reset()

func (*ProcessBundleResponse) String 

func (m *ProcessBundleResponse) String() string

func (*ProcessBundleResponse) XXX_DiscardUnknown 

func (m *ProcessBundleResponse) XXX_DiscardUnknown()

func (*ProcessBundleResponse) XXX_Marshal 

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

func (*ProcessBundleResponse) XXX_Merge 

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

func (*ProcessBundleResponse) XXX_Size 

func (m *ProcessBundleResponse) XXX_Size() int

func (*ProcessBundleResponse) XXX_Unmarshal 

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

type ProcessBundleSplitRequest 

type ProcessBundleSplitRequest struct {
	// (Required) A reference to an active process bundle request with the given
	// instruction id.
	InstructionReference string `protobuf:"bytes,1,opt,name=instruction_reference,json=instructionReference" json:"instruction_reference,omitempty"`
	// Specifies that the runner would like the bundle to split itself using
	// BundleSplit, and give up some of the work that the bundle hasn't started
	// doing yet, so that it can be done in a separate bundle (perhaps in
	// parallel with the current bundle).
	//
	// The value is the fraction of unstarted work to keep. E.g. 0 means give up
	// as much as possible of unstarted work (e.g. checkpoint), 0.5 means give
	// up about half of the unstarted work, etc.
	// This is a hint and the value is approximate.
	//
	// The value is relative to the current scope of work of the bundle.
	FractionOfRemainder  *wrappers.DoubleValue `protobuf:"bytes,2,opt,name=fraction_of_remainder,json=fractionOfRemainder" json:"fraction_of_remainder,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ProcessBundleSplitRequest) Descriptor 

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

func (*ProcessBundleSplitRequest) GetFractionOfRemainder 

func (m *ProcessBundleSplitRequest) GetFractionOfRemainder() *wrappers.DoubleValue

func (*ProcessBundleSplitRequest) GetInstructionReference 

func (m *ProcessBundleSplitRequest) GetInstructionReference() string

func (*ProcessBundleSplitRequest) ProtoMessage 

func (*ProcessBundleSplitRequest) ProtoMessage()

func (*ProcessBundleSplitRequest) Reset 

func (m *ProcessBundleSplitRequest) Reset()

func (*ProcessBundleSplitRequest) String 

func (m *ProcessBundleSplitRequest) String() string

func (*ProcessBundleSplitRequest) XXX_DiscardUnknown 

func (m *ProcessBundleSplitRequest) XXX_DiscardUnknown()

func (*ProcessBundleSplitRequest) XXX_Marshal 

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

func (*ProcessBundleSplitRequest) XXX_Merge 

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

func (*ProcessBundleSplitRequest) XXX_Size 

func (m *ProcessBundleSplitRequest) XXX_Size() int

func (*ProcessBundleSplitRequest) XXX_Unmarshal 

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

type ProcessBundleSplitResponse 

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

func (*ProcessBundleSplitResponse) Descriptor 

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

func (*ProcessBundleSplitResponse) ProtoMessage 

func (*ProcessBundleSplitResponse) ProtoMessage()

func (*ProcessBundleSplitResponse) Reset 

func (m *ProcessBundleSplitResponse) Reset()

func (*ProcessBundleSplitResponse) String 

func (m *ProcessBundleSplitResponse) String() string

func (*ProcessBundleSplitResponse) XXX_DiscardUnknown 

func (m *ProcessBundleSplitResponse) XXX_DiscardUnknown()

func (*ProcessBundleSplitResponse) XXX_Marshal 

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

func (*ProcessBundleSplitResponse) XXX_Merge 

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

func (*ProcessBundleSplitResponse) XXX_Size 

func (m *ProcessBundleSplitResponse) XXX_Size() int

func (*ProcessBundleSplitResponse) XXX_Unmarshal 

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

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) The worker ID. Often this will be the hostname.
	//
	// This is independent of the id passed to the SDK harness via the 'id'
	// argument in the Beam container contract.
	WorkerId string `protobuf:"bytes,5,opt,name=worker_id,json=workerId" json:"worker_id,omitempty"`
	// (required) Pipeline options. For non-template jobs, the options are
	// identical to what is passed to job submission.
	PipelineOptions *_struct.Struct `protobuf:"bytes,3,opt,name=pipeline_options,json=pipelineOptions" json:"pipeline_options,omitempty"`
	// (optional) Resource limits that the SDK harness worker should respect.
	// Runners may -- but are not required to -- enforce any limits provided.
	ResourceLimits       *Resources `protobuf:"bytes,4,opt,name=resource_limits,json=resourceLimits" json:"resource_limits,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

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() *_struct.Struct

func (*ProvisionInfo) GetResourceLimits 

func (m *ProvisionInfo) GetResourceLimits() *Resources

func (*ProvisionInfo) GetWorkerId 

func (m *ProvisionInfo) GetWorkerId() string

func (*ProvisionInfo) ProtoMessage 

func (*ProvisionInfo) ProtoMessage()

func (*ProvisionInfo) Reset 

func (m *ProvisionInfo) Reset()

func (*ProvisionInfo) String 

func (m *ProvisionInfo) String() string

func (*ProvisionInfo) XXX_DiscardUnknown 

func (m *ProvisionInfo) XXX_DiscardUnknown()

func (*ProvisionInfo) XXX_Marshal 

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

func (*ProvisionInfo) XXX_Merge 

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

func (*ProvisionInfo) XXX_Size 

func (m *ProvisionInfo) XXX_Size() int

func (*ProvisionInfo) XXX_Unmarshal 

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

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)
}

ProvisionServiceClient is the client API for ProvisionService service.

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

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)
}

ProvisionServiceServer is the server API for ProvisionService service.

type RegisterRequest 

type RegisterRequest struct {
	// (Optional) The set of descriptors used to process bundles.
	ProcessBundleDescriptor []*ProcessBundleDescriptor `protobuf:"bytes,1,rep,name=process_bundle_descriptor,json=processBundleDescriptor" json:"process_bundle_descriptor,omitempty"`
	XXX_NoUnkeyedLiteral    struct{}                   `json:"-"`
	XXX_unrecognized        []byte                     `json:"-"`
	XXX_sizecache           int32                      `json:"-"`
}

A list of objects which can be referred to by the runner in future requests. Stable

func (*RegisterRequest) Descriptor 

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

func (*RegisterRequest) GetProcessBundleDescriptor 

func (m *RegisterRequest) GetProcessBundleDescriptor() []*ProcessBundleDescriptor

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) Reset 

func (m *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (m *RegisterRequest) String() string

func (*RegisterRequest) XXX_DiscardUnknown 

func (m *RegisterRequest) XXX_DiscardUnknown()

func (*RegisterRequest) XXX_Marshal 

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

func (*RegisterRequest) XXX_Merge 

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

func (*RegisterRequest) XXX_Size 

func (m *RegisterRequest) XXX_Size() int

func (*RegisterRequest) XXX_Unmarshal 

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

type RegisterResponse 

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

Stable

func (*RegisterResponse) Descriptor 

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

func (*RegisterResponse) ProtoMessage 

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) Reset 

func (m *RegisterResponse) Reset()

func (*RegisterResponse) String 

func (m *RegisterResponse) String() string

func (*RegisterResponse) XXX_DiscardUnknown 

func (m *RegisterResponse) XXX_DiscardUnknown()

func (*RegisterResponse) XXX_Marshal 

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

func (*RegisterResponse) XXX_Merge 

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

func (*RegisterResponse) XXX_Size 

func (m *RegisterResponse) XXX_Size() int

func (*RegisterResponse) XXX_Unmarshal 

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

type RemoteGrpcPort 

type RemoteGrpcPort struct {
	// (Required) An API descriptor which describes where to
	// connect to including any authentication that is required.
	ApiServiceDescriptor *pipeline_v1.ApiServiceDescriptor `protobuf:"bytes,1,opt,name=api_service_descriptor,json=apiServiceDescriptor" json:"api_service_descriptor,omitempty"`
	// (Required) The ID of the Coder that will be used to encode and decode data sent over this port.
	CoderId              string   `protobuf:"bytes,2,opt,name=coder_id,json=coderId" json:"coder_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A descriptor for connecting to a remote port using the Beam Fn Data API. Allows for communication between two environments (for example between the runner and the SDK). Stable

func (*RemoteGrpcPort) Descriptor 

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

func (*RemoteGrpcPort) GetApiServiceDescriptor 

func (m *RemoteGrpcPort) GetApiServiceDescriptor() *pipeline_v1.ApiServiceDescriptor

func (*RemoteGrpcPort) GetCoderId 

func (m *RemoteGrpcPort) GetCoderId() string

func (*RemoteGrpcPort) ProtoMessage 

func (*RemoteGrpcPort) ProtoMessage()

func (*RemoteGrpcPort) Reset 

func (m *RemoteGrpcPort) Reset()

func (*RemoteGrpcPort) String 

func (m *RemoteGrpcPort) String() string

func (*RemoteGrpcPort) XXX_DiscardUnknown 

func (m *RemoteGrpcPort) XXX_DiscardUnknown()

func (*RemoteGrpcPort) XXX_Marshal 

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

func (*RemoteGrpcPort) XXX_Merge 

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

func (*RemoteGrpcPort) XXX_Size 

func (m *RemoteGrpcPort) XXX_Size() int

func (*RemoteGrpcPort) XXX_Unmarshal 

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

type Resources 

type Resources struct {
	// (optional) Memory usage limits. SDKs can use this value to configure
	// internal buffer sizes and language specific sizes.
	Memory *Resources_Memory `protobuf:"bytes,1,opt,name=memory" json:"memory,omitempty"`
	// (optional) CPU usage limits.
	Cpu *Resources_Cpu `protobuf:"bytes,2,opt,name=cpu" json:"cpu,omitempty"`
	// (optional) Disk size limits for the semi-persistent location.
	SemiPersistentDisk   *Resources_Disk `protobuf:"bytes,3,opt,name=semi_persistent_disk,json=semiPersistentDisk" json:"semi_persistent_disk,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Resources specify limits for local resources, such memory and cpu. It is used to inform SDK harnesses of their allocated footprint.

func (*Resources) Descriptor 

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

func (*Resources) GetCpu 

func (m *Resources) GetCpu() *Resources_Cpu

func (*Resources) GetMemory 

func (m *Resources) GetMemory() *Resources_Memory

func (*Resources) GetSemiPersistentDisk 

func (m *Resources) GetSemiPersistentDisk() *Resources_Disk

func (*Resources) ProtoMessage 

func (*Resources) ProtoMessage()

func (*Resources) Reset 

func (m *Resources) Reset()

func (*Resources) String 

func (m *Resources) String() string

func (*Resources) XXX_DiscardUnknown 

func (m *Resources) XXX_DiscardUnknown()

func (*Resources) XXX_Marshal 

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

func (*Resources) XXX_Merge 

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

func (*Resources) XXX_Size 

func (m *Resources) XXX_Size() int

func (*Resources) XXX_Unmarshal 

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

type Resources_Cpu 

type Resources_Cpu struct {
	// (optional) Shares of a cpu to use. Fractional values, such as "0.2"
	// or "2.5", are fine. Any value <= 0 means unspecified.
	Shares               float32  `protobuf:"fixed32,1,opt,name=shares" json:"shares,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CPU limits.

func (*Resources_Cpu) Descriptor 

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

func (*Resources_Cpu) GetShares 

func (m *Resources_Cpu) GetShares() float32

func (*Resources_Cpu) ProtoMessage 

func (*Resources_Cpu) ProtoMessage()

func (*Resources_Cpu) Reset 

func (m *Resources_Cpu) Reset()

func (*Resources_Cpu) String 

func (m *Resources_Cpu) String() string

func (*Resources_Cpu) XXX_DiscardUnknown 

func (m *Resources_Cpu) XXX_DiscardUnknown()

func (*Resources_Cpu) XXX_Marshal 

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

func (*Resources_Cpu) XXX_Merge 

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

func (*Resources_Cpu) XXX_Size 

func (m *Resources_Cpu) XXX_Size() int

func (*Resources_Cpu) XXX_Unmarshal 

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

type Resources_Disk 

type Resources_Disk struct {
	// (optional) Hard limit in bytes. A zero value means unspecified.
	Size                 uint64   `protobuf:"varint,1,opt,name=size" json:"size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Disk limits.

func (*Resources_Disk) Descriptor 

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

func (*Resources_Disk) GetSize 

func (m *Resources_Disk) GetSize() uint64

func (*Resources_Disk) ProtoMessage 

func (*Resources_Disk) ProtoMessage()

func (*Resources_Disk) Reset 

func (m *Resources_Disk) Reset()

func (*Resources_Disk) String 

func (m *Resources_Disk) String() string

func (*Resources_Disk) XXX_DiscardUnknown 

func (m *Resources_Disk) XXX_DiscardUnknown()

func (*Resources_Disk) XXX_Marshal 

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

func (*Resources_Disk) XXX_Merge 

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

func (*Resources_Disk) XXX_Size 

func (m *Resources_Disk) XXX_Size() int

func (*Resources_Disk) XXX_Unmarshal 

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

type Resources_Memory 

type Resources_Memory struct {
	// (optional) Hard limit in bytes. A zero value means unspecified.
	Size                 uint64   `protobuf:"varint,1,opt,name=size" json:"size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Memory limits.

func (*Resources_Memory) Descriptor 

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

func (*Resources_Memory) GetSize 

func (m *Resources_Memory) GetSize() uint64

func (*Resources_Memory) ProtoMessage 

func (*Resources_Memory) ProtoMessage()

func (*Resources_Memory) Reset 

func (m *Resources_Memory) Reset()

func (*Resources_Memory) String 

func (m *Resources_Memory) String() string

func (*Resources_Memory) XXX_DiscardUnknown 

func (m *Resources_Memory) XXX_DiscardUnknown()

func (*Resources_Memory) XXX_Marshal 

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

func (*Resources_Memory) XXX_Merge 

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

func (*Resources_Memory) XXX_Size 

func (m *Resources_Memory) XXX_Size() int

func (*Resources_Memory) XXX_Unmarshal 

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

type StateAppendRequest 

type StateAppendRequest struct {
	// Represents a part of a logical byte stream. Elements within
	// the logical byte stream are encoded in the nested context and
	// multiple append requests are concatenated together.
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A request to append state.

func (*StateAppendRequest) Descriptor 

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

func (*StateAppendRequest) GetData 

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

func (*StateAppendRequest) ProtoMessage 

func (*StateAppendRequest) ProtoMessage()

func (*StateAppendRequest) Reset 

func (m *StateAppendRequest) Reset()

func (*StateAppendRequest) String 

func (m *StateAppendRequest) String() string

func (*StateAppendRequest) XXX_DiscardUnknown 

func (m *StateAppendRequest) XXX_DiscardUnknown()

func (*StateAppendRequest) XXX_Marshal 

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

func (*StateAppendRequest) XXX_Merge 

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

func (*StateAppendRequest) XXX_Size 

func (m *StateAppendRequest) XXX_Size() int

func (*StateAppendRequest) XXX_Unmarshal 

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

type StateAppendResponse 

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

A response to append state.

func (*StateAppendResponse) Descriptor 

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

func (*StateAppendResponse) ProtoMessage 

func (*StateAppendResponse) ProtoMessage()

func (*StateAppendResponse) Reset 

func (m *StateAppendResponse) Reset()

func (*StateAppendResponse) String 

func (m *StateAppendResponse) String() string

func (*StateAppendResponse) XXX_DiscardUnknown 

func (m *StateAppendResponse) XXX_DiscardUnknown()

func (*StateAppendResponse) XXX_Marshal 

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

func (*StateAppendResponse) XXX_Merge 

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

func (*StateAppendResponse) XXX_Size 

func (m *StateAppendResponse) XXX_Size() int

func (*StateAppendResponse) XXX_Unmarshal 

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

type StateClearRequest 

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

A request to clear state.

func (*StateClearRequest) Descriptor 

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

func (*StateClearRequest) ProtoMessage 

func (*StateClearRequest) ProtoMessage()

func (*StateClearRequest) Reset 

func (m *StateClearRequest) Reset()

func (*StateClearRequest) String 

func (m *StateClearRequest) String() string

func (*StateClearRequest) XXX_DiscardUnknown 

func (m *StateClearRequest) XXX_DiscardUnknown()

func (*StateClearRequest) XXX_Marshal 

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

func (*StateClearRequest) XXX_Merge 

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

func (*StateClearRequest) XXX_Size 

func (m *StateClearRequest) XXX_Size() int

func (*StateClearRequest) XXX_Unmarshal 

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

type StateClearResponse 

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

A response to clear state.

func (*StateClearResponse) Descriptor 

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

func (*StateClearResponse) ProtoMessage 

func (*StateClearResponse) ProtoMessage()

func (*StateClearResponse) Reset 

func (m *StateClearResponse) Reset()

func (*StateClearResponse) String 

func (m *StateClearResponse) String() string

func (*StateClearResponse) XXX_DiscardUnknown 

func (m *StateClearResponse) XXX_DiscardUnknown()

func (*StateClearResponse) XXX_Marshal 

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

func (*StateClearResponse) XXX_Merge 

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

func (*StateClearResponse) XXX_Size 

func (m *StateClearResponse) XXX_Size() int

func (*StateClearResponse) XXX_Unmarshal 

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

type StateGetRequest 

type StateGetRequest struct {
	// (Optional) If specified, signals to the runner that the response
	// should resume from the following continuation token.
	//
	// If unspecified, signals to the runner that the response should start
	// from the beginning of the logical continuable stream.
	ContinuationToken    []byte   `protobuf:"bytes,1,opt,name=continuation_token,json=continuationToken,proto3" json:"continuation_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A request to get state.

func (*StateGetRequest) Descriptor 

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

func (*StateGetRequest) GetContinuationToken 

func (m *StateGetRequest) GetContinuationToken() []byte

func (*StateGetRequest) ProtoMessage 

func (*StateGetRequest) ProtoMessage()

func (*StateGetRequest) Reset 

func (m *StateGetRequest) Reset()

func (*StateGetRequest) String 

func (m *StateGetRequest) String() string

func (*StateGetRequest) XXX_DiscardUnknown 

func (m *StateGetRequest) XXX_DiscardUnknown()

func (*StateGetRequest) XXX_Marshal 

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

func (*StateGetRequest) XXX_Merge 

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

func (*StateGetRequest) XXX_Size 

func (m *StateGetRequest) XXX_Size() int

func (*StateGetRequest) XXX_Unmarshal 

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

type StateGetResponse 

type StateGetResponse struct {
	// (Optional) If specified, represents a token which can be used with the
	// state API to get the next chunk of this logical byte stream. The end of
	// the logical byte stream is signalled by this field being unset.
	ContinuationToken []byte `protobuf:"bytes,1,opt,name=continuation_token,json=continuationToken,proto3" json:"continuation_token,omitempty"`
	// Represents a part of a logical byte stream. Elements within
	// the logical byte stream are encoded in the nested context and
	// concatenated together.
	Data                 []byte   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A response to get state representing a logical byte stream which can be continued using the state API.

func (*StateGetResponse) Descriptor 

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

func (*StateGetResponse) GetContinuationToken 

func (m *StateGetResponse) GetContinuationToken() []byte

func (*StateGetResponse) GetData 

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

func (*StateGetResponse) ProtoMessage 

func (*StateGetResponse) ProtoMessage()

func (*StateGetResponse) Reset 

func (m *StateGetResponse) Reset()

func (*StateGetResponse) String 

func (m *StateGetResponse) String() string

func (*StateGetResponse) XXX_DiscardUnknown 

func (m *StateGetResponse) XXX_DiscardUnknown()

func (*StateGetResponse) XXX_Marshal 

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

func (*StateGetResponse) XXX_Merge 

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

func (*StateGetResponse) XXX_Size 

func (m *StateGetResponse) XXX_Size() int

func (*StateGetResponse) XXX_Unmarshal 

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

type StateKey 

type StateKey struct {
	// (Required) One of the following state keys must be set.
	//
	// Types that are valid to be assigned to Type:
	//	*StateKey_Runner_
	//	*StateKey_MultimapSideInput_
	//	*StateKey_BagUserState_
	Type                 isStateKey_Type `protobuf_oneof:"type"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*StateKey) Descriptor 

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

func (*StateKey) GetBagUserState 

func (m *StateKey) GetBagUserState() *StateKey_BagUserState

func (*StateKey) GetMultimapSideInput 

func (m *StateKey) GetMultimapSideInput() *StateKey_MultimapSideInput

func (*StateKey) GetRunner 

func (m *StateKey) GetRunner() *StateKey_Runner

func (*StateKey) GetType 

func (m *StateKey) GetType() isStateKey_Type

func (*StateKey) ProtoMessage 

func (*StateKey) ProtoMessage()

func (*StateKey) Reset 

func (m *StateKey) Reset()

func (*StateKey) String 

func (m *StateKey) String() string

func (*StateKey) XXX_DiscardUnknown 

func (m *StateKey) XXX_DiscardUnknown()

func (*StateKey) XXX_Marshal 

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

func (*StateKey) XXX_Merge 

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

func (*StateKey) XXX_OneofFuncs 

func (*StateKey) 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 (*StateKey) XXX_Size 

func (m *StateKey) XXX_Size() int

func (*StateKey) XXX_Unmarshal 

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

type StateKey_BagUserState 

type StateKey_BagUserState struct {
	// (Required) The id of the PTransform containing user state.
	PtransformId string `protobuf:"bytes,1,opt,name=ptransform_id,json=ptransformId" json:"ptransform_id,omitempty"`
	// (Required) The id of the user state.
	UserStateId string `protobuf:"bytes,2,opt,name=user_state_id,json=userStateId" json:"user_state_id,omitempty"`
	// (Required) The window encoded in a nested context.
	Window []byte `protobuf:"bytes,3,opt,name=window,proto3" json:"window,omitempty"`
	// (Required) The key of the currently executing element encoded in a
	// nested context.
	Key                  []byte   `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StateKey_BagUserState) Descriptor 

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

func (*StateKey_BagUserState) GetKey 

func (m *StateKey_BagUserState) GetKey() []byte

func (*StateKey_BagUserState) GetPtransformId 

func (m *StateKey_BagUserState) GetPtransformId() string

func (*StateKey_BagUserState) GetUserStateId 

func (m *StateKey_BagUserState) GetUserStateId() string

func (*StateKey_BagUserState) GetWindow 

func (m *StateKey_BagUserState) GetWindow() []byte

func (*StateKey_BagUserState) ProtoMessage 

func (*StateKey_BagUserState) ProtoMessage()

func (*StateKey_BagUserState) Reset 

func (m *StateKey_BagUserState) Reset()

func (*StateKey_BagUserState) String 

func (m *StateKey_BagUserState) String() string

func (*StateKey_BagUserState) XXX_DiscardUnknown 

func (m *StateKey_BagUserState) XXX_DiscardUnknown()

func (*StateKey_BagUserState) XXX_Marshal 

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

func (*StateKey_BagUserState) XXX_Merge 

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

func (*StateKey_BagUserState) XXX_Size 

func (m *StateKey_BagUserState) XXX_Size() int

func (*StateKey_BagUserState) XXX_Unmarshal 

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

type StateKey_BagUserState_ 

type StateKey_BagUserState_ struct {
	BagUserState *StateKey_BagUserState `protobuf:"bytes,3,opt,name=bag_user_state,json=bagUserState,oneof"`
}

type StateKey_MultimapSideInput 

type StateKey_MultimapSideInput struct {
	// (Required) The id of the PTransform containing a side input.
	PtransformId string `protobuf:"bytes,1,opt,name=ptransform_id,json=ptransformId" json:"ptransform_id,omitempty"`
	// (Required) The id of the side input.
	SideInputId string `protobuf:"bytes,2,opt,name=side_input_id,json=sideInputId" json:"side_input_id,omitempty"`
	// (Required) The window (after mapping the currently executing elements
	// window into the side input windows domain) encoded in a nested context.
	Window []byte `protobuf:"bytes,3,opt,name=window,proto3" json:"window,omitempty"`
	// (Required) The key encoded in a nested context.
	Key                  []byte   `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StateKey_MultimapSideInput) Descriptor 

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

func (*StateKey_MultimapSideInput) GetKey 

func (m *StateKey_MultimapSideInput) GetKey() []byte

func (*StateKey_MultimapSideInput) GetPtransformId 

func (m *StateKey_MultimapSideInput) GetPtransformId() string

func (*StateKey_MultimapSideInput) GetSideInputId 

func (m *StateKey_MultimapSideInput) GetSideInputId() string

func (*StateKey_MultimapSideInput) GetWindow 

func (m *StateKey_MultimapSideInput) GetWindow() []byte

func (*StateKey_MultimapSideInput) ProtoMessage 

func (*StateKey_MultimapSideInput) ProtoMessage()

func (*StateKey_MultimapSideInput) Reset 

func (m *StateKey_MultimapSideInput) Reset()

func (*StateKey_MultimapSideInput) String 

func (m *StateKey_MultimapSideInput) String() string

func (*StateKey_MultimapSideInput) XXX_DiscardUnknown 

func (m *StateKey_MultimapSideInput) XXX_DiscardUnknown()

func (*StateKey_MultimapSideInput) XXX_Marshal 

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

func (*StateKey_MultimapSideInput) XXX_Merge 

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

func (*StateKey_MultimapSideInput) XXX_Size 

func (m *StateKey_MultimapSideInput) XXX_Size() int

func (*StateKey_MultimapSideInput) XXX_Unmarshal 

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

type StateKey_MultimapSideInput_ 

type StateKey_MultimapSideInput_ struct {
	MultimapSideInput *StateKey_MultimapSideInput `protobuf:"bytes,2,opt,name=multimap_side_input,json=multimapSideInput,oneof"`
}

type StateKey_Runner 

type StateKey_Runner struct {
	// (Required) Opaque information supplied by the runner. Used to support
	// remote references.
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StateKey_Runner) Descriptor 

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

func (*StateKey_Runner) GetKey 

func (m *StateKey_Runner) GetKey() []byte

func (*StateKey_Runner) ProtoMessage 

func (*StateKey_Runner) ProtoMessage()

func (*StateKey_Runner) Reset 

func (m *StateKey_Runner) Reset()

func (*StateKey_Runner) String 

func (m *StateKey_Runner) String() string

func (*StateKey_Runner) XXX_DiscardUnknown 

func (m *StateKey_Runner) XXX_DiscardUnknown()

func (*StateKey_Runner) XXX_Marshal 

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

func (*StateKey_Runner) XXX_Merge 

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

func (*StateKey_Runner) XXX_Size 

func (m *StateKey_Runner) XXX_Size() int

func (*StateKey_Runner) XXX_Unmarshal 

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

type StateKey_Runner_ 

type StateKey_Runner_ struct {
	Runner *StateKey_Runner `protobuf:"bytes,1,opt,name=runner,oneof"`
}

type StateRequest 

type StateRequest struct {
	// (Required) An unique identifier provided by the SDK which represents this
	// requests execution. The StateResponse corresponding with this request
	// will have the matching id.
	Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	// (Required) The associated instruction id of the work that is currently
	// being processed. This allows for the runner to associate any modifications
	// to state to be committed with the appropriate work execution.
	InstructionReference string `protobuf:"bytes,2,opt,name=instruction_reference,json=instructionReference" json:"instruction_reference,omitempty"`
	// (Required) The state key this request is for.
	StateKey *StateKey `protobuf:"bytes,3,opt,name=state_key,json=stateKey" json:"state_key,omitempty"`
	// (Required) The action to take on this request.
	//
	// Types that are valid to be assigned to Request:
	//	*StateRequest_Get
	//	*StateRequest_Append
	//	*StateRequest_Clear
	Request              isStateRequest_Request `protobuf_oneof:"request"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*StateRequest) Descriptor 

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

func (*StateRequest) GetAppend 

func (m *StateRequest) GetAppend() *StateAppendRequest

func (*StateRequest) GetClear 

func (m *StateRequest) GetClear() *StateClearRequest

func (*StateRequest) GetGet 

func (m *StateRequest) GetGet() *StateGetRequest

func (*StateRequest) GetId 

func (m *StateRequest) GetId() string

func (*StateRequest) GetInstructionReference 

func (m *StateRequest) GetInstructionReference() string

func (*StateRequest) GetRequest 

func (m *StateRequest) GetRequest() isStateRequest_Request

func (*StateRequest) GetStateKey 

func (m *StateRequest) GetStateKey() *StateKey

func (*StateRequest) ProtoMessage 

func (*StateRequest) ProtoMessage()

func (*StateRequest) Reset 

func (m *StateRequest) Reset()

func (*StateRequest) String 

func (m *StateRequest) String() string

func (*StateRequest) XXX_DiscardUnknown 

func (m *StateRequest) XXX_DiscardUnknown()

func (*StateRequest) XXX_Marshal 

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

func (*StateRequest) XXX_Merge 

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

func (*StateRequest) XXX_OneofFuncs 

func (*StateRequest) 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 (*StateRequest) XXX_Size 

func (m *StateRequest) XXX_Size() int

func (*StateRequest) XXX_Unmarshal 

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

type StateRequest_Append 

type StateRequest_Append struct {
	Append *StateAppendRequest `protobuf:"bytes,1001,opt,name=append,oneof"`
}

type StateRequest_Clear 

type StateRequest_Clear struct {
	Clear *StateClearRequest `protobuf:"bytes,1002,opt,name=clear,oneof"`
}

type StateRequest_Get 

type StateRequest_Get struct {
	Get *StateGetRequest `protobuf:"bytes,1000,opt,name=get,oneof"`
}

type StateResponse 

type StateResponse struct {
	// (Required) A reference provided by the SDK which represents a requests
	// execution. The StateResponse must have the matching id when responding
	// to the SDK.
	Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	// (Optional) If this is specified, then the state request has failed.
	// A human readable string representing the reason as to why the request
	// failed.
	Error string `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	// (Optional) If this is specified, then the result of this state request
	// can be cached using the supplied token.
	CacheToken []byte `protobuf:"bytes,3,opt,name=cache_token,json=cacheToken,proto3" json:"cache_token,omitempty"`
	// A corresponding response matching the request will be populated.
	//
	// Types that are valid to be assigned to Response:
	//	*StateResponse_Get
	//	*StateResponse_Append
	//	*StateResponse_Clear
	Response             isStateResponse_Response `protobuf_oneof:"response"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*StateResponse) Descriptor 

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

func (*StateResponse) GetAppend 

func (m *StateResponse) GetAppend() *StateAppendResponse

func (*StateResponse) GetCacheToken 

func (m *StateResponse) GetCacheToken() []byte

func (*StateResponse) GetClear 

func (m *StateResponse) GetClear() *StateClearResponse

func (*StateResponse) GetError 

func (m *StateResponse) GetError() string

func (*StateResponse) GetGet 

func (m *StateResponse) GetGet() *StateGetResponse

func (*StateResponse) GetId 

func (m *StateResponse) GetId() string

func (*StateResponse) GetResponse 

func (m *StateResponse) GetResponse() isStateResponse_Response

func (*StateResponse) ProtoMessage 

func (*StateResponse) ProtoMessage()

func (*StateResponse) Reset 

func (m *StateResponse) Reset()

func (*StateResponse) String 

func (m *StateResponse) String() string

func (*StateResponse) XXX_DiscardUnknown 

func (m *StateResponse) XXX_DiscardUnknown()

func (*StateResponse) XXX_Marshal 

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

func (*StateResponse) XXX_Merge 

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

func (*StateResponse) XXX_OneofFuncs 

func (*StateResponse) 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 (*StateResponse) XXX_Size 

func (m *StateResponse) XXX_Size() int

func (*StateResponse) XXX_Unmarshal 

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

type StateResponse_Append 

type StateResponse_Append struct {
	Append *StateAppendResponse `protobuf:"bytes,1001,opt,name=append,oneof"`
}

type StateResponse_Clear 

type StateResponse_Clear struct {
	Clear *StateClearResponse `protobuf:"bytes,1002,opt,name=clear,oneof"`
}

type StateResponse_Get 

type StateResponse_Get struct {
	Get *StateGetResponse `protobuf:"bytes,1000,opt,name=get,oneof"`
}

type Target 

type Target struct {
	// (Required) The id of the PrimitiveTransform which is the target.
	PrimitiveTransformReference string `` /* 137-byte string literal not displayed */
	// (Required) The local name of an input or output defined on the primitive
	// transform.
	Name                 string   `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A representation of an input or output definition on a primitive transform. Stable

func (*Target) Descriptor 

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

func (*Target) GetName 

func (m *Target) GetName() string

func (*Target) GetPrimitiveTransformReference 

func (m *Target) GetPrimitiveTransformReference() string

func (*Target) ProtoMessage 

func (*Target) ProtoMessage()

func (*Target) Reset 

func (m *Target) Reset()

func (*Target) String 

func (m *Target) String() string

func (*Target) XXX_DiscardUnknown 

func (m *Target) XXX_DiscardUnknown()

func (*Target) XXX_Marshal 

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

func (*Target) XXX_Merge 

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

func (*Target) XXX_Size 

func (m *Target) XXX_Size() int

func (*Target) XXX_Unmarshal 

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

type Target_List 

type Target_List struct {
	Target               []*Target `protobuf:"bytes,1,rep,name=target" json:"target,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

A repeated list of target definitions.

func (*Target_List) Descriptor 

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

func (*Target_List) GetTarget 

func (m *Target_List) GetTarget() []*Target

func (*Target_List) ProtoMessage 

func (*Target_List) ProtoMessage()

func (*Target_List) Reset 

func (m *Target_List) Reset()

func (*Target_List) String 

func (m *Target_List) String() string

func (*Target_List) XXX_DiscardUnknown 

func (m *Target_List) XXX_DiscardUnknown()

func (*Target_List) XXX_Marshal 

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

func (*Target_List) XXX_Merge 

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

func (*Target_List) XXX_Size 

func (m *Target_List) XXX_Size() int

func (*Target_List) XXX_Unmarshal 

func (m *Target_List) 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.