Documentation ¶
Index ¶
- Variables
- func RegisterBeamFnControlServer(s *grpc.Server, srv BeamFnControlServer)
- func RegisterBeamFnDataServer(s *grpc.Server, srv BeamFnDataServer)
- func RegisterBeamFnExternalWorkerPoolServer(s *grpc.Server, srv BeamFnExternalWorkerPoolServer)
- func RegisterBeamFnLoggingServer(s *grpc.Server, srv BeamFnLoggingServer)
- func RegisterBeamFnStateServer(s *grpc.Server, srv BeamFnStateServer)
- func RegisterBeamFnWorkerStatusServer(s *grpc.Server, srv BeamFnWorkerStatusServer)
- func RegisterProvisionServiceServer(s *grpc.Server, srv ProvisionServiceServer)
- type BeamFnControlClient
- type BeamFnControlServer
- type BeamFnControl_ControlClient
- type BeamFnControl_ControlServer
- type BeamFnDataClient
- type BeamFnDataServer
- type BeamFnData_DataClient
- type BeamFnData_DataServer
- type BeamFnExternalWorkerPoolClient
- type BeamFnExternalWorkerPoolServer
- type BeamFnLoggingClient
- type BeamFnLoggingServer
- type BeamFnLogging_LoggingClient
- type BeamFnLogging_LoggingServer
- type BeamFnStateClient
- type BeamFnStateServer
- type BeamFnState_StateClient
- type BeamFnState_StateServer
- type BeamFnWorkerStatusClient
- type BeamFnWorkerStatusServer
- type BeamFnWorkerStatus_WorkerStatusClient
- type BeamFnWorkerStatus_WorkerStatusServer
- type BundleApplication
- func (*BundleApplication) Descriptor() ([]byte, []int)
- func (m *BundleApplication) GetElement() []byte
- func (m *BundleApplication) GetInputId() string
- func (m *BundleApplication) GetIsBounded() pipeline_v1.IsBounded_Enum
- func (m *BundleApplication) GetOutputWatermarks() map[string]*timestamp.Timestamp
- func (m *BundleApplication) GetTransformId() string
- func (*BundleApplication) ProtoMessage()
- func (m *BundleApplication) Reset()
- func (m *BundleApplication) String() string
- func (m *BundleApplication) XXX_DiscardUnknown()
- func (m *BundleApplication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BundleApplication) XXX_Merge(src proto.Message)
- func (m *BundleApplication) XXX_Size() int
- func (m *BundleApplication) XXX_Unmarshal(b []byte) error
- type DelayedBundleApplication
- func (*DelayedBundleApplication) Descriptor() ([]byte, []int)
- func (m *DelayedBundleApplication) GetApplication() *BundleApplication
- func (m *DelayedBundleApplication) GetRequestedTimeDelay() *duration.Duration
- func (*DelayedBundleApplication) ProtoMessage()
- func (m *DelayedBundleApplication) Reset()
- func (m *DelayedBundleApplication) String() string
- func (m *DelayedBundleApplication) XXX_DiscardUnknown()
- func (m *DelayedBundleApplication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DelayedBundleApplication) XXX_Merge(src proto.Message)
- func (m *DelayedBundleApplication) XXX_Size() int
- func (m *DelayedBundleApplication) XXX_Unmarshal(b []byte) error
- type Elements
- func (*Elements) Descriptor() ([]byte, []int)
- func (m *Elements) GetData() []*Elements_Data
- func (m *Elements) GetTimers() []*Elements_Timers
- func (*Elements) ProtoMessage()
- func (m *Elements) Reset()
- func (m *Elements) String() string
- func (m *Elements) XXX_DiscardUnknown()
- func (m *Elements) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Elements) XXX_Merge(src proto.Message)
- func (m *Elements) XXX_Size() int
- func (m *Elements) XXX_Unmarshal(b []byte) error
- type Elements_Data
- func (*Elements_Data) Descriptor() ([]byte, []int)
- func (m *Elements_Data) GetData() []byte
- func (m *Elements_Data) GetInstructionId() string
- func (m *Elements_Data) GetIsLast() bool
- func (m *Elements_Data) GetTransformId() string
- func (*Elements_Data) ProtoMessage()
- func (m *Elements_Data) Reset()
- func (m *Elements_Data) String() string
- func (m *Elements_Data) XXX_DiscardUnknown()
- func (m *Elements_Data) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Elements_Data) XXX_Merge(src proto.Message)
- func (m *Elements_Data) XXX_Size() int
- func (m *Elements_Data) XXX_Unmarshal(b []byte) error
- type Elements_Timers
- func (*Elements_Timers) Descriptor() ([]byte, []int)
- func (m *Elements_Timers) GetInstructionId() string
- func (m *Elements_Timers) GetIsLast() bool
- func (m *Elements_Timers) GetTimerFamilyId() string
- func (m *Elements_Timers) GetTimers() []byte
- func (m *Elements_Timers) GetTransformId() string
- func (*Elements_Timers) ProtoMessage()
- func (m *Elements_Timers) Reset()
- func (m *Elements_Timers) String() string
- func (m *Elements_Timers) XXX_DiscardUnknown()
- func (m *Elements_Timers) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Elements_Timers) XXX_Merge(src proto.Message)
- func (m *Elements_Timers) XXX_Size() int
- func (m *Elements_Timers) XXX_Unmarshal(b []byte) error
- type FinalizeBundleRequest
- func (*FinalizeBundleRequest) Descriptor() ([]byte, []int)
- func (m *FinalizeBundleRequest) GetInstructionId() string
- func (*FinalizeBundleRequest) ProtoMessage()
- func (m *FinalizeBundleRequest) Reset()
- func (m *FinalizeBundleRequest) String() string
- func (m *FinalizeBundleRequest) XXX_DiscardUnknown()
- func (m *FinalizeBundleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FinalizeBundleRequest) XXX_Merge(src proto.Message)
- func (m *FinalizeBundleRequest) XXX_Size() int
- func (m *FinalizeBundleRequest) XXX_Unmarshal(b []byte) error
- type FinalizeBundleResponse
- func (*FinalizeBundleResponse) Descriptor() ([]byte, []int)
- func (*FinalizeBundleResponse) ProtoMessage()
- func (m *FinalizeBundleResponse) Reset()
- func (m *FinalizeBundleResponse) String() string
- func (m *FinalizeBundleResponse) XXX_DiscardUnknown()
- func (m *FinalizeBundleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FinalizeBundleResponse) XXX_Merge(src proto.Message)
- func (m *FinalizeBundleResponse) XXX_Size() int
- func (m *FinalizeBundleResponse) XXX_Unmarshal(b []byte) error
- type GetProcessBundleDescriptorRequest
- func (*GetProcessBundleDescriptorRequest) Descriptor() ([]byte, []int)
- func (m *GetProcessBundleDescriptorRequest) GetProcessBundleDescriptorId() string
- func (*GetProcessBundleDescriptorRequest) ProtoMessage()
- func (m *GetProcessBundleDescriptorRequest) Reset()
- func (m *GetProcessBundleDescriptorRequest) String() string
- func (m *GetProcessBundleDescriptorRequest) XXX_DiscardUnknown()
- func (m *GetProcessBundleDescriptorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetProcessBundleDescriptorRequest) XXX_Merge(src proto.Message)
- func (m *GetProcessBundleDescriptorRequest) XXX_Size() int
- func (m *GetProcessBundleDescriptorRequest) XXX_Unmarshal(b []byte) error
- type GetProvisionInfoRequest
- func (*GetProvisionInfoRequest) Descriptor() ([]byte, []int)
- func (*GetProvisionInfoRequest) ProtoMessage()
- func (m *GetProvisionInfoRequest) Reset()
- func (m *GetProvisionInfoRequest) String() string
- func (m *GetProvisionInfoRequest) XXX_DiscardUnknown()
- func (m *GetProvisionInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetProvisionInfoRequest) XXX_Merge(src proto.Message)
- func (m *GetProvisionInfoRequest) XXX_Size() int
- func (m *GetProvisionInfoRequest) XXX_Unmarshal(b []byte) error
- type GetProvisionInfoResponse
- func (*GetProvisionInfoResponse) Descriptor() ([]byte, []int)
- func (m *GetProvisionInfoResponse) GetInfo() *ProvisionInfo
- func (*GetProvisionInfoResponse) ProtoMessage()
- func (m *GetProvisionInfoResponse) Reset()
- func (m *GetProvisionInfoResponse) String() string
- func (m *GetProvisionInfoResponse) XXX_DiscardUnknown()
- func (m *GetProvisionInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetProvisionInfoResponse) XXX_Merge(src proto.Message)
- func (m *GetProvisionInfoResponse) XXX_Size() int
- func (m *GetProvisionInfoResponse) XXX_Unmarshal(b []byte) error
- type InstructionRequest
- func (*InstructionRequest) Descriptor() ([]byte, []int)
- func (m *InstructionRequest) GetFinalizeBundle() *FinalizeBundleRequest
- func (m *InstructionRequest) GetInstructionId() string
- func (m *InstructionRequest) GetProcessBundle() *ProcessBundleRequest
- func (m *InstructionRequest) GetProcessBundleProgress() *ProcessBundleProgressRequest
- func (m *InstructionRequest) GetProcessBundleProgressMetadata() *ProcessBundleProgressMetadataRequest
- func (m *InstructionRequest) GetProcessBundleSplit() *ProcessBundleSplitRequest
- func (m *InstructionRequest) GetRegister() *RegisterRequest
- func (m *InstructionRequest) GetRequest() isInstructionRequest_Request
- func (*InstructionRequest) ProtoMessage()
- func (m *InstructionRequest) Reset()
- func (m *InstructionRequest) String() string
- func (m *InstructionRequest) XXX_DiscardUnknown()
- func (m *InstructionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InstructionRequest) XXX_Merge(src proto.Message)
- func (*InstructionRequest) XXX_OneofWrappers() []interface{}
- func (m *InstructionRequest) XXX_Size() int
- func (m *InstructionRequest) XXX_Unmarshal(b []byte) error
- type InstructionRequest_FinalizeBundle
- type InstructionRequest_ProcessBundle
- type InstructionRequest_ProcessBundleProgress
- type InstructionRequest_ProcessBundleProgressMetadata
- type InstructionRequest_ProcessBundleSplit
- type InstructionRequest_Register
- type InstructionResponse
- func (*InstructionResponse) Descriptor() ([]byte, []int)
- func (m *InstructionResponse) GetError() string
- func (m *InstructionResponse) GetFinalizeBundle() *FinalizeBundleResponse
- func (m *InstructionResponse) GetInstructionId() string
- func (m *InstructionResponse) GetProcessBundle() *ProcessBundleResponse
- func (m *InstructionResponse) GetProcessBundleProgress() *ProcessBundleProgressResponse
- func (m *InstructionResponse) GetProcessBundleProgressMetadata() *ProcessBundleProgressMetadataResponse
- func (m *InstructionResponse) GetProcessBundleSplit() *ProcessBundleSplitResponse
- func (m *InstructionResponse) GetRegister() *RegisterResponse
- func (m *InstructionResponse) GetResponse() isInstructionResponse_Response
- func (*InstructionResponse) ProtoMessage()
- func (m *InstructionResponse) Reset()
- func (m *InstructionResponse) String() string
- func (m *InstructionResponse) XXX_DiscardUnknown()
- func (m *InstructionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InstructionResponse) XXX_Merge(src proto.Message)
- func (*InstructionResponse) XXX_OneofWrappers() []interface{}
- func (m *InstructionResponse) XXX_Size() int
- func (m *InstructionResponse) XXX_Unmarshal(b []byte) error
- type InstructionResponse_FinalizeBundle
- type InstructionResponse_ProcessBundle
- type InstructionResponse_ProcessBundleProgress
- type InstructionResponse_ProcessBundleProgressMetadata
- type InstructionResponse_ProcessBundleSplit
- type InstructionResponse_Register
- type LogControl
- func (*LogControl) Descriptor() ([]byte, []int)
- func (*LogControl) ProtoMessage()
- func (m *LogControl) Reset()
- func (m *LogControl) String() string
- func (m *LogControl) XXX_DiscardUnknown()
- func (m *LogControl) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogControl) XXX_Merge(src proto.Message)
- func (m *LogControl) XXX_Size() int
- func (m *LogControl) XXX_Unmarshal(b []byte) error
- type LogEntry
- func (*LogEntry) Descriptor() ([]byte, []int)
- func (m *LogEntry) GetInstructionId() string
- func (m *LogEntry) GetLogLocation() string
- func (m *LogEntry) GetMessage() string
- func (m *LogEntry) GetSeverity() LogEntry_Severity_Enum
- func (m *LogEntry) GetThread() string
- func (m *LogEntry) GetTimestamp() *timestamp.Timestamp
- func (m *LogEntry) GetTrace() string
- func (m *LogEntry) GetTransformId() string
- func (*LogEntry) ProtoMessage()
- func (m *LogEntry) Reset()
- func (m *LogEntry) String() string
- func (m *LogEntry) XXX_DiscardUnknown()
- func (m *LogEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogEntry) XXX_Merge(src proto.Message)
- func (m *LogEntry) XXX_Size() int
- func (m *LogEntry) XXX_Unmarshal(b []byte) error
- type LogEntry_List
- func (*LogEntry_List) Descriptor() ([]byte, []int)
- func (m *LogEntry_List) GetLogEntries() []*LogEntry
- func (*LogEntry_List) ProtoMessage()
- func (m *LogEntry_List) Reset()
- func (m *LogEntry_List) String() string
- func (m *LogEntry_List) XXX_DiscardUnknown()
- func (m *LogEntry_List) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogEntry_List) XXX_Merge(src proto.Message)
- func (m *LogEntry_List) XXX_Size() int
- func (m *LogEntry_List) XXX_Unmarshal(b []byte) error
- type LogEntry_Severity
- func (*LogEntry_Severity) Descriptor() ([]byte, []int)
- func (*LogEntry_Severity) ProtoMessage()
- func (m *LogEntry_Severity) Reset()
- func (m *LogEntry_Severity) String() string
- func (m *LogEntry_Severity) XXX_DiscardUnknown()
- func (m *LogEntry_Severity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogEntry_Severity) XXX_Merge(src proto.Message)
- func (m *LogEntry_Severity) XXX_Size() int
- func (m *LogEntry_Severity) XXX_Unmarshal(b []byte) error
- type LogEntry_Severity_Enum
- type ProcessBundleDescriptor
- func (*ProcessBundleDescriptor) Descriptor() ([]byte, []int)
- func (m *ProcessBundleDescriptor) GetCoders() map[string]*pipeline_v1.Coder
- func (m *ProcessBundleDescriptor) GetEnvironments() map[string]*pipeline_v1.Environment
- func (m *ProcessBundleDescriptor) GetId() string
- func (m *ProcessBundleDescriptor) GetPcollections() map[string]*pipeline_v1.PCollection
- func (m *ProcessBundleDescriptor) GetStateApiServiceDescriptor() *pipeline_v1.ApiServiceDescriptor
- func (m *ProcessBundleDescriptor) GetTimerApiServiceDescriptor() *pipeline_v1.ApiServiceDescriptor
- func (m *ProcessBundleDescriptor) GetTransforms() map[string]*pipeline_v1.PTransform
- func (m *ProcessBundleDescriptor) GetWindowingStrategies() map[string]*pipeline_v1.WindowingStrategy
- func (*ProcessBundleDescriptor) ProtoMessage()
- func (m *ProcessBundleDescriptor) Reset()
- func (m *ProcessBundleDescriptor) String() string
- func (m *ProcessBundleDescriptor) XXX_DiscardUnknown()
- func (m *ProcessBundleDescriptor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessBundleDescriptor) XXX_Merge(src proto.Message)
- func (m *ProcessBundleDescriptor) XXX_Size() int
- func (m *ProcessBundleDescriptor) XXX_Unmarshal(b []byte) error
- type ProcessBundleProgressMetadataRequest
- func (*ProcessBundleProgressMetadataRequest) Descriptor() ([]byte, []int)
- func (m *ProcessBundleProgressMetadataRequest) GetMonitoringInfoId() []string
- func (*ProcessBundleProgressMetadataRequest) ProtoMessage()
- func (m *ProcessBundleProgressMetadataRequest) Reset()
- func (m *ProcessBundleProgressMetadataRequest) String() string
- func (m *ProcessBundleProgressMetadataRequest) XXX_DiscardUnknown()
- func (m *ProcessBundleProgressMetadataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessBundleProgressMetadataRequest) XXX_Merge(src proto.Message)
- func (m *ProcessBundleProgressMetadataRequest) XXX_Size() int
- func (m *ProcessBundleProgressMetadataRequest) XXX_Unmarshal(b []byte) error
- type ProcessBundleProgressMetadataResponse
- func (*ProcessBundleProgressMetadataResponse) Descriptor() ([]byte, []int)
- func (m *ProcessBundleProgressMetadataResponse) GetMonitoringInfo() map[string]*pipeline_v1.MonitoringInfo
- func (*ProcessBundleProgressMetadataResponse) ProtoMessage()
- func (m *ProcessBundleProgressMetadataResponse) Reset()
- func (m *ProcessBundleProgressMetadataResponse) String() string
- func (m *ProcessBundleProgressMetadataResponse) XXX_DiscardUnknown()
- func (m *ProcessBundleProgressMetadataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessBundleProgressMetadataResponse) XXX_Merge(src proto.Message)
- func (m *ProcessBundleProgressMetadataResponse) XXX_Size() int
- func (m *ProcessBundleProgressMetadataResponse) XXX_Unmarshal(b []byte) error
- type ProcessBundleProgressRequest
- func (*ProcessBundleProgressRequest) Descriptor() ([]byte, []int)
- func (m *ProcessBundleProgressRequest) GetInstructionId() string
- func (*ProcessBundleProgressRequest) ProtoMessage()
- func (m *ProcessBundleProgressRequest) Reset()
- func (m *ProcessBundleProgressRequest) String() string
- func (m *ProcessBundleProgressRequest) XXX_DiscardUnknown()
- func (m *ProcessBundleProgressRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessBundleProgressRequest) XXX_Merge(src proto.Message)
- func (m *ProcessBundleProgressRequest) XXX_Size() int
- func (m *ProcessBundleProgressRequest) XXX_Unmarshal(b []byte) error
- type ProcessBundleProgressResponse
- func (*ProcessBundleProgressResponse) Descriptor() ([]byte, []int)
- func (m *ProcessBundleProgressResponse) GetMonitoringData() map[string][]byte
- func (m *ProcessBundleProgressResponse) GetMonitoringInfos() []*pipeline_v1.MonitoringInfo
- func (*ProcessBundleProgressResponse) ProtoMessage()
- func (m *ProcessBundleProgressResponse) Reset()
- func (m *ProcessBundleProgressResponse) String() string
- func (m *ProcessBundleProgressResponse) XXX_DiscardUnknown()
- func (m *ProcessBundleProgressResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessBundleProgressResponse) XXX_Merge(src proto.Message)
- func (m *ProcessBundleProgressResponse) XXX_Size() int
- func (m *ProcessBundleProgressResponse) XXX_Unmarshal(b []byte) error
- type ProcessBundleRequest
- func (*ProcessBundleRequest) Descriptor() ([]byte, []int)
- func (m *ProcessBundleRequest) GetCacheTokens() []*ProcessBundleRequest_CacheToken
- func (m *ProcessBundleRequest) GetProcessBundleDescriptorId() string
- func (*ProcessBundleRequest) ProtoMessage()
- func (m *ProcessBundleRequest) Reset()
- func (m *ProcessBundleRequest) String() string
- func (m *ProcessBundleRequest) XXX_DiscardUnknown()
- func (m *ProcessBundleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessBundleRequest) XXX_Merge(src proto.Message)
- func (m *ProcessBundleRequest) XXX_Size() int
- func (m *ProcessBundleRequest) XXX_Unmarshal(b []byte) error
- type ProcessBundleRequest_CacheToken
- func (*ProcessBundleRequest_CacheToken) Descriptor() ([]byte, []int)
- func (m *ProcessBundleRequest_CacheToken) GetSideInput() *ProcessBundleRequest_CacheToken_SideInput
- func (m *ProcessBundleRequest_CacheToken) GetToken() []byte
- func (m *ProcessBundleRequest_CacheToken) GetType() isProcessBundleRequest_CacheToken_Type
- func (m *ProcessBundleRequest_CacheToken) GetUserState() *ProcessBundleRequest_CacheToken_UserState
- func (*ProcessBundleRequest_CacheToken) ProtoMessage()
- func (m *ProcessBundleRequest_CacheToken) Reset()
- func (m *ProcessBundleRequest_CacheToken) String() string
- func (m *ProcessBundleRequest_CacheToken) XXX_DiscardUnknown()
- func (m *ProcessBundleRequest_CacheToken) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessBundleRequest_CacheToken) XXX_Merge(src proto.Message)
- func (*ProcessBundleRequest_CacheToken) XXX_OneofWrappers() []interface{}
- func (m *ProcessBundleRequest_CacheToken) XXX_Size() int
- func (m *ProcessBundleRequest_CacheToken) XXX_Unmarshal(b []byte) error
- type ProcessBundleRequest_CacheToken_SideInput
- func (*ProcessBundleRequest_CacheToken_SideInput) Descriptor() ([]byte, []int)
- func (m *ProcessBundleRequest_CacheToken_SideInput) GetSideInputId() string
- func (m *ProcessBundleRequest_CacheToken_SideInput) GetTransformId() string
- func (*ProcessBundleRequest_CacheToken_SideInput) ProtoMessage()
- func (m *ProcessBundleRequest_CacheToken_SideInput) Reset()
- func (m *ProcessBundleRequest_CacheToken_SideInput) String() string
- func (m *ProcessBundleRequest_CacheToken_SideInput) XXX_DiscardUnknown()
- func (m *ProcessBundleRequest_CacheToken_SideInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessBundleRequest_CacheToken_SideInput) XXX_Merge(src proto.Message)
- func (m *ProcessBundleRequest_CacheToken_SideInput) XXX_Size() int
- func (m *ProcessBundleRequest_CacheToken_SideInput) XXX_Unmarshal(b []byte) error
- type ProcessBundleRequest_CacheToken_SideInput_
- type ProcessBundleRequest_CacheToken_UserState
- func (*ProcessBundleRequest_CacheToken_UserState) Descriptor() ([]byte, []int)
- func (*ProcessBundleRequest_CacheToken_UserState) ProtoMessage()
- func (m *ProcessBundleRequest_CacheToken_UserState) Reset()
- func (m *ProcessBundleRequest_CacheToken_UserState) String() string
- func (m *ProcessBundleRequest_CacheToken_UserState) XXX_DiscardUnknown()
- func (m *ProcessBundleRequest_CacheToken_UserState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessBundleRequest_CacheToken_UserState) XXX_Merge(src proto.Message)
- func (m *ProcessBundleRequest_CacheToken_UserState) XXX_Size() int
- func (m *ProcessBundleRequest_CacheToken_UserState) XXX_Unmarshal(b []byte) error
- type ProcessBundleRequest_CacheToken_UserState_
- type ProcessBundleResponse
- func (*ProcessBundleResponse) Descriptor() ([]byte, []int)
- func (m *ProcessBundleResponse) GetMonitoringData() map[string][]byte
- func (m *ProcessBundleResponse) GetMonitoringInfos() []*pipeline_v1.MonitoringInfo
- func (m *ProcessBundleResponse) GetRequiresFinalization() bool
- func (m *ProcessBundleResponse) GetResidualRoots() []*DelayedBundleApplication
- func (*ProcessBundleResponse) ProtoMessage()
- func (m *ProcessBundleResponse) Reset()
- func (m *ProcessBundleResponse) String() string
- func (m *ProcessBundleResponse) XXX_DiscardUnknown()
- func (m *ProcessBundleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessBundleResponse) XXX_Merge(src proto.Message)
- func (m *ProcessBundleResponse) XXX_Size() int
- func (m *ProcessBundleResponse) XXX_Unmarshal(b []byte) error
- type ProcessBundleSplitRequest
- func (*ProcessBundleSplitRequest) Descriptor() ([]byte, []int)
- func (m *ProcessBundleSplitRequest) GetDesiredSplits() map[string]*ProcessBundleSplitRequest_DesiredSplit
- func (m *ProcessBundleSplitRequest) GetInstructionId() string
- func (*ProcessBundleSplitRequest) ProtoMessage()
- func (m *ProcessBundleSplitRequest) Reset()
- func (m *ProcessBundleSplitRequest) String() string
- func (m *ProcessBundleSplitRequest) XXX_DiscardUnknown()
- func (m *ProcessBundleSplitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessBundleSplitRequest) XXX_Merge(src proto.Message)
- func (m *ProcessBundleSplitRequest) XXX_Size() int
- func (m *ProcessBundleSplitRequest) XXX_Unmarshal(b []byte) error
- type ProcessBundleSplitRequest_DesiredSplit
- func (*ProcessBundleSplitRequest_DesiredSplit) Descriptor() ([]byte, []int)
- func (m *ProcessBundleSplitRequest_DesiredSplit) GetAllowedSplitPoints() []int64
- func (m *ProcessBundleSplitRequest_DesiredSplit) GetEstimatedInputElements() int64
- func (m *ProcessBundleSplitRequest_DesiredSplit) GetFractionOfRemainder() float64
- func (*ProcessBundleSplitRequest_DesiredSplit) ProtoMessage()
- func (m *ProcessBundleSplitRequest_DesiredSplit) Reset()
- func (m *ProcessBundleSplitRequest_DesiredSplit) String() string
- func (m *ProcessBundleSplitRequest_DesiredSplit) XXX_DiscardUnknown()
- func (m *ProcessBundleSplitRequest_DesiredSplit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessBundleSplitRequest_DesiredSplit) XXX_Merge(src proto.Message)
- func (m *ProcessBundleSplitRequest_DesiredSplit) XXX_Size() int
- func (m *ProcessBundleSplitRequest_DesiredSplit) XXX_Unmarshal(b []byte) error
- type ProcessBundleSplitResponse
- func (*ProcessBundleSplitResponse) Descriptor() ([]byte, []int)
- func (m *ProcessBundleSplitResponse) GetChannelSplits() []*ProcessBundleSplitResponse_ChannelSplit
- func (m *ProcessBundleSplitResponse) GetPrimaryRoots() []*BundleApplication
- func (m *ProcessBundleSplitResponse) GetResidualRoots() []*DelayedBundleApplication
- func (*ProcessBundleSplitResponse) ProtoMessage()
- func (m *ProcessBundleSplitResponse) Reset()
- func (m *ProcessBundleSplitResponse) String() string
- func (m *ProcessBundleSplitResponse) XXX_DiscardUnknown()
- func (m *ProcessBundleSplitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessBundleSplitResponse) XXX_Merge(src proto.Message)
- func (m *ProcessBundleSplitResponse) XXX_Size() int
- func (m *ProcessBundleSplitResponse) XXX_Unmarshal(b []byte) error
- type ProcessBundleSplitResponse_ChannelSplit
- func (*ProcessBundleSplitResponse_ChannelSplit) Descriptor() ([]byte, []int)
- func (m *ProcessBundleSplitResponse_ChannelSplit) GetFirstResidualElement() int64
- func (m *ProcessBundleSplitResponse_ChannelSplit) GetLastPrimaryElement() int64
- func (m *ProcessBundleSplitResponse_ChannelSplit) GetTransformId() string
- func (*ProcessBundleSplitResponse_ChannelSplit) ProtoMessage()
- func (m *ProcessBundleSplitResponse_ChannelSplit) Reset()
- func (m *ProcessBundleSplitResponse_ChannelSplit) String() string
- func (m *ProcessBundleSplitResponse_ChannelSplit) XXX_DiscardUnknown()
- func (m *ProcessBundleSplitResponse_ChannelSplit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessBundleSplitResponse_ChannelSplit) XXX_Merge(src proto.Message)
- func (m *ProcessBundleSplitResponse_ChannelSplit) XXX_Size() int
- func (m *ProcessBundleSplitResponse_ChannelSplit) XXX_Unmarshal(b []byte) error
- type ProvisionInfo
- func (*ProvisionInfo) Descriptor() ([]byte, []int)
- func (m *ProvisionInfo) GetArtifactEndpoint() *pipeline_v1.ApiServiceDescriptor
- func (m *ProvisionInfo) GetControlEndpoint() *pipeline_v1.ApiServiceDescriptor
- func (m *ProvisionInfo) GetDependencies() []*pipeline_v1.ArtifactInformation
- func (m *ProvisionInfo) GetLoggingEndpoint() *pipeline_v1.ApiServiceDescriptor
- func (m *ProvisionInfo) GetPipelineOptions() *_struct.Struct
- func (m *ProvisionInfo) GetRetrievalToken() string
- func (m *ProvisionInfo) GetStatusEndpoint() *pipeline_v1.ApiServiceDescriptor
- func (*ProvisionInfo) ProtoMessage()
- func (m *ProvisionInfo) Reset()
- func (m *ProvisionInfo) String() string
- func (m *ProvisionInfo) XXX_DiscardUnknown()
- func (m *ProvisionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProvisionInfo) XXX_Merge(src proto.Message)
- func (m *ProvisionInfo) XXX_Size() int
- func (m *ProvisionInfo) XXX_Unmarshal(b []byte) error
- type ProvisionServiceClient
- type ProvisionServiceServer
- type RegisterRequest
- func (*RegisterRequest) Descriptor() ([]byte, []int)
- func (m *RegisterRequest) GetProcessBundleDescriptor() []*ProcessBundleDescriptor
- func (*RegisterRequest) ProtoMessage()
- func (m *RegisterRequest) Reset()
- func (m *RegisterRequest) String() string
- func (m *RegisterRequest) XXX_DiscardUnknown()
- func (m *RegisterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RegisterRequest) XXX_Merge(src proto.Message)
- func (m *RegisterRequest) XXX_Size() int
- func (m *RegisterRequest) XXX_Unmarshal(b []byte) error
- type RegisterResponse
- func (*RegisterResponse) Descriptor() ([]byte, []int)
- func (*RegisterResponse) ProtoMessage()
- func (m *RegisterResponse) Reset()
- func (m *RegisterResponse) String() string
- func (m *RegisterResponse) XXX_DiscardUnknown()
- func (m *RegisterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RegisterResponse) XXX_Merge(src proto.Message)
- func (m *RegisterResponse) XXX_Size() int
- func (m *RegisterResponse) XXX_Unmarshal(b []byte) error
- type RemoteGrpcPort
- func (*RemoteGrpcPort) Descriptor() ([]byte, []int)
- func (m *RemoteGrpcPort) GetApiServiceDescriptor() *pipeline_v1.ApiServiceDescriptor
- func (m *RemoteGrpcPort) GetCoderId() string
- func (*RemoteGrpcPort) ProtoMessage()
- func (m *RemoteGrpcPort) Reset()
- func (m *RemoteGrpcPort) String() string
- func (m *RemoteGrpcPort) XXX_DiscardUnknown()
- func (m *RemoteGrpcPort) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RemoteGrpcPort) XXX_Merge(src proto.Message)
- func (m *RemoteGrpcPort) XXX_Size() int
- func (m *RemoteGrpcPort) XXX_Unmarshal(b []byte) error
- type StartWorkerRequest
- func (*StartWorkerRequest) Descriptor() ([]byte, []int)
- func (m *StartWorkerRequest) GetArtifactEndpoint() *pipeline_v1.ApiServiceDescriptor
- func (m *StartWorkerRequest) GetControlEndpoint() *pipeline_v1.ApiServiceDescriptor
- func (m *StartWorkerRequest) GetLoggingEndpoint() *pipeline_v1.ApiServiceDescriptor
- func (m *StartWorkerRequest) GetParams() map[string]string
- func (m *StartWorkerRequest) GetProvisionEndpoint() *pipeline_v1.ApiServiceDescriptor
- func (m *StartWorkerRequest) GetWorkerId() string
- func (*StartWorkerRequest) ProtoMessage()
- func (m *StartWorkerRequest) Reset()
- func (m *StartWorkerRequest) String() string
- func (m *StartWorkerRequest) XXX_DiscardUnknown()
- func (m *StartWorkerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StartWorkerRequest) XXX_Merge(src proto.Message)
- func (m *StartWorkerRequest) XXX_Size() int
- func (m *StartWorkerRequest) XXX_Unmarshal(b []byte) error
- type StartWorkerResponse
- func (*StartWorkerResponse) Descriptor() ([]byte, []int)
- func (m *StartWorkerResponse) GetError() string
- func (*StartWorkerResponse) ProtoMessage()
- func (m *StartWorkerResponse) Reset()
- func (m *StartWorkerResponse) String() string
- func (m *StartWorkerResponse) XXX_DiscardUnknown()
- func (m *StartWorkerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StartWorkerResponse) XXX_Merge(src proto.Message)
- func (m *StartWorkerResponse) XXX_Size() int
- func (m *StartWorkerResponse) XXX_Unmarshal(b []byte) error
- type StateAppendRequest
- func (*StateAppendRequest) Descriptor() ([]byte, []int)
- func (m *StateAppendRequest) GetData() []byte
- func (*StateAppendRequest) ProtoMessage()
- func (m *StateAppendRequest) Reset()
- func (m *StateAppendRequest) String() string
- func (m *StateAppendRequest) XXX_DiscardUnknown()
- func (m *StateAppendRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StateAppendRequest) XXX_Merge(src proto.Message)
- func (m *StateAppendRequest) XXX_Size() int
- func (m *StateAppendRequest) XXX_Unmarshal(b []byte) error
- type StateAppendResponse
- func (*StateAppendResponse) Descriptor() ([]byte, []int)
- func (*StateAppendResponse) ProtoMessage()
- func (m *StateAppendResponse) Reset()
- func (m *StateAppendResponse) String() string
- func (m *StateAppendResponse) XXX_DiscardUnknown()
- func (m *StateAppendResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StateAppendResponse) XXX_Merge(src proto.Message)
- func (m *StateAppendResponse) XXX_Size() int
- func (m *StateAppendResponse) XXX_Unmarshal(b []byte) error
- type StateClearRequest
- func (*StateClearRequest) Descriptor() ([]byte, []int)
- func (*StateClearRequest) ProtoMessage()
- func (m *StateClearRequest) Reset()
- func (m *StateClearRequest) String() string
- func (m *StateClearRequest) XXX_DiscardUnknown()
- func (m *StateClearRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StateClearRequest) XXX_Merge(src proto.Message)
- func (m *StateClearRequest) XXX_Size() int
- func (m *StateClearRequest) XXX_Unmarshal(b []byte) error
- type StateClearResponse
- func (*StateClearResponse) Descriptor() ([]byte, []int)
- func (*StateClearResponse) ProtoMessage()
- func (m *StateClearResponse) Reset()
- func (m *StateClearResponse) String() string
- func (m *StateClearResponse) XXX_DiscardUnknown()
- func (m *StateClearResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StateClearResponse) XXX_Merge(src proto.Message)
- func (m *StateClearResponse) XXX_Size() int
- func (m *StateClearResponse) XXX_Unmarshal(b []byte) error
- type StateGetRequest
- func (*StateGetRequest) Descriptor() ([]byte, []int)
- func (m *StateGetRequest) GetContinuationToken() []byte
- func (*StateGetRequest) ProtoMessage()
- func (m *StateGetRequest) Reset()
- func (m *StateGetRequest) String() string
- func (m *StateGetRequest) XXX_DiscardUnknown()
- func (m *StateGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StateGetRequest) XXX_Merge(src proto.Message)
- func (m *StateGetRequest) XXX_Size() int
- func (m *StateGetRequest) XXX_Unmarshal(b []byte) error
- type StateGetResponse
- func (*StateGetResponse) Descriptor() ([]byte, []int)
- func (m *StateGetResponse) GetContinuationToken() []byte
- func (m *StateGetResponse) GetData() []byte
- func (*StateGetResponse) ProtoMessage()
- func (m *StateGetResponse) Reset()
- func (m *StateGetResponse) String() string
- func (m *StateGetResponse) XXX_DiscardUnknown()
- func (m *StateGetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StateGetResponse) XXX_Merge(src proto.Message)
- func (m *StateGetResponse) XXX_Size() int
- func (m *StateGetResponse) XXX_Unmarshal(b []byte) error
- type StateKey
- func (*StateKey) Descriptor() ([]byte, []int)
- func (m *StateKey) GetBagUserState() *StateKey_BagUserState
- func (m *StateKey) GetIterableSideInput() *StateKey_IterableSideInput
- func (m *StateKey) GetMultimapKeysSideInput() *StateKey_MultimapKeysSideInput
- func (m *StateKey) GetMultimapSideInput() *StateKey_MultimapSideInput
- func (m *StateKey) GetRunner() *StateKey_Runner
- func (m *StateKey) GetType() isStateKey_Type
- func (*StateKey) ProtoMessage()
- func (m *StateKey) Reset()
- func (m *StateKey) String() string
- func (m *StateKey) XXX_DiscardUnknown()
- func (m *StateKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StateKey) XXX_Merge(src proto.Message)
- func (*StateKey) XXX_OneofWrappers() []interface{}
- func (m *StateKey) XXX_Size() int
- func (m *StateKey) XXX_Unmarshal(b []byte) error
- type StateKey_BagUserState
- func (*StateKey_BagUserState) Descriptor() ([]byte, []int)
- func (m *StateKey_BagUserState) GetKey() []byte
- func (m *StateKey_BagUserState) GetTransformId() string
- func (m *StateKey_BagUserState) GetUserStateId() string
- func (m *StateKey_BagUserState) GetWindow() []byte
- func (*StateKey_BagUserState) ProtoMessage()
- func (m *StateKey_BagUserState) Reset()
- func (m *StateKey_BagUserState) String() string
- func (m *StateKey_BagUserState) XXX_DiscardUnknown()
- func (m *StateKey_BagUserState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StateKey_BagUserState) XXX_Merge(src proto.Message)
- func (m *StateKey_BagUserState) XXX_Size() int
- func (m *StateKey_BagUserState) XXX_Unmarshal(b []byte) error
- type StateKey_BagUserState_
- type StateKey_IterableSideInput
- func (*StateKey_IterableSideInput) Descriptor() ([]byte, []int)
- func (m *StateKey_IterableSideInput) GetSideInputId() string
- func (m *StateKey_IterableSideInput) GetTransformId() string
- func (m *StateKey_IterableSideInput) GetWindow() []byte
- func (*StateKey_IterableSideInput) ProtoMessage()
- func (m *StateKey_IterableSideInput) Reset()
- func (m *StateKey_IterableSideInput) String() string
- func (m *StateKey_IterableSideInput) XXX_DiscardUnknown()
- func (m *StateKey_IterableSideInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StateKey_IterableSideInput) XXX_Merge(src proto.Message)
- func (m *StateKey_IterableSideInput) XXX_Size() int
- func (m *StateKey_IterableSideInput) XXX_Unmarshal(b []byte) error
- type StateKey_IterableSideInput_
- type StateKey_MultimapKeysSideInput
- func (*StateKey_MultimapKeysSideInput) Descriptor() ([]byte, []int)
- func (m *StateKey_MultimapKeysSideInput) GetSideInputId() string
- func (m *StateKey_MultimapKeysSideInput) GetTransformId() string
- func (m *StateKey_MultimapKeysSideInput) GetWindow() []byte
- func (*StateKey_MultimapKeysSideInput) ProtoMessage()
- func (m *StateKey_MultimapKeysSideInput) Reset()
- func (m *StateKey_MultimapKeysSideInput) String() string
- func (m *StateKey_MultimapKeysSideInput) XXX_DiscardUnknown()
- func (m *StateKey_MultimapKeysSideInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StateKey_MultimapKeysSideInput) XXX_Merge(src proto.Message)
- func (m *StateKey_MultimapKeysSideInput) XXX_Size() int
- func (m *StateKey_MultimapKeysSideInput) XXX_Unmarshal(b []byte) error
- type StateKey_MultimapKeysSideInput_
- type StateKey_MultimapSideInput
- func (*StateKey_MultimapSideInput) Descriptor() ([]byte, []int)
- func (m *StateKey_MultimapSideInput) GetKey() []byte
- func (m *StateKey_MultimapSideInput) GetSideInputId() string
- func (m *StateKey_MultimapSideInput) GetTransformId() string
- func (m *StateKey_MultimapSideInput) GetWindow() []byte
- func (*StateKey_MultimapSideInput) ProtoMessage()
- func (m *StateKey_MultimapSideInput) Reset()
- func (m *StateKey_MultimapSideInput) String() string
- func (m *StateKey_MultimapSideInput) XXX_DiscardUnknown()
- func (m *StateKey_MultimapSideInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StateKey_MultimapSideInput) XXX_Merge(src proto.Message)
- func (m *StateKey_MultimapSideInput) XXX_Size() int
- func (m *StateKey_MultimapSideInput) XXX_Unmarshal(b []byte) error
- type StateKey_MultimapSideInput_
- type StateKey_Runner
- func (*StateKey_Runner) Descriptor() ([]byte, []int)
- func (m *StateKey_Runner) GetKey() []byte
- func (*StateKey_Runner) ProtoMessage()
- func (m *StateKey_Runner) Reset()
- func (m *StateKey_Runner) String() string
- func (m *StateKey_Runner) XXX_DiscardUnknown()
- func (m *StateKey_Runner) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StateKey_Runner) XXX_Merge(src proto.Message)
- func (m *StateKey_Runner) XXX_Size() int
- func (m *StateKey_Runner) XXX_Unmarshal(b []byte) error
- type StateKey_Runner_
- type StateRequest
- func (*StateRequest) Descriptor() ([]byte, []int)
- func (m *StateRequest) GetAppend() *StateAppendRequest
- func (m *StateRequest) GetClear() *StateClearRequest
- func (m *StateRequest) GetGet() *StateGetRequest
- func (m *StateRequest) GetId() string
- func (m *StateRequest) GetInstructionId() string
- func (m *StateRequest) GetRequest() isStateRequest_Request
- func (m *StateRequest) GetStateKey() *StateKey
- func (*StateRequest) ProtoMessage()
- func (m *StateRequest) Reset()
- func (m *StateRequest) String() string
- func (m *StateRequest) XXX_DiscardUnknown()
- func (m *StateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StateRequest) XXX_Merge(src proto.Message)
- func (*StateRequest) XXX_OneofWrappers() []interface{}
- func (m *StateRequest) XXX_Size() int
- func (m *StateRequest) XXX_Unmarshal(b []byte) error
- type StateRequest_Append
- type StateRequest_Clear
- type StateRequest_Get
- type StateResponse
- func (*StateResponse) Descriptor() ([]byte, []int)
- func (m *StateResponse) GetAppend() *StateAppendResponse
- func (m *StateResponse) GetClear() *StateClearResponse
- func (m *StateResponse) GetError() string
- func (m *StateResponse) GetGet() *StateGetResponse
- func (m *StateResponse) GetId() string
- func (m *StateResponse) GetResponse() isStateResponse_Response
- func (*StateResponse) ProtoMessage()
- func (m *StateResponse) Reset()
- func (m *StateResponse) String() string
- func (m *StateResponse) XXX_DiscardUnknown()
- func (m *StateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StateResponse) XXX_Merge(src proto.Message)
- func (*StateResponse) XXX_OneofWrappers() []interface{}
- func (m *StateResponse) XXX_Size() int
- func (m *StateResponse) XXX_Unmarshal(b []byte) error
- type StateResponse_Append
- type StateResponse_Clear
- type StateResponse_Get
- type StopWorkerRequest
- func (*StopWorkerRequest) Descriptor() ([]byte, []int)
- func (m *StopWorkerRequest) GetWorkerId() string
- func (*StopWorkerRequest) ProtoMessage()
- func (m *StopWorkerRequest) Reset()
- func (m *StopWorkerRequest) String() string
- func (m *StopWorkerRequest) XXX_DiscardUnknown()
- func (m *StopWorkerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StopWorkerRequest) XXX_Merge(src proto.Message)
- func (m *StopWorkerRequest) XXX_Size() int
- func (m *StopWorkerRequest) XXX_Unmarshal(b []byte) error
- type StopWorkerResponse
- func (*StopWorkerResponse) Descriptor() ([]byte, []int)
- func (m *StopWorkerResponse) GetError() string
- func (*StopWorkerResponse) ProtoMessage()
- func (m *StopWorkerResponse) Reset()
- func (m *StopWorkerResponse) String() string
- func (m *StopWorkerResponse) XXX_DiscardUnknown()
- func (m *StopWorkerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StopWorkerResponse) XXX_Merge(src proto.Message)
- func (m *StopWorkerResponse) XXX_Size() int
- func (m *StopWorkerResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedBeamFnControlServer
- type UnimplementedBeamFnDataServer
- type UnimplementedBeamFnExternalWorkerPoolServer
- type UnimplementedBeamFnLoggingServer
- type UnimplementedBeamFnStateServer
- type UnimplementedBeamFnWorkerStatusServer
- type UnimplementedProvisionServiceServer
- type WorkerStatusRequest
- func (*WorkerStatusRequest) Descriptor() ([]byte, []int)
- func (m *WorkerStatusRequest) GetId() string
- func (*WorkerStatusRequest) ProtoMessage()
- func (m *WorkerStatusRequest) Reset()
- func (m *WorkerStatusRequest) String() string
- func (m *WorkerStatusRequest) XXX_DiscardUnknown()
- func (m *WorkerStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkerStatusRequest) XXX_Merge(src proto.Message)
- func (m *WorkerStatusRequest) XXX_Size() int
- func (m *WorkerStatusRequest) XXX_Unmarshal(b []byte) error
- type WorkerStatusResponse
- func (*WorkerStatusResponse) Descriptor() ([]byte, []int)
- func (m *WorkerStatusResponse) GetError() string
- func (m *WorkerStatusResponse) GetId() string
- func (m *WorkerStatusResponse) GetStatusInfo() string
- func (*WorkerStatusResponse) ProtoMessage()
- func (m *WorkerStatusResponse) Reset()
- func (m *WorkerStatusResponse) String() string
- func (m *WorkerStatusResponse) XXX_DiscardUnknown()
- func (m *WorkerStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkerStatusResponse) XXX_Merge(src proto.Message)
- func (m *WorkerStatusResponse) XXX_Size() int
- func (m *WorkerStatusResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func RegisterBeamFnControlServer ¶
func RegisterBeamFnControlServer(s *grpc.Server, srv BeamFnControlServer)
func RegisterBeamFnDataServer ¶
func RegisterBeamFnDataServer(s *grpc.Server, srv BeamFnDataServer)
func RegisterBeamFnExternalWorkerPoolServer ¶
func RegisterBeamFnExternalWorkerPoolServer(s *grpc.Server, srv BeamFnExternalWorkerPoolServer)
func RegisterBeamFnLoggingServer ¶
func RegisterBeamFnLoggingServer(s *grpc.Server, srv BeamFnLoggingServer)
func RegisterBeamFnStateServer ¶
func RegisterBeamFnStateServer(s *grpc.Server, srv BeamFnStateServer)
func RegisterBeamFnWorkerStatusServer ¶
func RegisterBeamFnWorkerStatusServer(s *grpc.Server, srv BeamFnWorkerStatusServer)
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) // Used to get the full process bundle descriptors for bundles one // is asked to process. GetProcessBundleDescriptor(ctx context.Context, in *GetProcessBundleDescriptorRequest, opts ...grpc.CallOption) (*ProcessBundleDescriptor, 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 // Used to get the full process bundle descriptors for bundles one // is asked to process. GetProcessBundleDescriptor(context.Context, *GetProcessBundleDescriptorRequest) (*ProcessBundleDescriptor, 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_DataServer ¶
type BeamFnExternalWorkerPoolClient ¶
type BeamFnExternalWorkerPoolClient interface { // Start the SDK worker with the given ID. StartWorker(ctx context.Context, in *StartWorkerRequest, opts ...grpc.CallOption) (*StartWorkerResponse, error) // Stop the SDK worker. StopWorker(ctx context.Context, in *StopWorkerRequest, opts ...grpc.CallOption) (*StopWorkerResponse, error) }
BeamFnExternalWorkerPoolClient is the client API for BeamFnExternalWorkerPool service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewBeamFnExternalWorkerPoolClient ¶
func NewBeamFnExternalWorkerPoolClient(cc *grpc.ClientConn) BeamFnExternalWorkerPoolClient
type BeamFnExternalWorkerPoolServer ¶
type BeamFnExternalWorkerPoolServer interface { // Start the SDK worker with the given ID. StartWorker(context.Context, *StartWorkerRequest) (*StartWorkerResponse, error) // Stop the SDK worker. StopWorker(context.Context, *StopWorkerRequest) (*StopWorkerResponse, error) }
BeamFnExternalWorkerPoolServer is the server API for BeamFnExternalWorkerPool service.
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 BeamFnWorkerStatusClient ¶
type BeamFnWorkerStatusClient interface {
WorkerStatus(ctx context.Context, opts ...grpc.CallOption) (BeamFnWorkerStatus_WorkerStatusClient, error)
}
BeamFnWorkerStatusClient is the client API for BeamFnWorkerStatus service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewBeamFnWorkerStatusClient ¶
func NewBeamFnWorkerStatusClient(cc *grpc.ClientConn) BeamFnWorkerStatusClient
type BeamFnWorkerStatusServer ¶
type BeamFnWorkerStatusServer interface {
WorkerStatus(BeamFnWorkerStatus_WorkerStatusServer) error
}
BeamFnWorkerStatusServer is the server API for BeamFnWorkerStatus service.
type BeamFnWorkerStatus_WorkerStatusClient ¶
type BeamFnWorkerStatus_WorkerStatusClient interface { Send(*WorkerStatusResponse) error Recv() (*WorkerStatusRequest, error) grpc.ClientStream }
type BeamFnWorkerStatus_WorkerStatusServer ¶
type BeamFnWorkerStatus_WorkerStatusServer interface { Send(*WorkerStatusRequest) error Recv() (*WorkerStatusResponse, error) grpc.ServerStream }
type BundleApplication ¶
type BundleApplication struct { // (Required) The transform to which to pass the element TransformId string `protobuf:"bytes,1,opt,name=transform_id,json=transformId,proto3" json:"transform_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,proto3" 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"` // The map is keyed by the local output name of the PTransform. Each // value represents a lower bound on the timestamps of elements that // are produced by this PTransform into each of its output PCollections // when invoked with this application. // // If there is no watermark reported from RestrictionTracker, the runner will // use MIN_TIMESTAMP by default. OutputWatermarks map[string]*timestamp.Timestamp `` /* 197-byte string literal not displayed */ // Whether this application potentially produces an unbounded // amount of data. Note that this should only be set to BOUNDED if and // only if the application is known to produce a finite amount of output. IsBounded pipeline_v1.IsBounded_Enum `` /* 143-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
One of the applications specifying the scope of work for a bundle. See https://docs.google.com/document/d/1tUDb45sStdR8u7-jBkGdw3OGFK7aa2-V7eo86zYSE_4/edit#heading=h.9g3g5weg2u9 for further details.
func (*BundleApplication) Descriptor ¶
func (*BundleApplication) Descriptor() ([]byte, []int)
func (*BundleApplication) GetElement ¶
func (m *BundleApplication) GetElement() []byte
func (*BundleApplication) GetInputId ¶
func (m *BundleApplication) GetInputId() string
func (*BundleApplication) GetIsBounded ¶
func (m *BundleApplication) GetIsBounded() pipeline_v1.IsBounded_Enum
func (*BundleApplication) GetOutputWatermarks ¶
func (m *BundleApplication) GetOutputWatermarks() map[string]*timestamp.Timestamp
func (*BundleApplication) GetTransformId ¶
func (m *BundleApplication) GetTransformId() string
func (*BundleApplication) ProtoMessage ¶
func (*BundleApplication) ProtoMessage()
func (*BundleApplication) Reset ¶
func (m *BundleApplication) Reset()
func (*BundleApplication) String ¶
func (m *BundleApplication) String() string
func (*BundleApplication) XXX_DiscardUnknown ¶
func (m *BundleApplication) XXX_DiscardUnknown()
func (*BundleApplication) XXX_Marshal ¶
func (m *BundleApplication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BundleApplication) XXX_Merge ¶
func (m *BundleApplication) XXX_Merge(src proto.Message)
func (*BundleApplication) XXX_Size ¶
func (m *BundleApplication) XXX_Size() int
func (*BundleApplication) XXX_Unmarshal ¶
func (m *BundleApplication) XXX_Unmarshal(b []byte) error
type DelayedBundleApplication ¶
type DelayedBundleApplication struct { // (Required) The application that should be scheduled. Application *BundleApplication `protobuf:"bytes,1,opt,name=application,proto3" json:"application,omitempty"` // Recommended time delay at which the application should be scheduled to // execute by the runner. Time delay that equals 0 may be scheduled to execute // immediately. The unit of time delay should be microsecond. RequestedTimeDelay *duration.Duration `protobuf:"bytes,2,opt,name=requested_time_delay,json=requestedTimeDelay,proto3" json:"requested_time_delay,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
An Application should be scheduled for execution after a delay. Either an absolute timestamp or a relative timestamp can represent a scheduled execution time.
func (*DelayedBundleApplication) Descriptor ¶
func (*DelayedBundleApplication) Descriptor() ([]byte, []int)
func (*DelayedBundleApplication) GetApplication ¶
func (m *DelayedBundleApplication) GetApplication() *BundleApplication
func (*DelayedBundleApplication) GetRequestedTimeDelay ¶
func (m *DelayedBundleApplication) GetRequestedTimeDelay() *duration.Duration
func (*DelayedBundleApplication) ProtoMessage ¶
func (*DelayedBundleApplication) ProtoMessage()
func (*DelayedBundleApplication) Reset ¶
func (m *DelayedBundleApplication) Reset()
func (*DelayedBundleApplication) String ¶
func (m *DelayedBundleApplication) String() string
func (*DelayedBundleApplication) XXX_DiscardUnknown ¶
func (m *DelayedBundleApplication) XXX_DiscardUnknown()
func (*DelayedBundleApplication) XXX_Marshal ¶
func (m *DelayedBundleApplication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DelayedBundleApplication) XXX_Merge ¶
func (m *DelayedBundleApplication) XXX_Merge(src proto.Message)
func (*DelayedBundleApplication) XXX_Size ¶
func (m *DelayedBundleApplication) XXX_Size() int
func (*DelayedBundleApplication) XXX_Unmarshal ¶
func (m *DelayedBundleApplication) XXX_Unmarshal(b []byte) error
type Elements ¶
type Elements struct { // (Optional) A list containing parts of logical byte streams. Data []*Elements_Data `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"` // (Optional) A list of timer byte streams. Timers []*Elements_Timers `protobuf:"bytes,2,rep,name=timers,proto3" json:"timers,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Messages used to represent logical byte streams. Stable
func (*Elements) GetData ¶
func (m *Elements) GetData() []*Elements_Data
func (*Elements) GetTimers ¶
func (m *Elements) GetTimers() []*Elements_Timers
func (*Elements) XXX_Marshal ¶
type Elements_Data ¶
type Elements_Data struct { // (Required) A reference to an active instruction request with the given // instruction id. InstructionId string `protobuf:"bytes,1,opt,name=instruction_id,json=instructionId,proto3" json:"instruction_id,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 identifier. TransformId string `protobuf:"bytes,2,opt,name=transform_id,json=transformId,proto3" json:"transform_id,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. Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` // (Optional) Set this bit to indicate the this is the last data block // for the given instruction and transform, ending the stream. IsLast bool `protobuf:"varint,4,opt,name=is_last,json=isLast,proto3" json:"is_last,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 transform.
func (*Elements_Data) Descriptor ¶
func (*Elements_Data) Descriptor() ([]byte, []int)
func (*Elements_Data) GetData ¶
func (m *Elements_Data) GetData() []byte
func (*Elements_Data) GetInstructionId ¶
func (m *Elements_Data) GetInstructionId() string
func (*Elements_Data) GetIsLast ¶
func (m *Elements_Data) GetIsLast() bool
func (*Elements_Data) GetTransformId ¶
func (m *Elements_Data) GetTransformId() string
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 (m *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 Elements_Timers ¶
type Elements_Timers struct { // (Required) A reference to an active instruction request with the given // instruction id. InstructionId string `protobuf:"bytes,1,opt,name=instruction_id,json=instructionId,proto3" json:"instruction_id,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 timers. If sent by a harness, this // represents the producer of these timers. TransformId string `protobuf:"bytes,2,opt,name=transform_id,json=transformId,proto3" json:"transform_id,omitempty"` // (Required) The local timer family name used to identify the associated // timer family specification TimerFamilyId string `protobuf:"bytes,3,opt,name=timer_family_id,json=timerFamilyId,proto3" json:"timer_family_id,omitempty"` // (Optional) Represents a logical byte stream of timers. Encoded according // to the coder in the timer spec. Timers []byte `protobuf:"bytes,4,opt,name=timers,proto3" json:"timers,omitempty"` // (Optional) Set this bit to indicate the this is the last data block // for the given instruction and transform, ending the stream. IsLast bool `protobuf:"varint,5,opt,name=is_last,json=isLast,proto3" json:"is_last,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Represent the encoded user timer for a given instruction, transform and timer id.
func (*Elements_Timers) Descriptor ¶
func (*Elements_Timers) Descriptor() ([]byte, []int)
func (*Elements_Timers) GetInstructionId ¶
func (m *Elements_Timers) GetInstructionId() string
func (*Elements_Timers) GetIsLast ¶
func (m *Elements_Timers) GetIsLast() bool
func (*Elements_Timers) GetTimerFamilyId ¶
func (m *Elements_Timers) GetTimerFamilyId() string
func (*Elements_Timers) GetTimers ¶
func (m *Elements_Timers) GetTimers() []byte
func (*Elements_Timers) GetTransformId ¶
func (m *Elements_Timers) GetTransformId() string
func (*Elements_Timers) ProtoMessage ¶
func (*Elements_Timers) ProtoMessage()
func (*Elements_Timers) Reset ¶
func (m *Elements_Timers) Reset()
func (*Elements_Timers) String ¶
func (m *Elements_Timers) String() string
func (*Elements_Timers) XXX_DiscardUnknown ¶
func (m *Elements_Timers) XXX_DiscardUnknown()
func (*Elements_Timers) XXX_Marshal ¶
func (m *Elements_Timers) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Elements_Timers) XXX_Merge ¶
func (m *Elements_Timers) XXX_Merge(src proto.Message)
func (*Elements_Timers) XXX_Size ¶
func (m *Elements_Timers) XXX_Size() int
func (*Elements_Timers) XXX_Unmarshal ¶
func (m *Elements_Timers) XXX_Unmarshal(b []byte) error
type FinalizeBundleRequest ¶
type FinalizeBundleRequest struct { // (Required) A reference to a completed process bundle request with the given // instruction id. InstructionId string `protobuf:"bytes,1,opt,name=instruction_id,json=instructionId,proto3" json:"instruction_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FinalizeBundleRequest) Descriptor ¶
func (*FinalizeBundleRequest) Descriptor() ([]byte, []int)
func (*FinalizeBundleRequest) GetInstructionId ¶
func (m *FinalizeBundleRequest) GetInstructionId() string
func (*FinalizeBundleRequest) ProtoMessage ¶
func (*FinalizeBundleRequest) ProtoMessage()
func (*FinalizeBundleRequest) Reset ¶
func (m *FinalizeBundleRequest) Reset()
func (*FinalizeBundleRequest) String ¶
func (m *FinalizeBundleRequest) String() string
func (*FinalizeBundleRequest) XXX_DiscardUnknown ¶
func (m *FinalizeBundleRequest) XXX_DiscardUnknown()
func (*FinalizeBundleRequest) XXX_Marshal ¶
func (m *FinalizeBundleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FinalizeBundleRequest) XXX_Merge ¶
func (m *FinalizeBundleRequest) XXX_Merge(src proto.Message)
func (*FinalizeBundleRequest) XXX_Size ¶
func (m *FinalizeBundleRequest) XXX_Size() int
func (*FinalizeBundleRequest) XXX_Unmarshal ¶
func (m *FinalizeBundleRequest) XXX_Unmarshal(b []byte) error
type FinalizeBundleResponse ¶
type FinalizeBundleResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FinalizeBundleResponse) Descriptor ¶
func (*FinalizeBundleResponse) Descriptor() ([]byte, []int)
func (*FinalizeBundleResponse) ProtoMessage ¶
func (*FinalizeBundleResponse) ProtoMessage()
func (*FinalizeBundleResponse) Reset ¶
func (m *FinalizeBundleResponse) Reset()
func (*FinalizeBundleResponse) String ¶
func (m *FinalizeBundleResponse) String() string
func (*FinalizeBundleResponse) XXX_DiscardUnknown ¶
func (m *FinalizeBundleResponse) XXX_DiscardUnknown()
func (*FinalizeBundleResponse) XXX_Marshal ¶
func (m *FinalizeBundleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FinalizeBundleResponse) XXX_Merge ¶
func (m *FinalizeBundleResponse) XXX_Merge(src proto.Message)
func (*FinalizeBundleResponse) XXX_Size ¶
func (m *FinalizeBundleResponse) XXX_Size() int
func (*FinalizeBundleResponse) XXX_Unmarshal ¶
func (m *FinalizeBundleResponse) XXX_Unmarshal(b []byte) error
type GetProcessBundleDescriptorRequest ¶
type GetProcessBundleDescriptorRequest struct { ProcessBundleDescriptorId string `` /* 140-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Requests the ProcessBundleDescriptor with the given id.
func (*GetProcessBundleDescriptorRequest) Descriptor ¶
func (*GetProcessBundleDescriptorRequest) Descriptor() ([]byte, []int)
func (*GetProcessBundleDescriptorRequest) GetProcessBundleDescriptorId ¶
func (m *GetProcessBundleDescriptorRequest) GetProcessBundleDescriptorId() string
func (*GetProcessBundleDescriptorRequest) ProtoMessage ¶
func (*GetProcessBundleDescriptorRequest) ProtoMessage()
func (*GetProcessBundleDescriptorRequest) Reset ¶
func (m *GetProcessBundleDescriptorRequest) Reset()
func (*GetProcessBundleDescriptorRequest) String ¶
func (m *GetProcessBundleDescriptorRequest) String() string
func (*GetProcessBundleDescriptorRequest) XXX_DiscardUnknown ¶
func (m *GetProcessBundleDescriptorRequest) XXX_DiscardUnknown()
func (*GetProcessBundleDescriptorRequest) XXX_Marshal ¶
func (m *GetProcessBundleDescriptorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetProcessBundleDescriptorRequest) XXX_Merge ¶
func (m *GetProcessBundleDescriptorRequest) XXX_Merge(src proto.Message)
func (*GetProcessBundleDescriptorRequest) XXX_Size ¶
func (m *GetProcessBundleDescriptorRequest) XXX_Size() int
func (*GetProcessBundleDescriptorRequest) XXX_Unmarshal ¶
func (m *GetProcessBundleDescriptorRequest) 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 (m *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,proto3" 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 (m *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) A 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,proto3" json:"instruction_id,omitempty"` // (Required) A request that the SDK Harness needs to interpret. // // Types that are valid to be assigned to Request: // *InstructionRequest_ProcessBundle // *InstructionRequest_ProcessBundleProgress // *InstructionRequest_ProcessBundleSplit // *InstructionRequest_FinalizeBundle // *InstructionRequest_ProcessBundleProgressMetadata // *InstructionRequest_Register 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) GetFinalizeBundle ¶
func (m *InstructionRequest) GetFinalizeBundle() *FinalizeBundleRequest
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) GetProcessBundleProgressMetadata ¶
func (m *InstructionRequest) GetProcessBundleProgressMetadata() *ProcessBundleProgressMetadataRequest
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 (m *InstructionRequest) XXX_Merge(src proto.Message)
func (*InstructionRequest) XXX_OneofWrappers ¶
func (*InstructionRequest) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers 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_FinalizeBundle ¶
type InstructionRequest_FinalizeBundle struct {
FinalizeBundle *FinalizeBundleRequest `protobuf:"bytes,1004,opt,name=finalize_bundle,json=finalizeBundle,proto3,oneof"`
}
type InstructionRequest_ProcessBundle ¶
type InstructionRequest_ProcessBundle struct {
ProcessBundle *ProcessBundleRequest `protobuf:"bytes,1001,opt,name=process_bundle,json=processBundle,proto3,oneof"`
}
type InstructionRequest_ProcessBundleProgress ¶
type InstructionRequest_ProcessBundleProgress struct {
ProcessBundleProgress *ProcessBundleProgressRequest `protobuf:"bytes,1002,opt,name=process_bundle_progress,json=processBundleProgress,proto3,oneof"`
}
type InstructionRequest_ProcessBundleProgressMetadata ¶
type InstructionRequest_ProcessBundleProgressMetadata struct {
ProcessBundleProgressMetadata *ProcessBundleProgressMetadataRequest `protobuf:"bytes,1005,opt,name=process_bundle_progress_metadata,json=processBundleProgressMetadata,proto3,oneof"`
}
type InstructionRequest_ProcessBundleSplit ¶
type InstructionRequest_ProcessBundleSplit struct {
ProcessBundleSplit *ProcessBundleSplitRequest `protobuf:"bytes,1003,opt,name=process_bundle_split,json=processBundleSplit,proto3,oneof"`
}
type InstructionRequest_Register ¶
type InstructionRequest_Register struct {
Register *RegisterRequest `protobuf:"bytes,1000,opt,name=register,proto3,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,proto3" 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,proto3" 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_ProcessBundle // *InstructionResponse_ProcessBundleProgress // *InstructionResponse_ProcessBundleSplit // *InstructionResponse_FinalizeBundle // *InstructionResponse_ProcessBundleProgressMetadata // *InstructionResponse_Register 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) GetFinalizeBundle ¶
func (m *InstructionResponse) GetFinalizeBundle() *FinalizeBundleResponse
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) GetProcessBundleProgressMetadata ¶
func (m *InstructionResponse) GetProcessBundleProgressMetadata() *ProcessBundleProgressMetadataResponse
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 (m *InstructionResponse) XXX_Merge(src proto.Message)
func (*InstructionResponse) XXX_OneofWrappers ¶
func (*InstructionResponse) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers 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_FinalizeBundle ¶
type InstructionResponse_FinalizeBundle struct {
FinalizeBundle *FinalizeBundleResponse `protobuf:"bytes,1004,opt,name=finalize_bundle,json=finalizeBundle,proto3,oneof"`
}
type InstructionResponse_ProcessBundle ¶
type InstructionResponse_ProcessBundle struct {
ProcessBundle *ProcessBundleResponse `protobuf:"bytes,1001,opt,name=process_bundle,json=processBundle,proto3,oneof"`
}
type InstructionResponse_ProcessBundleProgress ¶
type InstructionResponse_ProcessBundleProgress struct {
ProcessBundleProgress *ProcessBundleProgressResponse `protobuf:"bytes,1002,opt,name=process_bundle_progress,json=processBundleProgress,proto3,oneof"`
}
type InstructionResponse_ProcessBundleProgressMetadata ¶
type InstructionResponse_ProcessBundleProgressMetadata struct {
ProcessBundleProgressMetadata *ProcessBundleProgressMetadataResponse `protobuf:"bytes,1005,opt,name=process_bundle_progress_metadata,json=processBundleProgressMetadata,proto3,oneof"`
}
type InstructionResponse_ProcessBundleSplit ¶
type InstructionResponse_ProcessBundleSplit struct {
ProcessBundleSplit *ProcessBundleSplitResponse `protobuf:"bytes,1003,opt,name=process_bundle_split,json=processBundleSplit,proto3,oneof"`
}
type InstructionResponse_Register ¶
type InstructionResponse_Register struct {
Register *RegisterResponse `protobuf:"bytes,1000,opt,name=register,proto3,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 (m *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 `` /* 136-byte string literal not displayed */ // (Required) The time at which this log statement occurred. Timestamp *timestamp.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // (Required) A human readable message. Message string `protobuf:"bytes,3,opt,name=message,proto3" 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,proto3" json:"trace,omitempty"` // (Optional) A reference to the instruction this log statement is associated // with. InstructionId string `protobuf:"bytes,5,opt,name=instruction_id,json=instructionId,proto3" json:"instruction_id,omitempty"` // (Optional) A reference to the transform this log statement is // associated with. TransformId string `protobuf:"bytes,6,opt,name=transform_id,json=transformId,proto3" json:"transform_id,omitempty"` // (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,proto3" json:"log_location,omitempty"` // (Optional) The name of the thread this log statement is associated with. Thread string `protobuf:"bytes,8,opt,name=thread,proto3" json:"thread,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A log entry
func (*LogEntry) GetSeverity ¶
func (m *LogEntry) GetSeverity() LogEntry_Severity_Enum
func (*LogEntry) XXX_Marshal ¶
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,proto3" 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 (m *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 (m *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 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 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,proto3" json:"id,omitempty"` // (Required) A map from pipeline-scoped id to PTransform. Transforms map[string]*pipeline_v1.PTransform `` /* 161-byte string literal not displayed */ // (Required) A map from pipeline-scoped id to PCollection. Pcollections map[string]*pipeline_v1.PCollection `` /* 165-byte string literal not displayed */ // (Required) A map from pipeline-scoped id to WindowingStrategy. WindowingStrategies map[string]*pipeline_v1.WindowingStrategy `` /* 206-byte string literal not displayed */ // (Required) A map from pipeline-scoped id to Coder. Coders map[string]*pipeline_v1.Coder `` /* 153-byte string literal not displayed */ // (Required) A map from pipeline-scoped id to Environment. Environments map[string]*pipeline_v1.Environment `` /* 165-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 `` /* 140-byte string literal not displayed */ // A descriptor describing the end point to use for Data API for user timers. // Required if the ProcessBundleDescriptor contains any transforms that have user timers. TimerApiServiceDescriptor *pipeline_v1.ApiServiceDescriptor `` /* 140-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) GetTimerApiServiceDescriptor ¶
func (m *ProcessBundleDescriptor) GetTimerApiServiceDescriptor() *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 (m *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 ProcessBundleProgressMetadataRequest ¶
type ProcessBundleProgressMetadataRequest struct { // A list of ids for which the full MonitoringInfo is requested for. MonitoringInfoId []string `protobuf:"bytes,1,rep,name=monitoring_info_id,json=monitoringInfoId,proto3" json:"monitoring_info_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A request to provide full MonitoringInfo for a given bundle.
An SDK can report metrics using an identifier that only contains the associated payload. A runner who wants to receive the full metrics information can request all the monitoring metadata via a ProcessBundleProgressMetadataRequest providing a list of ids as necessary.
The SDK is allowed to reuse the identifiers across multiple bundles as long as the MonitoringInfo could be reconstructed fully by overwriting its payload field with the bytes specified here.
func (*ProcessBundleProgressMetadataRequest) Descriptor ¶
func (*ProcessBundleProgressMetadataRequest) Descriptor() ([]byte, []int)
func (*ProcessBundleProgressMetadataRequest) GetMonitoringInfoId ¶
func (m *ProcessBundleProgressMetadataRequest) GetMonitoringInfoId() []string
func (*ProcessBundleProgressMetadataRequest) ProtoMessage ¶
func (*ProcessBundleProgressMetadataRequest) ProtoMessage()
func (*ProcessBundleProgressMetadataRequest) Reset ¶
func (m *ProcessBundleProgressMetadataRequest) Reset()
func (*ProcessBundleProgressMetadataRequest) String ¶
func (m *ProcessBundleProgressMetadataRequest) String() string
func (*ProcessBundleProgressMetadataRequest) XXX_DiscardUnknown ¶
func (m *ProcessBundleProgressMetadataRequest) XXX_DiscardUnknown()
func (*ProcessBundleProgressMetadataRequest) XXX_Marshal ¶
func (m *ProcessBundleProgressMetadataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessBundleProgressMetadataRequest) XXX_Merge ¶
func (m *ProcessBundleProgressMetadataRequest) XXX_Merge(src proto.Message)
func (*ProcessBundleProgressMetadataRequest) XXX_Size ¶
func (m *ProcessBundleProgressMetadataRequest) XXX_Size() int
func (*ProcessBundleProgressMetadataRequest) XXX_Unmarshal ¶
func (m *ProcessBundleProgressMetadataRequest) XXX_Unmarshal(b []byte) error
type ProcessBundleProgressMetadataResponse ¶
type ProcessBundleProgressMetadataResponse struct { // A mapping from an identifier to the full metrics information. MonitoringInfo map[string]*pipeline_v1.MonitoringInfo `` /* 191-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A response that contains the full mapping information associated with a specified set of identifiers.
An SDK can report metrics using an identifier that only contains the associated payload. A runner who wants to receive the full metrics information can request all the monitoring metadata via a ProcessBundleProgressMetadataRequest providing a list of ids as necessary.
The SDK is allowed to reuse the identifiers across multiple bundles as long as the MonitoringInfo could be reconstructed fully by overwriting its payload field with the bytes specified here.
func (*ProcessBundleProgressMetadataResponse) Descriptor ¶
func (*ProcessBundleProgressMetadataResponse) Descriptor() ([]byte, []int)
func (*ProcessBundleProgressMetadataResponse) GetMonitoringInfo ¶
func (m *ProcessBundleProgressMetadataResponse) GetMonitoringInfo() map[string]*pipeline_v1.MonitoringInfo
func (*ProcessBundleProgressMetadataResponse) ProtoMessage ¶
func (*ProcessBundleProgressMetadataResponse) ProtoMessage()
func (*ProcessBundleProgressMetadataResponse) Reset ¶
func (m *ProcessBundleProgressMetadataResponse) Reset()
func (*ProcessBundleProgressMetadataResponse) String ¶
func (m *ProcessBundleProgressMetadataResponse) String() string
func (*ProcessBundleProgressMetadataResponse) XXX_DiscardUnknown ¶
func (m *ProcessBundleProgressMetadataResponse) XXX_DiscardUnknown()
func (*ProcessBundleProgressMetadataResponse) XXX_Marshal ¶
func (m *ProcessBundleProgressMetadataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessBundleProgressMetadataResponse) XXX_Merge ¶
func (m *ProcessBundleProgressMetadataResponse) XXX_Merge(src proto.Message)
func (*ProcessBundleProgressMetadataResponse) XXX_Size ¶
func (m *ProcessBundleProgressMetadataResponse) XXX_Size() int
func (*ProcessBundleProgressMetadataResponse) XXX_Unmarshal ¶
func (m *ProcessBundleProgressMetadataResponse) XXX_Unmarshal(b []byte) error
type ProcessBundleProgressRequest ¶
type ProcessBundleProgressRequest struct { // (Required) A reference to an active process bundle request with the given // instruction id. InstructionId string `protobuf:"bytes,1,opt,name=instruction_id,json=instructionId,proto3" json:"instruction_id,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) GetInstructionId ¶
func (m *ProcessBundleProgressRequest) GetInstructionId() 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 (m *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 { // DEPRECATED (Required) The list of metrics or other MonitoredState // collected while processing this bundle. MonitoringInfos []*pipeline_v1.MonitoringInfo `protobuf:"bytes,3,rep,name=monitoring_infos,json=monitoringInfos,proto3" json:"monitoring_infos,omitempty"` // An identifier to MonitoringInfo.payload mapping. // // An SDK can report metrics using an identifier that only contains the // associated payload. A runner who wants to receive the full metrics // information can request all the monitoring metadata via a // ProcessBundleProgressMetadataRequest providing a list of ids as necessary. // // The SDK is allowed to reuse the identifiers across multiple bundles as long // as the MonitoringInfo could be reconstructed fully by overwriting its // payload field with the bytes specified here. MonitoringData map[string][]byte `` /* 191-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProcessBundleProgressResponse) Descriptor ¶
func (*ProcessBundleProgressResponse) Descriptor() ([]byte, []int)
func (*ProcessBundleProgressResponse) GetMonitoringData ¶
func (m *ProcessBundleProgressResponse) GetMonitoringData() map[string][]byte
func (*ProcessBundleProgressResponse) GetMonitoringInfos ¶
func (m *ProcessBundleProgressResponse) GetMonitoringInfos() []*pipeline_v1.MonitoringInfo
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 (m *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. ProcessBundleDescriptorId string `` /* 140-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 []*ProcessBundleRequest_CacheToken `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() []*ProcessBundleRequest_CacheToken
func (*ProcessBundleRequest) GetProcessBundleDescriptorId ¶
func (m *ProcessBundleRequest) GetProcessBundleDescriptorId() 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 (m *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 ProcessBundleRequest_CacheToken ¶
type ProcessBundleRequest_CacheToken struct { // The scope of a cache token. // // Types that are valid to be assigned to Type: // *ProcessBundleRequest_CacheToken_UserState_ // *ProcessBundleRequest_CacheToken_SideInput_ Type isProcessBundleRequest_CacheToken_Type `protobuf_oneof:"type"` // The cache token identifier which should be globally unique. Token []byte `protobuf:"bytes,10,opt,name=token,proto3" json:"token,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A cache token which can be used by an SDK to check for the validity of cached elements which have a cache token associated.
func (*ProcessBundleRequest_CacheToken) Descriptor ¶
func (*ProcessBundleRequest_CacheToken) Descriptor() ([]byte, []int)
func (*ProcessBundleRequest_CacheToken) GetSideInput ¶
func (m *ProcessBundleRequest_CacheToken) GetSideInput() *ProcessBundleRequest_CacheToken_SideInput
func (*ProcessBundleRequest_CacheToken) GetToken ¶
func (m *ProcessBundleRequest_CacheToken) GetToken() []byte
func (*ProcessBundleRequest_CacheToken) GetType ¶
func (m *ProcessBundleRequest_CacheToken) GetType() isProcessBundleRequest_CacheToken_Type
func (*ProcessBundleRequest_CacheToken) GetUserState ¶
func (m *ProcessBundleRequest_CacheToken) GetUserState() *ProcessBundleRequest_CacheToken_UserState
func (*ProcessBundleRequest_CacheToken) ProtoMessage ¶
func (*ProcessBundleRequest_CacheToken) ProtoMessage()
func (*ProcessBundleRequest_CacheToken) Reset ¶
func (m *ProcessBundleRequest_CacheToken) Reset()
func (*ProcessBundleRequest_CacheToken) String ¶
func (m *ProcessBundleRequest_CacheToken) String() string
func (*ProcessBundleRequest_CacheToken) XXX_DiscardUnknown ¶
func (m *ProcessBundleRequest_CacheToken) XXX_DiscardUnknown()
func (*ProcessBundleRequest_CacheToken) XXX_Marshal ¶
func (m *ProcessBundleRequest_CacheToken) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessBundleRequest_CacheToken) XXX_Merge ¶
func (m *ProcessBundleRequest_CacheToken) XXX_Merge(src proto.Message)
func (*ProcessBundleRequest_CacheToken) XXX_OneofWrappers ¶
func (*ProcessBundleRequest_CacheToken) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*ProcessBundleRequest_CacheToken) XXX_Size ¶
func (m *ProcessBundleRequest_CacheToken) XXX_Size() int
func (*ProcessBundleRequest_CacheToken) XXX_Unmarshal ¶
func (m *ProcessBundleRequest_CacheToken) XXX_Unmarshal(b []byte) error
type ProcessBundleRequest_CacheToken_SideInput ¶
type ProcessBundleRequest_CacheToken_SideInput struct { // (Required) The id of the PTransform containing a side input. TransformId string `protobuf:"bytes,1,opt,name=transform_id,json=transformId,proto3" json:"transform_id,omitempty"` // (Required) The id of the side input. SideInputId string `protobuf:"bytes,2,opt,name=side_input_id,json=sideInputId,proto3" json:"side_input_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A flag to indicate a cache token is valid for a side input.
func (*ProcessBundleRequest_CacheToken_SideInput) Descriptor ¶
func (*ProcessBundleRequest_CacheToken_SideInput) Descriptor() ([]byte, []int)
func (*ProcessBundleRequest_CacheToken_SideInput) GetSideInputId ¶
func (m *ProcessBundleRequest_CacheToken_SideInput) GetSideInputId() string
func (*ProcessBundleRequest_CacheToken_SideInput) GetTransformId ¶
func (m *ProcessBundleRequest_CacheToken_SideInput) GetTransformId() string
func (*ProcessBundleRequest_CacheToken_SideInput) ProtoMessage ¶
func (*ProcessBundleRequest_CacheToken_SideInput) ProtoMessage()
func (*ProcessBundleRequest_CacheToken_SideInput) Reset ¶
func (m *ProcessBundleRequest_CacheToken_SideInput) Reset()
func (*ProcessBundleRequest_CacheToken_SideInput) String ¶
func (m *ProcessBundleRequest_CacheToken_SideInput) String() string
func (*ProcessBundleRequest_CacheToken_SideInput) XXX_DiscardUnknown ¶
func (m *ProcessBundleRequest_CacheToken_SideInput) XXX_DiscardUnknown()
func (*ProcessBundleRequest_CacheToken_SideInput) XXX_Marshal ¶
func (m *ProcessBundleRequest_CacheToken_SideInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessBundleRequest_CacheToken_SideInput) XXX_Merge ¶
func (m *ProcessBundleRequest_CacheToken_SideInput) XXX_Merge(src proto.Message)
func (*ProcessBundleRequest_CacheToken_SideInput) XXX_Size ¶
func (m *ProcessBundleRequest_CacheToken_SideInput) XXX_Size() int
func (*ProcessBundleRequest_CacheToken_SideInput) XXX_Unmarshal ¶
func (m *ProcessBundleRequest_CacheToken_SideInput) XXX_Unmarshal(b []byte) error
type ProcessBundleRequest_CacheToken_SideInput_ ¶
type ProcessBundleRequest_CacheToken_SideInput_ struct {
SideInput *ProcessBundleRequest_CacheToken_SideInput `protobuf:"bytes,2,opt,name=side_input,json=sideInput,proto3,oneof"`
}
type ProcessBundleRequest_CacheToken_UserState ¶
type ProcessBundleRequest_CacheToken_UserState struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A flag to indicate a cache token is valid for all user state.
func (*ProcessBundleRequest_CacheToken_UserState) Descriptor ¶
func (*ProcessBundleRequest_CacheToken_UserState) Descriptor() ([]byte, []int)
func (*ProcessBundleRequest_CacheToken_UserState) ProtoMessage ¶
func (*ProcessBundleRequest_CacheToken_UserState) ProtoMessage()
func (*ProcessBundleRequest_CacheToken_UserState) Reset ¶
func (m *ProcessBundleRequest_CacheToken_UserState) Reset()
func (*ProcessBundleRequest_CacheToken_UserState) String ¶
func (m *ProcessBundleRequest_CacheToken_UserState) String() string
func (*ProcessBundleRequest_CacheToken_UserState) XXX_DiscardUnknown ¶
func (m *ProcessBundleRequest_CacheToken_UserState) XXX_DiscardUnknown()
func (*ProcessBundleRequest_CacheToken_UserState) XXX_Marshal ¶
func (m *ProcessBundleRequest_CacheToken_UserState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessBundleRequest_CacheToken_UserState) XXX_Merge ¶
func (m *ProcessBundleRequest_CacheToken_UserState) XXX_Merge(src proto.Message)
func (*ProcessBundleRequest_CacheToken_UserState) XXX_Size ¶
func (m *ProcessBundleRequest_CacheToken_UserState) XXX_Size() int
func (*ProcessBundleRequest_CacheToken_UserState) XXX_Unmarshal ¶
func (m *ProcessBundleRequest_CacheToken_UserState) XXX_Unmarshal(b []byte) error
type ProcessBundleRequest_CacheToken_UserState_ ¶
type ProcessBundleRequest_CacheToken_UserState_ struct {
UserState *ProcessBundleRequest_CacheToken_UserState `protobuf:"bytes,1,opt,name=user_state,json=userState,proto3,oneof"`
}
type ProcessBundleResponse ¶
type ProcessBundleResponse struct { // (Optional) Specifies that the bundle has not been completed and the // following applications need to be scheduled and executed in the future. // A runner that does not yet support residual roots MUST still check that // this is empty for correctness. ResidualRoots []*DelayedBundleApplication `protobuf:"bytes,2,rep,name=residual_roots,json=residualRoots,proto3" json:"residual_roots,omitempty"` // DEPRECATED (Required) The list of metrics or other MonitoredState // collected while processing this bundle. MonitoringInfos []*pipeline_v1.MonitoringInfo `protobuf:"bytes,3,rep,name=monitoring_infos,json=monitoringInfos,proto3" json:"monitoring_infos,omitempty"` // (Optional) Specifies that the runner must callback to this worker // once the output of the bundle is committed. The Runner must send a // FinalizeBundleRequest with the instruction id of the ProcessBundleRequest // that is related to this ProcessBundleResponse. RequiresFinalization bool `protobuf:"varint,4,opt,name=requires_finalization,json=requiresFinalization,proto3" json:"requires_finalization,omitempty"` // An identifier to MonitoringInfo.payload mapping. // // An SDK can report metrics using an identifier that only contains the // associated payload. A runner who wants to receive the full metrics // information can request all the monitoring metadata via a // ProcessBundleProgressMetadataRequest providing a list of ids as necessary. // // The SDK is allowed to reuse the identifiers across multiple bundles as long // as the MonitoringInfo could be reconstructed fully by overwriting its // payload field with the bytes specified here. MonitoringData map[string][]byte `` /* 191-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProcessBundleResponse) Descriptor ¶
func (*ProcessBundleResponse) Descriptor() ([]byte, []int)
func (*ProcessBundleResponse) GetMonitoringData ¶
func (m *ProcessBundleResponse) GetMonitoringData() map[string][]byte
func (*ProcessBundleResponse) GetMonitoringInfos ¶
func (m *ProcessBundleResponse) GetMonitoringInfos() []*pipeline_v1.MonitoringInfo
func (*ProcessBundleResponse) GetRequiresFinalization ¶
func (m *ProcessBundleResponse) GetRequiresFinalization() bool
func (*ProcessBundleResponse) GetResidualRoots ¶
func (m *ProcessBundleResponse) GetResidualRoots() []*DelayedBundleApplication
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 (m *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. InstructionId string `protobuf:"bytes,1,opt,name=instruction_id,json=instructionId,proto3" json:"instruction_id,omitempty"` // (Required) Specifies the desired split for each transform. // // Currently only splits at GRPC read operations are supported. // This may, of course, limit the amount of work downstream operations // receive. DesiredSplits map[string]*ProcessBundleSplitRequest_DesiredSplit `` /* 188-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Represents a request to the SDK to split a currently active bundle.
func (*ProcessBundleSplitRequest) Descriptor ¶
func (*ProcessBundleSplitRequest) Descriptor() ([]byte, []int)
func (*ProcessBundleSplitRequest) GetDesiredSplits ¶
func (m *ProcessBundleSplitRequest) GetDesiredSplits() map[string]*ProcessBundleSplitRequest_DesiredSplit
func (*ProcessBundleSplitRequest) GetInstructionId ¶
func (m *ProcessBundleSplitRequest) GetInstructionId() 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 (m *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 ProcessBundleSplitRequest_DesiredSplit ¶
type ProcessBundleSplitRequest_DesiredSplit struct { // (Required) The fraction of known work remaining in this bundle // for this transform that should be kept by the SDK after this split. // // Set to 0 to "checkpoint" as soon as possible (keeping as little work as // possible and returning the remainder). FractionOfRemainder float64 `protobuf:"fixed64,1,opt,name=fraction_of_remainder,json=fractionOfRemainder,proto3" json:"fraction_of_remainder,omitempty"` // A set of allowed element indices where the SDK may split. When this is // empty, there are no constraints on where to split. // Specifically, the first_residual_element of a split result must be an // allowed split point, and the last_primary_element must immediately // preceded an allowed split point. AllowedSplitPoints []int64 `protobuf:"varint,3,rep,packed,name=allowed_split_points,json=allowedSplitPoints,proto3" json:"allowed_split_points,omitempty"` // (Required for GrpcRead operations) Number of total elements expected // to be sent to this GrpcRead operation, required to correctly account // for unreceived data when determining where to split. EstimatedInputElements int64 `` /* 130-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A message specifying the desired split for a single transform.
func (*ProcessBundleSplitRequest_DesiredSplit) Descriptor ¶
func (*ProcessBundleSplitRequest_DesiredSplit) Descriptor() ([]byte, []int)
func (*ProcessBundleSplitRequest_DesiredSplit) GetAllowedSplitPoints ¶
func (m *ProcessBundleSplitRequest_DesiredSplit) GetAllowedSplitPoints() []int64
func (*ProcessBundleSplitRequest_DesiredSplit) GetEstimatedInputElements ¶
func (m *ProcessBundleSplitRequest_DesiredSplit) GetEstimatedInputElements() int64
func (*ProcessBundleSplitRequest_DesiredSplit) GetFractionOfRemainder ¶
func (m *ProcessBundleSplitRequest_DesiredSplit) GetFractionOfRemainder() float64
func (*ProcessBundleSplitRequest_DesiredSplit) ProtoMessage ¶
func (*ProcessBundleSplitRequest_DesiredSplit) ProtoMessage()
func (*ProcessBundleSplitRequest_DesiredSplit) Reset ¶
func (m *ProcessBundleSplitRequest_DesiredSplit) Reset()
func (*ProcessBundleSplitRequest_DesiredSplit) String ¶
func (m *ProcessBundleSplitRequest_DesiredSplit) String() string
func (*ProcessBundleSplitRequest_DesiredSplit) XXX_DiscardUnknown ¶
func (m *ProcessBundleSplitRequest_DesiredSplit) XXX_DiscardUnknown()
func (*ProcessBundleSplitRequest_DesiredSplit) XXX_Marshal ¶
func (m *ProcessBundleSplitRequest_DesiredSplit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessBundleSplitRequest_DesiredSplit) XXX_Merge ¶
func (m *ProcessBundleSplitRequest_DesiredSplit) XXX_Merge(src proto.Message)
func (*ProcessBundleSplitRequest_DesiredSplit) XXX_Size ¶
func (m *ProcessBundleSplitRequest_DesiredSplit) XXX_Size() int
func (*ProcessBundleSplitRequest_DesiredSplit) XXX_Unmarshal ¶
func (m *ProcessBundleSplitRequest_DesiredSplit) XXX_Unmarshal(b []byte) error
type ProcessBundleSplitResponse ¶
type ProcessBundleSplitResponse struct { // Root applications that should replace the current bundle. PrimaryRoots []*BundleApplication `protobuf:"bytes,1,rep,name=primary_roots,json=primaryRoots,proto3" 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 []*DelayedBundleApplication `protobuf:"bytes,2,rep,name=residual_roots,json=residualRoots,proto3" json:"residual_roots,omitempty"` // Partitions of input data channels into primary and residual elements, // if any. Should not include any elements represented in the bundle // applications roots above. ChannelSplits []*ProcessBundleSplitResponse_ChannelSplit `protobuf:"bytes,3,rep,name=channel_splits,json=channelSplits,proto3" json:"channel_splits,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Represents a partition of the bundle: 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 (*ProcessBundleSplitResponse) Descriptor ¶
func (*ProcessBundleSplitResponse) Descriptor() ([]byte, []int)
func (*ProcessBundleSplitResponse) GetChannelSplits ¶
func (m *ProcessBundleSplitResponse) GetChannelSplits() []*ProcessBundleSplitResponse_ChannelSplit
func (*ProcessBundleSplitResponse) GetPrimaryRoots ¶
func (m *ProcessBundleSplitResponse) GetPrimaryRoots() []*BundleApplication
func (*ProcessBundleSplitResponse) GetResidualRoots ¶
func (m *ProcessBundleSplitResponse) GetResidualRoots() []*DelayedBundleApplication
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 (m *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 ProcessBundleSplitResponse_ChannelSplit ¶
type ProcessBundleSplitResponse_ChannelSplit struct { // (Required) The grpc read transform reading this channel. TransformId string `protobuf:"bytes,1,opt,name=transform_id,json=transformId,proto3" json:"transform_id,omitempty"` // The last element of the input channel that should be entirely considered // part of the primary, identified by its absolute index in the (ordered) // channel. LastPrimaryElement int64 `protobuf:"varint,2,opt,name=last_primary_element,json=lastPrimaryElement,proto3" json:"last_primary_element,omitempty"` // The first element of the input channel that should be entirely considered // part of the residual, identified by its absolute index in the (ordered) // channel. FirstResidualElement int64 `protobuf:"varint,3,opt,name=first_residual_element,json=firstResidualElement,proto3" json:"first_residual_element,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Represents contiguous portions of the data channel that are either entirely processed or entirely unprocessed and belong to the primary or residual respectively.
This affords both a more efficient representation over the FnAPI (if the bundle is large) and often a more efficient representation on the runner side (e.g. if the set of elements can be represented as some range in an underlying dataset).
func (*ProcessBundleSplitResponse_ChannelSplit) Descriptor ¶
func (*ProcessBundleSplitResponse_ChannelSplit) Descriptor() ([]byte, []int)
func (*ProcessBundleSplitResponse_ChannelSplit) GetFirstResidualElement ¶
func (m *ProcessBundleSplitResponse_ChannelSplit) GetFirstResidualElement() int64
func (*ProcessBundleSplitResponse_ChannelSplit) GetLastPrimaryElement ¶
func (m *ProcessBundleSplitResponse_ChannelSplit) GetLastPrimaryElement() int64
func (*ProcessBundleSplitResponse_ChannelSplit) GetTransformId ¶
func (m *ProcessBundleSplitResponse_ChannelSplit) GetTransformId() string
func (*ProcessBundleSplitResponse_ChannelSplit) ProtoMessage ¶
func (*ProcessBundleSplitResponse_ChannelSplit) ProtoMessage()
func (*ProcessBundleSplitResponse_ChannelSplit) Reset ¶
func (m *ProcessBundleSplitResponse_ChannelSplit) Reset()
func (*ProcessBundleSplitResponse_ChannelSplit) String ¶
func (m *ProcessBundleSplitResponse_ChannelSplit) String() string
func (*ProcessBundleSplitResponse_ChannelSplit) XXX_DiscardUnknown ¶
func (m *ProcessBundleSplitResponse_ChannelSplit) XXX_DiscardUnknown()
func (*ProcessBundleSplitResponse_ChannelSplit) XXX_Marshal ¶
func (m *ProcessBundleSplitResponse_ChannelSplit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessBundleSplitResponse_ChannelSplit) XXX_Merge ¶
func (m *ProcessBundleSplitResponse_ChannelSplit) XXX_Merge(src proto.Message)
func (*ProcessBundleSplitResponse_ChannelSplit) XXX_Size ¶
func (m *ProcessBundleSplitResponse_ChannelSplit) XXX_Size() int
func (*ProcessBundleSplitResponse_ChannelSplit) XXX_Unmarshal ¶
func (m *ProcessBundleSplitResponse_ChannelSplit) XXX_Unmarshal(b []byte) error
type ProvisionInfo ¶
type ProvisionInfo struct { // (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,proto3" json:"pipeline_options,omitempty"` // (required) The artifact retrieval token produced by // LegacyArtifactStagingService.CommitManifestResponse. RetrievalToken string `protobuf:"bytes,6,opt,name=retrieval_token,json=retrievalToken,proto3" json:"retrieval_token,omitempty"` // (optional) The endpoint that the runner is hosting for the SDK to submit // status reports to during pipeline execution. This field will only be // populated if the runner supports SDK status reports. For more details see // https://s.apache.org/beam-fn-api-harness-status StatusEndpoint *pipeline_v1.ApiServiceDescriptor `protobuf:"bytes,7,opt,name=status_endpoint,json=statusEndpoint,proto3" json:"status_endpoint,omitempty"` // (optional) The logging endpoint this SDK should use. LoggingEndpoint *pipeline_v1.ApiServiceDescriptor `protobuf:"bytes,8,opt,name=logging_endpoint,json=loggingEndpoint,proto3" json:"logging_endpoint,omitempty"` // (optional) The artifact retrieval endpoint this SDK should use. ArtifactEndpoint *pipeline_v1.ApiServiceDescriptor `protobuf:"bytes,9,opt,name=artifact_endpoint,json=artifactEndpoint,proto3" json:"artifact_endpoint,omitempty"` // (optional) The control endpoint this SDK should use. ControlEndpoint *pipeline_v1.ApiServiceDescriptor `protobuf:"bytes,10,opt,name=control_endpoint,json=controlEndpoint,proto3" json:"control_endpoint,omitempty"` // The set of dependencies that should be staged into this environment. Dependencies []*pipeline_v1.ArtifactInformation `protobuf:"bytes,11,rep,name=dependencies,proto3" json:"dependencies,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) GetArtifactEndpoint ¶
func (m *ProvisionInfo) GetArtifactEndpoint() *pipeline_v1.ApiServiceDescriptor
func (*ProvisionInfo) GetControlEndpoint ¶
func (m *ProvisionInfo) GetControlEndpoint() *pipeline_v1.ApiServiceDescriptor
func (*ProvisionInfo) GetDependencies ¶
func (m *ProvisionInfo) GetDependencies() []*pipeline_v1.ArtifactInformation
func (*ProvisionInfo) GetLoggingEndpoint ¶
func (m *ProvisionInfo) GetLoggingEndpoint() *pipeline_v1.ApiServiceDescriptor
func (*ProvisionInfo) GetPipelineOptions ¶
func (m *ProvisionInfo) GetPipelineOptions() *_struct.Struct
func (*ProvisionInfo) GetRetrievalToken ¶
func (m *ProvisionInfo) GetRetrievalToken() string
func (*ProvisionInfo) GetStatusEndpoint ¶
func (m *ProvisionInfo) GetStatusEndpoint() *pipeline_v1.ApiServiceDescriptor
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 (m *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 `` /* 132-byte string literal not displayed */ 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 (m *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 (m *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,proto3" 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,proto3" 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 (m *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 StartWorkerRequest ¶
type StartWorkerRequest struct { WorkerId string `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"` ControlEndpoint *pipeline_v1.ApiServiceDescriptor `protobuf:"bytes,2,opt,name=control_endpoint,json=controlEndpoint,proto3" json:"control_endpoint,omitempty"` LoggingEndpoint *pipeline_v1.ApiServiceDescriptor `protobuf:"bytes,3,opt,name=logging_endpoint,json=loggingEndpoint,proto3" json:"logging_endpoint,omitempty"` ArtifactEndpoint *pipeline_v1.ApiServiceDescriptor `protobuf:"bytes,4,opt,name=artifact_endpoint,json=artifactEndpoint,proto3" json:"artifact_endpoint,omitempty"` ProvisionEndpoint *pipeline_v1.ApiServiceDescriptor `protobuf:"bytes,5,opt,name=provision_endpoint,json=provisionEndpoint,proto3" json:"provision_endpoint,omitempty"` Params map[string]string `` /* 154-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StartWorkerRequest) Descriptor ¶
func (*StartWorkerRequest) Descriptor() ([]byte, []int)
func (*StartWorkerRequest) GetArtifactEndpoint ¶
func (m *StartWorkerRequest) GetArtifactEndpoint() *pipeline_v1.ApiServiceDescriptor
func (*StartWorkerRequest) GetControlEndpoint ¶
func (m *StartWorkerRequest) GetControlEndpoint() *pipeline_v1.ApiServiceDescriptor
func (*StartWorkerRequest) GetLoggingEndpoint ¶
func (m *StartWorkerRequest) GetLoggingEndpoint() *pipeline_v1.ApiServiceDescriptor
func (*StartWorkerRequest) GetParams ¶
func (m *StartWorkerRequest) GetParams() map[string]string
func (*StartWorkerRequest) GetProvisionEndpoint ¶
func (m *StartWorkerRequest) GetProvisionEndpoint() *pipeline_v1.ApiServiceDescriptor
func (*StartWorkerRequest) GetWorkerId ¶
func (m *StartWorkerRequest) GetWorkerId() string
func (*StartWorkerRequest) ProtoMessage ¶
func (*StartWorkerRequest) ProtoMessage()
func (*StartWorkerRequest) Reset ¶
func (m *StartWorkerRequest) Reset()
func (*StartWorkerRequest) String ¶
func (m *StartWorkerRequest) String() string
func (*StartWorkerRequest) XXX_DiscardUnknown ¶
func (m *StartWorkerRequest) XXX_DiscardUnknown()
func (*StartWorkerRequest) XXX_Marshal ¶
func (m *StartWorkerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartWorkerRequest) XXX_Merge ¶
func (m *StartWorkerRequest) XXX_Merge(src proto.Message)
func (*StartWorkerRequest) XXX_Size ¶
func (m *StartWorkerRequest) XXX_Size() int
func (*StartWorkerRequest) XXX_Unmarshal ¶
func (m *StartWorkerRequest) XXX_Unmarshal(b []byte) error
type StartWorkerResponse ¶
type StartWorkerResponse struct { Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StartWorkerResponse) Descriptor ¶
func (*StartWorkerResponse) Descriptor() ([]byte, []int)
func (*StartWorkerResponse) GetError ¶
func (m *StartWorkerResponse) GetError() string
func (*StartWorkerResponse) ProtoMessage ¶
func (*StartWorkerResponse) ProtoMessage()
func (*StartWorkerResponse) Reset ¶
func (m *StartWorkerResponse) Reset()
func (*StartWorkerResponse) String ¶
func (m *StartWorkerResponse) String() string
func (*StartWorkerResponse) XXX_DiscardUnknown ¶
func (m *StartWorkerResponse) XXX_DiscardUnknown()
func (*StartWorkerResponse) XXX_Marshal ¶
func (m *StartWorkerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartWorkerResponse) XXX_Merge ¶
func (m *StartWorkerResponse) XXX_Merge(src proto.Message)
func (*StartWorkerResponse) XXX_Size ¶
func (m *StartWorkerResponse) XXX_Size() int
func (*StartWorkerResponse) XXX_Unmarshal ¶
func (m *StartWorkerResponse) 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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *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_ // *StateKey_IterableSideInput_ // *StateKey_MultimapKeysSideInput_ Type isStateKey_Type `protobuf_oneof:"type"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StateKey) GetBagUserState ¶
func (m *StateKey) GetBagUserState() *StateKey_BagUserState
func (*StateKey) GetIterableSideInput ¶
func (m *StateKey) GetIterableSideInput() *StateKey_IterableSideInput
func (*StateKey) GetMultimapKeysSideInput ¶
func (m *StateKey) GetMultimapKeysSideInput() *StateKey_MultimapKeysSideInput
func (*StateKey) GetMultimapSideInput ¶
func (m *StateKey) GetMultimapSideInput() *StateKey_MultimapSideInput
func (*StateKey) GetRunner ¶
func (m *StateKey) GetRunner() *StateKey_Runner
func (*StateKey) XXX_Marshal ¶
type StateKey_BagUserState ¶
type StateKey_BagUserState struct { // (Required) The id of the PTransform containing user state. TransformId string `protobuf:"bytes,1,opt,name=transform_id,json=transformId,proto3" json:"transform_id,omitempty"` // (Required) The id of the user state. UserStateId string `protobuf:"bytes,2,opt,name=user_state_id,json=userStateId,proto3" 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) GetTransformId ¶
func (m *StateKey_BagUserState) GetTransformId() 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 (m *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,proto3,oneof"`
}
type StateKey_IterableSideInput ¶
type StateKey_IterableSideInput struct { // (Required) The id of the PTransform containing a side input. TransformId string `protobuf:"bytes,1,opt,name=transform_id,json=transformId,proto3" json:"transform_id,omitempty"` // (Required) The id of the side input. SideInputId string `protobuf:"bytes,2,opt,name=side_input_id,json=sideInputId,proto3" 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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Represents a request for the values associated with a specified window in a PCollection. See https://s.apache.org/beam-fn-state-api-and-bundle-processing for further details.
Can only be used to perform StateGetRequests on side inputs of the URN beam:side_input:iterable:v1.
For a PCollection<V>, the response data stream will be a concatenation of all V's. See https://s.apache.org/beam-fn-api-send-and-receive-data for further details.
func (*StateKey_IterableSideInput) Descriptor ¶
func (*StateKey_IterableSideInput) Descriptor() ([]byte, []int)
func (*StateKey_IterableSideInput) GetSideInputId ¶
func (m *StateKey_IterableSideInput) GetSideInputId() string
func (*StateKey_IterableSideInput) GetTransformId ¶
func (m *StateKey_IterableSideInput) GetTransformId() string
func (*StateKey_IterableSideInput) GetWindow ¶
func (m *StateKey_IterableSideInput) GetWindow() []byte
func (*StateKey_IterableSideInput) ProtoMessage ¶
func (*StateKey_IterableSideInput) ProtoMessage()
func (*StateKey_IterableSideInput) Reset ¶
func (m *StateKey_IterableSideInput) Reset()
func (*StateKey_IterableSideInput) String ¶
func (m *StateKey_IterableSideInput) String() string
func (*StateKey_IterableSideInput) XXX_DiscardUnknown ¶
func (m *StateKey_IterableSideInput) XXX_DiscardUnknown()
func (*StateKey_IterableSideInput) XXX_Marshal ¶
func (m *StateKey_IterableSideInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StateKey_IterableSideInput) XXX_Merge ¶
func (m *StateKey_IterableSideInput) XXX_Merge(src proto.Message)
func (*StateKey_IterableSideInput) XXX_Size ¶
func (m *StateKey_IterableSideInput) XXX_Size() int
func (*StateKey_IterableSideInput) XXX_Unmarshal ¶
func (m *StateKey_IterableSideInput) XXX_Unmarshal(b []byte) error
type StateKey_IterableSideInput_ ¶
type StateKey_IterableSideInput_ struct {
IterableSideInput *StateKey_IterableSideInput `protobuf:"bytes,4,opt,name=iterable_side_input,json=iterableSideInput,proto3,oneof"`
}
type StateKey_MultimapKeysSideInput ¶
type StateKey_MultimapKeysSideInput struct { // (Required) The id of the PTransform containing a side input. TransformId string `protobuf:"bytes,1,opt,name=transform_id,json=transformId,proto3" json:"transform_id,omitempty"` // (Required) The id of the side input. SideInputId string `protobuf:"bytes,2,opt,name=side_input_id,json=sideInputId,proto3" 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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Represents a request for the keys associated with a specified window in a PCollection. See https://s.apache.org/beam-fn-state-api-and-bundle-processing for further details.
Can only be used to perform StateGetRequests on side inputs of the URN beam:side_input:multimap:v1.
For a PCollection<KV<K, V>>, the response data stream will be a concatenation of all K's associated with the specified window. See https://s.apache.org/beam-fn-api-send-and-receive-data for further details.
func (*StateKey_MultimapKeysSideInput) Descriptor ¶
func (*StateKey_MultimapKeysSideInput) Descriptor() ([]byte, []int)
func (*StateKey_MultimapKeysSideInput) GetSideInputId ¶
func (m *StateKey_MultimapKeysSideInput) GetSideInputId() string
func (*StateKey_MultimapKeysSideInput) GetTransformId ¶
func (m *StateKey_MultimapKeysSideInput) GetTransformId() string
func (*StateKey_MultimapKeysSideInput) GetWindow ¶
func (m *StateKey_MultimapKeysSideInput) GetWindow() []byte
func (*StateKey_MultimapKeysSideInput) ProtoMessage ¶
func (*StateKey_MultimapKeysSideInput) ProtoMessage()
func (*StateKey_MultimapKeysSideInput) Reset ¶
func (m *StateKey_MultimapKeysSideInput) Reset()
func (*StateKey_MultimapKeysSideInput) String ¶
func (m *StateKey_MultimapKeysSideInput) String() string
func (*StateKey_MultimapKeysSideInput) XXX_DiscardUnknown ¶
func (m *StateKey_MultimapKeysSideInput) XXX_DiscardUnknown()
func (*StateKey_MultimapKeysSideInput) XXX_Marshal ¶
func (m *StateKey_MultimapKeysSideInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StateKey_MultimapKeysSideInput) XXX_Merge ¶
func (m *StateKey_MultimapKeysSideInput) XXX_Merge(src proto.Message)
func (*StateKey_MultimapKeysSideInput) XXX_Size ¶
func (m *StateKey_MultimapKeysSideInput) XXX_Size() int
func (*StateKey_MultimapKeysSideInput) XXX_Unmarshal ¶
func (m *StateKey_MultimapKeysSideInput) XXX_Unmarshal(b []byte) error
type StateKey_MultimapKeysSideInput_ ¶
type StateKey_MultimapKeysSideInput_ struct {
MultimapKeysSideInput *StateKey_MultimapKeysSideInput `protobuf:"bytes,5,opt,name=multimap_keys_side_input,json=multimapKeysSideInput,proto3,oneof"`
}
type StateKey_MultimapSideInput ¶
type StateKey_MultimapSideInput struct { // (Required) The id of the PTransform containing a side input. TransformId string `protobuf:"bytes,1,opt,name=transform_id,json=transformId,proto3" json:"transform_id,omitempty"` // (Required) The id of the side input. SideInputId string `protobuf:"bytes,2,opt,name=side_input_id,json=sideInputId,proto3" 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:"-"` }
Represents a request for the values associated with a specified user key and window in a PCollection. See https://s.apache.org/beam-fn-state-api-and-bundle-processing for further details.
Can only be used to perform StateGetRequests on side inputs of the URN beam:side_input:multimap:v1.
For a PCollection<KV<K, V>>, the response data stream will be a concatenation of all V's associated with the specified key K. See https://s.apache.org/beam-fn-api-send-and-receive-data for further details.
func (*StateKey_MultimapSideInput) Descriptor ¶
func (*StateKey_MultimapSideInput) Descriptor() ([]byte, []int)
func (*StateKey_MultimapSideInput) GetKey ¶
func (m *StateKey_MultimapSideInput) GetKey() []byte
func (*StateKey_MultimapSideInput) GetSideInputId ¶
func (m *StateKey_MultimapSideInput) GetSideInputId() string
func (*StateKey_MultimapSideInput) GetTransformId ¶
func (m *StateKey_MultimapSideInput) GetTransformId() 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 (m *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,proto3,oneof"`
}
type StateKey_Runner ¶
type StateKey_Runner struct { // (Required) Opaque information supplied by the runner. Used to support // remote references. // https://s.apache.org/beam-fn-api-send-and-receive-data // // Used by state backed iterable. And in this use case, request type can // only be of type get. Details see: // https://s.apache.org/beam-fn-api-state-backed-iterables 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 (m *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,proto3,oneof"`
}
type StateRequest ¶
type StateRequest struct { // (Required) A 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,proto3" 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. InstructionId string `protobuf:"bytes,2,opt,name=instruction_id,json=instructionId,proto3" json:"instruction_id,omitempty"` // (Required) The state key this request is for. StateKey *StateKey `protobuf:"bytes,3,opt,name=state_key,json=stateKey,proto3" 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) GetInstructionId ¶
func (m *StateRequest) GetInstructionId() 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 (m *StateRequest) XXX_Merge(src proto.Message)
func (*StateRequest) XXX_OneofWrappers ¶
func (*StateRequest) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers 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,proto3,oneof"`
}
type StateRequest_Clear ¶
type StateRequest_Clear struct {
Clear *StateClearRequest `protobuf:"bytes,1002,opt,name=clear,proto3,oneof"`
}
type StateRequest_Get ¶
type StateRequest_Get struct {
Get *StateGetRequest `protobuf:"bytes,1000,opt,name=get,proto3,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,proto3" 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,proto3" json:"error,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) 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 (m *StateResponse) XXX_Merge(src proto.Message)
func (*StateResponse) XXX_OneofWrappers ¶
func (*StateResponse) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers 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,proto3,oneof"`
}
type StateResponse_Clear ¶
type StateResponse_Clear struct {
Clear *StateClearResponse `protobuf:"bytes,1002,opt,name=clear,proto3,oneof"`
}
type StateResponse_Get ¶
type StateResponse_Get struct {
Get *StateGetResponse `protobuf:"bytes,1000,opt,name=get,proto3,oneof"`
}
type StopWorkerRequest ¶
type StopWorkerRequest struct { WorkerId string `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StopWorkerRequest) Descriptor ¶
func (*StopWorkerRequest) Descriptor() ([]byte, []int)
func (*StopWorkerRequest) GetWorkerId ¶
func (m *StopWorkerRequest) GetWorkerId() string
func (*StopWorkerRequest) ProtoMessage ¶
func (*StopWorkerRequest) ProtoMessage()
func (*StopWorkerRequest) Reset ¶
func (m *StopWorkerRequest) Reset()
func (*StopWorkerRequest) String ¶
func (m *StopWorkerRequest) String() string
func (*StopWorkerRequest) XXX_DiscardUnknown ¶
func (m *StopWorkerRequest) XXX_DiscardUnknown()
func (*StopWorkerRequest) XXX_Marshal ¶
func (m *StopWorkerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StopWorkerRequest) XXX_Merge ¶
func (m *StopWorkerRequest) XXX_Merge(src proto.Message)
func (*StopWorkerRequest) XXX_Size ¶
func (m *StopWorkerRequest) XXX_Size() int
func (*StopWorkerRequest) XXX_Unmarshal ¶
func (m *StopWorkerRequest) XXX_Unmarshal(b []byte) error
type StopWorkerResponse ¶
type StopWorkerResponse struct { Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StopWorkerResponse) Descriptor ¶
func (*StopWorkerResponse) Descriptor() ([]byte, []int)
func (*StopWorkerResponse) GetError ¶
func (m *StopWorkerResponse) GetError() string
func (*StopWorkerResponse) ProtoMessage ¶
func (*StopWorkerResponse) ProtoMessage()
func (*StopWorkerResponse) Reset ¶
func (m *StopWorkerResponse) Reset()
func (*StopWorkerResponse) String ¶
func (m *StopWorkerResponse) String() string
func (*StopWorkerResponse) XXX_DiscardUnknown ¶
func (m *StopWorkerResponse) XXX_DiscardUnknown()
func (*StopWorkerResponse) XXX_Marshal ¶
func (m *StopWorkerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StopWorkerResponse) XXX_Merge ¶
func (m *StopWorkerResponse) XXX_Merge(src proto.Message)
func (*StopWorkerResponse) XXX_Size ¶
func (m *StopWorkerResponse) XXX_Size() int
func (*StopWorkerResponse) XXX_Unmarshal ¶
func (m *StopWorkerResponse) XXX_Unmarshal(b []byte) error
type UnimplementedBeamFnControlServer ¶
type UnimplementedBeamFnControlServer struct { }
UnimplementedBeamFnControlServer can be embedded to have forward compatible implementations.
func (*UnimplementedBeamFnControlServer) Control ¶
func (*UnimplementedBeamFnControlServer) Control(srv BeamFnControl_ControlServer) error
func (*UnimplementedBeamFnControlServer) GetProcessBundleDescriptor ¶
func (*UnimplementedBeamFnControlServer) GetProcessBundleDescriptor(ctx context.Context, req *GetProcessBundleDescriptorRequest) (*ProcessBundleDescriptor, error)
type UnimplementedBeamFnDataServer ¶
type UnimplementedBeamFnDataServer struct { }
UnimplementedBeamFnDataServer can be embedded to have forward compatible implementations.
func (*UnimplementedBeamFnDataServer) Data ¶
func (*UnimplementedBeamFnDataServer) Data(srv BeamFnData_DataServer) error
type UnimplementedBeamFnExternalWorkerPoolServer ¶
type UnimplementedBeamFnExternalWorkerPoolServer struct { }
UnimplementedBeamFnExternalWorkerPoolServer can be embedded to have forward compatible implementations.
func (*UnimplementedBeamFnExternalWorkerPoolServer) StartWorker ¶
func (*UnimplementedBeamFnExternalWorkerPoolServer) StartWorker(ctx context.Context, req *StartWorkerRequest) (*StartWorkerResponse, error)
func (*UnimplementedBeamFnExternalWorkerPoolServer) StopWorker ¶
func (*UnimplementedBeamFnExternalWorkerPoolServer) StopWorker(ctx context.Context, req *StopWorkerRequest) (*StopWorkerResponse, error)
type UnimplementedBeamFnLoggingServer ¶
type UnimplementedBeamFnLoggingServer struct { }
UnimplementedBeamFnLoggingServer can be embedded to have forward compatible implementations.
func (*UnimplementedBeamFnLoggingServer) Logging ¶
func (*UnimplementedBeamFnLoggingServer) Logging(srv BeamFnLogging_LoggingServer) error
type UnimplementedBeamFnStateServer ¶
type UnimplementedBeamFnStateServer struct { }
UnimplementedBeamFnStateServer can be embedded to have forward compatible implementations.
func (*UnimplementedBeamFnStateServer) State ¶
func (*UnimplementedBeamFnStateServer) State(srv BeamFnState_StateServer) error
type UnimplementedBeamFnWorkerStatusServer ¶
type UnimplementedBeamFnWorkerStatusServer struct { }
UnimplementedBeamFnWorkerStatusServer can be embedded to have forward compatible implementations.
func (*UnimplementedBeamFnWorkerStatusServer) WorkerStatus ¶
func (*UnimplementedBeamFnWorkerStatusServer) WorkerStatus(srv BeamFnWorkerStatus_WorkerStatusServer) error
type UnimplementedProvisionServiceServer ¶
type UnimplementedProvisionServiceServer struct { }
UnimplementedProvisionServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedProvisionServiceServer) GetProvisionInfo ¶
func (*UnimplementedProvisionServiceServer) GetProvisionInfo(ctx context.Context, req *GetProvisionInfoRequest) (*GetProvisionInfoResponse, error)
type WorkerStatusRequest ¶
type WorkerStatusRequest struct { // (Required) Unique ID identifying this request. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Request from runner to SDK Harness asking for its status. For more details see https://s.apache.org/beam-fn-api-harness-status
func (*WorkerStatusRequest) Descriptor ¶
func (*WorkerStatusRequest) Descriptor() ([]byte, []int)
func (*WorkerStatusRequest) GetId ¶
func (m *WorkerStatusRequest) GetId() string
func (*WorkerStatusRequest) ProtoMessage ¶
func (*WorkerStatusRequest) ProtoMessage()
func (*WorkerStatusRequest) Reset ¶
func (m *WorkerStatusRequest) Reset()
func (*WorkerStatusRequest) String ¶
func (m *WorkerStatusRequest) String() string
func (*WorkerStatusRequest) XXX_DiscardUnknown ¶
func (m *WorkerStatusRequest) XXX_DiscardUnknown()
func (*WorkerStatusRequest) XXX_Marshal ¶
func (m *WorkerStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WorkerStatusRequest) XXX_Merge ¶
func (m *WorkerStatusRequest) XXX_Merge(src proto.Message)
func (*WorkerStatusRequest) XXX_Size ¶
func (m *WorkerStatusRequest) XXX_Size() int
func (*WorkerStatusRequest) XXX_Unmarshal ¶
func (m *WorkerStatusRequest) XXX_Unmarshal(b []byte) error
type WorkerStatusResponse ¶
type WorkerStatusResponse struct { // (Required) Unique ID from the original request. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // (Optional) Error message if exception encountered generating the status response. Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // (Optional) Status debugging info reported by SDK harness worker. Content and // format is not strongly enforced but should be print-friendly and // appropriate as an HTTP response body for end user. For details of the preferred // info to include in the message see // https://s.apache.org/beam-fn-api-harness-status StatusInfo string `protobuf:"bytes,3,opt,name=status_info,json=statusInfo,proto3" json:"status_info,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Response from SDK Harness to runner containing the debug related status info.
func (*WorkerStatusResponse) Descriptor ¶
func (*WorkerStatusResponse) Descriptor() ([]byte, []int)
func (*WorkerStatusResponse) GetError ¶
func (m *WorkerStatusResponse) GetError() string
func (*WorkerStatusResponse) GetId ¶
func (m *WorkerStatusResponse) GetId() string
func (*WorkerStatusResponse) GetStatusInfo ¶
func (m *WorkerStatusResponse) GetStatusInfo() string
func (*WorkerStatusResponse) ProtoMessage ¶
func (*WorkerStatusResponse) ProtoMessage()
func (*WorkerStatusResponse) Reset ¶
func (m *WorkerStatusResponse) Reset()
func (*WorkerStatusResponse) String ¶
func (m *WorkerStatusResponse) String() string
func (*WorkerStatusResponse) XXX_DiscardUnknown ¶
func (m *WorkerStatusResponse) XXX_DiscardUnknown()
func (*WorkerStatusResponse) XXX_Marshal ¶
func (m *WorkerStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WorkerStatusResponse) XXX_Merge ¶
func (m *WorkerStatusResponse) XXX_Merge(src proto.Message)
func (*WorkerStatusResponse) XXX_Size ¶
func (m *WorkerStatusResponse) XXX_Size() int
func (*WorkerStatusResponse) XXX_Unmarshal ¶
func (m *WorkerStatusResponse) XXX_Unmarshal(b []byte) error