Documentation ¶
Index ¶
- Variables
- func RegisterBeamFnControlServer(s *grpc.Server, srv BeamFnControlServer)
- func RegisterBeamFnDataServer(s *grpc.Server, srv BeamFnDataServer)
- func RegisterBeamFnLoggingServer(s *grpc.Server, srv BeamFnLoggingServer)
- func RegisterBeamFnStateServer(s *grpc.Server, srv BeamFnStateServer)
- 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 BeamFnLoggingClient
- type BeamFnLoggingServer
- type BeamFnLogging_LoggingClient
- type BeamFnLogging_LoggingServer
- type BeamFnStateClient
- type BeamFnStateServer
- type BeamFnState_StateClient
- type BeamFnState_StateServer
- type BundleSplit
- func (*BundleSplit) Descriptor() ([]byte, []int)
- func (m *BundleSplit) GetPrimaryRoots() []*BundleSplit_Application
- func (m *BundleSplit) GetResidualRoots() []*BundleSplit_Application
- func (*BundleSplit) ProtoMessage()
- func (m *BundleSplit) Reset()
- func (m *BundleSplit) String() string
- func (m *BundleSplit) XXX_DiscardUnknown()
- func (m *BundleSplit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *BundleSplit) XXX_Merge(src proto.Message)
- func (m *BundleSplit) XXX_Size() int
- func (m *BundleSplit) XXX_Unmarshal(b []byte) error
- type BundleSplit_Application
- func (*BundleSplit_Application) Descriptor() ([]byte, []int)
- func (m *BundleSplit_Application) GetElement() []byte
- func (m *BundleSplit_Application) GetFractionOfWork() *wrappers.DoubleValue
- func (m *BundleSplit_Application) GetInputId() string
- func (m *BundleSplit_Application) GetOutputWatermarks() map[string]int64
- func (m *BundleSplit_Application) GetPtransformId() string
- func (*BundleSplit_Application) ProtoMessage()
- func (m *BundleSplit_Application) Reset()
- func (m *BundleSplit_Application) String() string
- func (m *BundleSplit_Application) XXX_DiscardUnknown()
- func (m *BundleSplit_Application) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *BundleSplit_Application) XXX_Merge(src proto.Message)
- func (m *BundleSplit_Application) XXX_Size() int
- func (m *BundleSplit_Application) XXX_Unmarshal(b []byte) error
- type CounterData
- func (*CounterData) Descriptor() ([]byte, []int)
- func (m *CounterData) GetDoubleValue() float64
- func (m *CounterData) GetInt64Value() int64
- func (m *CounterData) GetStringValue() string
- func (m *CounterData) GetValue() isCounterData_Value
- func (*CounterData) ProtoMessage()
- func (m *CounterData) Reset()
- func (m *CounterData) String() string
- func (m *CounterData) XXX_DiscardUnknown()
- func (m *CounterData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *CounterData) XXX_Merge(src proto.Message)
- func (*CounterData) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *CounterData) XXX_Size() int
- func (m *CounterData) XXX_Unmarshal(b []byte) error
- type CounterData_DoubleValue
- type CounterData_Int64Value
- type CounterData_StringValue
- type DistributionData
- func (*DistributionData) Descriptor() ([]byte, []int)
- func (m *DistributionData) GetDistribution() isDistributionData_Distribution
- func (m *DistributionData) GetDoubleDistributionData() *DoubleDistributionData
- func (m *DistributionData) GetIntDistributionData() *IntDistributionData
- func (*DistributionData) ProtoMessage()
- func (m *DistributionData) Reset()
- func (m *DistributionData) String() string
- func (m *DistributionData) XXX_DiscardUnknown()
- func (m *DistributionData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DistributionData) XXX_Merge(src proto.Message)
- func (*DistributionData) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *DistributionData) XXX_Size() int
- func (m *DistributionData) XXX_Unmarshal(b []byte) error
- type DistributionData_DoubleDistributionData
- type DistributionData_IntDistributionData
- type DoubleDistributionData
- func (*DoubleDistributionData) Descriptor() ([]byte, []int)
- func (m *DoubleDistributionData) GetCount() int64
- func (m *DoubleDistributionData) GetMax() float64
- func (m *DoubleDistributionData) GetMin() float64
- func (m *DoubleDistributionData) GetSum() float64
- func (*DoubleDistributionData) ProtoMessage()
- func (m *DoubleDistributionData) Reset()
- func (m *DoubleDistributionData) String() string
- func (m *DoubleDistributionData) XXX_DiscardUnknown()
- func (m *DoubleDistributionData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DoubleDistributionData) XXX_Merge(src proto.Message)
- func (m *DoubleDistributionData) XXX_Size() int
- func (m *DoubleDistributionData) XXX_Unmarshal(b []byte) error
- type DoubleExtremaData
- func (*DoubleExtremaData) Descriptor() ([]byte, []int)
- func (m *DoubleExtremaData) GetDoubleValues() []float64
- func (*DoubleExtremaData) ProtoMessage()
- func (m *DoubleExtremaData) Reset()
- func (m *DoubleExtremaData) String() string
- func (m *DoubleExtremaData) XXX_DiscardUnknown()
- func (m *DoubleExtremaData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DoubleExtremaData) XXX_Merge(src proto.Message)
- func (m *DoubleExtremaData) XXX_Size() int
- func (m *DoubleExtremaData) XXX_Unmarshal(b []byte) error
- type Elements
- func (*Elements) Descriptor() ([]byte, []int)
- func (m *Elements) GetData() []*Elements_Data
- 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 (dst *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) GetInstructionReference() string
- func (m *Elements_Data) GetTarget() *Target
- 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 (dst *Elements_Data) XXX_Merge(src proto.Message)
- func (m *Elements_Data) XXX_Size() int
- func (m *Elements_Data) XXX_Unmarshal(b []byte) error
- type ExtremaData
- func (*ExtremaData) Descriptor() ([]byte, []int)
- func (m *ExtremaData) GetDoubleExtremaData() *DoubleExtremaData
- func (m *ExtremaData) GetExtrema() isExtremaData_Extrema
- func (m *ExtremaData) GetIntExtremaData() *IntExtremaData
- func (*ExtremaData) ProtoMessage()
- func (m *ExtremaData) Reset()
- func (m *ExtremaData) String() string
- func (m *ExtremaData) XXX_DiscardUnknown()
- func (m *ExtremaData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ExtremaData) XXX_Merge(src proto.Message)
- func (*ExtremaData) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *ExtremaData) XXX_Size() int
- func (m *ExtremaData) XXX_Unmarshal(b []byte) error
- type ExtremaData_DoubleExtremaData
- type ExtremaData_IntExtremaData
- 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 (dst *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 (dst *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) GetInstructionId() string
- func (m *InstructionRequest) GetProcessBundle() *ProcessBundleRequest
- func (m *InstructionRequest) GetProcessBundleProgress() *ProcessBundleProgressRequest
- 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 (dst *InstructionRequest) XXX_Merge(src proto.Message)
- func (*InstructionRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *InstructionRequest) XXX_Size() int
- func (m *InstructionRequest) XXX_Unmarshal(b []byte) error
- type InstructionRequest_ProcessBundle
- type InstructionRequest_ProcessBundleProgress
- type InstructionRequest_ProcessBundleSplit
- type InstructionRequest_Register
- type InstructionResponse
- func (*InstructionResponse) Descriptor() ([]byte, []int)
- func (m *InstructionResponse) GetError() string
- func (m *InstructionResponse) GetInstructionId() string
- func (m *InstructionResponse) GetProcessBundle() *ProcessBundleResponse
- func (m *InstructionResponse) GetProcessBundleProgress() *ProcessBundleProgressResponse
- 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 (dst *InstructionResponse) XXX_Merge(src proto.Message)
- func (*InstructionResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *InstructionResponse) XXX_Size() int
- func (m *InstructionResponse) XXX_Unmarshal(b []byte) error
- type InstructionResponse_ProcessBundle
- type InstructionResponse_ProcessBundleProgress
- type InstructionResponse_ProcessBundleSplit
- type InstructionResponse_Register
- type IntDistributionData
- func (*IntDistributionData) Descriptor() ([]byte, []int)
- func (m *IntDistributionData) GetCount() int64
- func (m *IntDistributionData) GetMax() int64
- func (m *IntDistributionData) GetMin() int64
- func (m *IntDistributionData) GetSum() int64
- func (*IntDistributionData) ProtoMessage()
- func (m *IntDistributionData) Reset()
- func (m *IntDistributionData) String() string
- func (m *IntDistributionData) XXX_DiscardUnknown()
- func (m *IntDistributionData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *IntDistributionData) XXX_Merge(src proto.Message)
- func (m *IntDistributionData) XXX_Size() int
- func (m *IntDistributionData) XXX_Unmarshal(b []byte) error
- type IntExtremaData
- func (*IntExtremaData) Descriptor() ([]byte, []int)
- func (m *IntExtremaData) GetIntValues() []int64
- func (*IntExtremaData) ProtoMessage()
- func (m *IntExtremaData) Reset()
- func (m *IntExtremaData) String() string
- func (m *IntExtremaData) XXX_DiscardUnknown()
- func (m *IntExtremaData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *IntExtremaData) XXX_Merge(src proto.Message)
- func (m *IntExtremaData) XXX_Size() int
- func (m *IntExtremaData) XXX_Unmarshal(b []byte) error
- 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 (dst *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) GetInstructionReference() string
- func (m *LogEntry) GetLogLocation() string
- func (m *LogEntry) GetMessage() string
- func (m *LogEntry) GetPrimitiveTransformReference() 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 (*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 (dst *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 (dst *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 (dst *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 Metric
- func (*Metric) Descriptor() ([]byte, []int)
- func (m *Metric) GetCounterData() *CounterData
- func (m *Metric) GetData() isMetric_Data
- func (m *Metric) GetDistributionData() *DistributionData
- func (m *Metric) GetExtremaData() *ExtremaData
- func (*Metric) ProtoMessage()
- func (m *Metric) Reset()
- func (m *Metric) String() string
- func (m *Metric) XXX_DiscardUnknown()
- func (m *Metric) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Metric) XXX_Merge(src proto.Message)
- func (*Metric) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *Metric) XXX_Size() int
- func (m *Metric) XXX_Unmarshal(b []byte) error
- type Metric_CounterData
- type Metric_DistributionData
- type Metric_ExtremaData
- type Metrics
- func (*Metrics) Descriptor() ([]byte, []int)
- func (m *Metrics) GetPtransforms() map[string]*Metrics_PTransform
- func (*Metrics) ProtoMessage()
- func (m *Metrics) Reset()
- func (m *Metrics) String() string
- func (m *Metrics) XXX_DiscardUnknown()
- func (m *Metrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Metrics) XXX_Merge(src proto.Message)
- func (m *Metrics) XXX_Size() int
- func (m *Metrics) XXX_Unmarshal(b []byte) error
- type Metrics_PTransform
- func (*Metrics_PTransform) Descriptor() ([]byte, []int)
- func (m *Metrics_PTransform) GetActiveElements() *Metrics_PTransform_ActiveElements
- func (m *Metrics_PTransform) GetProcessedElements() *Metrics_PTransform_ProcessedElements
- func (m *Metrics_PTransform) GetUser() []*Metrics_User
- func (m *Metrics_PTransform) GetWatermarks() map[string]int64
- func (*Metrics_PTransform) ProtoMessage()
- func (m *Metrics_PTransform) Reset()
- func (m *Metrics_PTransform) String() string
- func (m *Metrics_PTransform) XXX_DiscardUnknown()
- func (m *Metrics_PTransform) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Metrics_PTransform) XXX_Merge(src proto.Message)
- func (m *Metrics_PTransform) XXX_Size() int
- func (m *Metrics_PTransform) XXX_Unmarshal(b []byte) error
- type Metrics_PTransform_ActiveElements
- func (*Metrics_PTransform_ActiveElements) Descriptor() ([]byte, []int)
- func (m *Metrics_PTransform_ActiveElements) GetFractionRemaining() float64
- func (m *Metrics_PTransform_ActiveElements) GetMeasured() *Metrics_PTransform_Measured
- func (m *Metrics_PTransform_ActiveElements) GetOutputElementsRemaining() map[string]int64
- func (*Metrics_PTransform_ActiveElements) ProtoMessage()
- func (m *Metrics_PTransform_ActiveElements) Reset()
- func (m *Metrics_PTransform_ActiveElements) String() string
- func (m *Metrics_PTransform_ActiveElements) XXX_DiscardUnknown()
- func (m *Metrics_PTransform_ActiveElements) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Metrics_PTransform_ActiveElements) XXX_Merge(src proto.Message)
- func (m *Metrics_PTransform_ActiveElements) XXX_Size() int
- func (m *Metrics_PTransform_ActiveElements) XXX_Unmarshal(b []byte) error
- type Metrics_PTransform_Measured
- func (*Metrics_PTransform_Measured) Descriptor() ([]byte, []int)
- func (m *Metrics_PTransform_Measured) GetInputElementCounts() map[string]int64
- func (m *Metrics_PTransform_Measured) GetOutputElementCounts() map[string]int64
- func (m *Metrics_PTransform_Measured) GetTotalTimeSpent() float64
- func (*Metrics_PTransform_Measured) ProtoMessage()
- func (m *Metrics_PTransform_Measured) Reset()
- func (m *Metrics_PTransform_Measured) String() string
- func (m *Metrics_PTransform_Measured) XXX_DiscardUnknown()
- func (m *Metrics_PTransform_Measured) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Metrics_PTransform_Measured) XXX_Merge(src proto.Message)
- func (m *Metrics_PTransform_Measured) XXX_Size() int
- func (m *Metrics_PTransform_Measured) XXX_Unmarshal(b []byte) error
- type Metrics_PTransform_ProcessedElements
- func (*Metrics_PTransform_ProcessedElements) Descriptor() ([]byte, []int)
- func (m *Metrics_PTransform_ProcessedElements) GetMeasured() *Metrics_PTransform_Measured
- func (*Metrics_PTransform_ProcessedElements) ProtoMessage()
- func (m *Metrics_PTransform_ProcessedElements) Reset()
- func (m *Metrics_PTransform_ProcessedElements) String() string
- func (m *Metrics_PTransform_ProcessedElements) XXX_DiscardUnknown()
- func (m *Metrics_PTransform_ProcessedElements) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Metrics_PTransform_ProcessedElements) XXX_Merge(src proto.Message)
- func (m *Metrics_PTransform_ProcessedElements) XXX_Size() int
- func (m *Metrics_PTransform_ProcessedElements) XXX_Unmarshal(b []byte) error
- type Metrics_User
- func (*Metrics_User) Descriptor() ([]byte, []int)
- func (m *Metrics_User) GetCounterData() *Metrics_User_CounterData
- func (m *Metrics_User) GetData() isMetrics_User_Data
- func (m *Metrics_User) GetDistributionData() *Metrics_User_DistributionData
- func (m *Metrics_User) GetGaugeData() *Metrics_User_GaugeData
- func (m *Metrics_User) GetMetricName() *Metrics_User_MetricName
- func (*Metrics_User) ProtoMessage()
- func (m *Metrics_User) Reset()
- func (m *Metrics_User) String() string
- func (m *Metrics_User) XXX_DiscardUnknown()
- func (m *Metrics_User) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Metrics_User) XXX_Merge(src proto.Message)
- func (*Metrics_User) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *Metrics_User) XXX_Size() int
- func (m *Metrics_User) XXX_Unmarshal(b []byte) error
- type Metrics_User_CounterData
- func (*Metrics_User_CounterData) Descriptor() ([]byte, []int)
- func (m *Metrics_User_CounterData) GetValue() int64
- func (*Metrics_User_CounterData) ProtoMessage()
- func (m *Metrics_User_CounterData) Reset()
- func (m *Metrics_User_CounterData) String() string
- func (m *Metrics_User_CounterData) XXX_DiscardUnknown()
- func (m *Metrics_User_CounterData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Metrics_User_CounterData) XXX_Merge(src proto.Message)
- func (m *Metrics_User_CounterData) XXX_Size() int
- func (m *Metrics_User_CounterData) XXX_Unmarshal(b []byte) error
- type Metrics_User_CounterData_
- type Metrics_User_DistributionData
- func (*Metrics_User_DistributionData) Descriptor() ([]byte, []int)
- func (m *Metrics_User_DistributionData) GetCount() int64
- func (m *Metrics_User_DistributionData) GetMax() int64
- func (m *Metrics_User_DistributionData) GetMin() int64
- func (m *Metrics_User_DistributionData) GetSum() int64
- func (*Metrics_User_DistributionData) ProtoMessage()
- func (m *Metrics_User_DistributionData) Reset()
- func (m *Metrics_User_DistributionData) String() string
- func (m *Metrics_User_DistributionData) XXX_DiscardUnknown()
- func (m *Metrics_User_DistributionData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Metrics_User_DistributionData) XXX_Merge(src proto.Message)
- func (m *Metrics_User_DistributionData) XXX_Size() int
- func (m *Metrics_User_DistributionData) XXX_Unmarshal(b []byte) error
- type Metrics_User_DistributionData_
- type Metrics_User_GaugeData
- func (*Metrics_User_GaugeData) Descriptor() ([]byte, []int)
- func (m *Metrics_User_GaugeData) GetTimestamp() *timestamp.Timestamp
- func (m *Metrics_User_GaugeData) GetValue() int64
- func (*Metrics_User_GaugeData) ProtoMessage()
- func (m *Metrics_User_GaugeData) Reset()
- func (m *Metrics_User_GaugeData) String() string
- func (m *Metrics_User_GaugeData) XXX_DiscardUnknown()
- func (m *Metrics_User_GaugeData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Metrics_User_GaugeData) XXX_Merge(src proto.Message)
- func (m *Metrics_User_GaugeData) XXX_Size() int
- func (m *Metrics_User_GaugeData) XXX_Unmarshal(b []byte) error
- type Metrics_User_GaugeData_
- type Metrics_User_MetricName
- func (*Metrics_User_MetricName) Descriptor() ([]byte, []int)
- func (m *Metrics_User_MetricName) GetName() string
- func (m *Metrics_User_MetricName) GetNamespace() string
- func (*Metrics_User_MetricName) ProtoMessage()
- func (m *Metrics_User_MetricName) Reset()
- func (m *Metrics_User_MetricName) String() string
- func (m *Metrics_User_MetricName) XXX_DiscardUnknown()
- func (m *Metrics_User_MetricName) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Metrics_User_MetricName) XXX_Merge(src proto.Message)
- func (m *Metrics_User_MetricName) XXX_Size() int
- func (m *Metrics_User_MetricName) XXX_Unmarshal(b []byte) error
- type MonitoringInfo
- func (*MonitoringInfo) Descriptor() ([]byte, []int)
- func (m *MonitoringInfo) GetData() isMonitoringInfo_Data
- func (m *MonitoringInfo) GetLabels() map[string]string
- func (m *MonitoringInfo) GetMetric() *Metric
- func (m *MonitoringInfo) GetMonitoringTableData() *MonitoringTableData
- func (m *MonitoringInfo) GetType() string
- func (m *MonitoringInfo) GetUrn() string
- func (*MonitoringInfo) ProtoMessage()
- func (m *MonitoringInfo) Reset()
- func (m *MonitoringInfo) String() string
- func (m *MonitoringInfo) XXX_DiscardUnknown()
- func (m *MonitoringInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *MonitoringInfo) XXX_Merge(src proto.Message)
- func (*MonitoringInfo) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *MonitoringInfo) XXX_Size() int
- func (m *MonitoringInfo) XXX_Unmarshal(b []byte) error
- type MonitoringInfo_Metric
- type MonitoringInfo_MonitoringInfoLabels
- type MonitoringInfo_MonitoringTableData
- type MonitoringTableData
- func (*MonitoringTableData) Descriptor() ([]byte, []int)
- func (m *MonitoringTableData) GetColumnNames() []string
- func (m *MonitoringTableData) GetRowData() []*MonitoringTableData_MonitoringRow
- func (*MonitoringTableData) ProtoMessage()
- func (m *MonitoringTableData) Reset()
- func (m *MonitoringTableData) String() string
- func (m *MonitoringTableData) XXX_DiscardUnknown()
- func (m *MonitoringTableData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *MonitoringTableData) XXX_Merge(src proto.Message)
- func (m *MonitoringTableData) XXX_Size() int
- func (m *MonitoringTableData) XXX_Unmarshal(b []byte) error
- type MonitoringTableData_MonitoringColumnValue
- func (*MonitoringTableData_MonitoringColumnValue) Descriptor() ([]byte, []int)
- func (m *MonitoringTableData_MonitoringColumnValue) GetDoubleValue() float64
- func (m *MonitoringTableData_MonitoringColumnValue) GetInt64Value() int64
- func (m *MonitoringTableData_MonitoringColumnValue) GetStringValue() string
- func (m *MonitoringTableData_MonitoringColumnValue) GetTimestamp() *timestamp.Timestamp
- func (m *MonitoringTableData_MonitoringColumnValue) GetValue() isMonitoringTableData_MonitoringColumnValue_Value
- func (*MonitoringTableData_MonitoringColumnValue) ProtoMessage()
- func (m *MonitoringTableData_MonitoringColumnValue) Reset()
- func (m *MonitoringTableData_MonitoringColumnValue) String() string
- func (m *MonitoringTableData_MonitoringColumnValue) XXX_DiscardUnknown()
- func (m *MonitoringTableData_MonitoringColumnValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *MonitoringTableData_MonitoringColumnValue) XXX_Merge(src proto.Message)
- func (*MonitoringTableData_MonitoringColumnValue) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *MonitoringTableData_MonitoringColumnValue) XXX_Size() int
- func (m *MonitoringTableData_MonitoringColumnValue) XXX_Unmarshal(b []byte) error
- type MonitoringTableData_MonitoringColumnValue_DoubleValue
- type MonitoringTableData_MonitoringColumnValue_Int64Value
- type MonitoringTableData_MonitoringColumnValue_StringValue
- type MonitoringTableData_MonitoringColumnValue_Timestamp
- type MonitoringTableData_MonitoringRow
- func (*MonitoringTableData_MonitoringRow) Descriptor() ([]byte, []int)
- func (m *MonitoringTableData_MonitoringRow) GetValues() []*MonitoringTableData_MonitoringColumnValue
- func (*MonitoringTableData_MonitoringRow) ProtoMessage()
- func (m *MonitoringTableData_MonitoringRow) Reset()
- func (m *MonitoringTableData_MonitoringRow) String() string
- func (m *MonitoringTableData_MonitoringRow) XXX_DiscardUnknown()
- func (m *MonitoringTableData_MonitoringRow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *MonitoringTableData_MonitoringRow) XXX_Merge(src proto.Message)
- func (m *MonitoringTableData_MonitoringRow) XXX_Size() int
- func (m *MonitoringTableData_MonitoringRow) XXX_Unmarshal(b []byte) error
- 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) 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 (dst *ProcessBundleDescriptor) XXX_Merge(src proto.Message)
- func (m *ProcessBundleDescriptor) XXX_Size() int
- func (m *ProcessBundleDescriptor) XXX_Unmarshal(b []byte) error
- type ProcessBundleProgressRequest
- func (*ProcessBundleProgressRequest) Descriptor() ([]byte, []int)
- func (m *ProcessBundleProgressRequest) GetInstructionReference() 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 (dst *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) GetMetrics() *Metrics
- func (m *ProcessBundleProgressResponse) GetSplit() *BundleSplit
- 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 (dst *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() [][]byte
- func (m *ProcessBundleRequest) GetProcessBundleDescriptorReference() 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 (dst *ProcessBundleRequest) XXX_Merge(src proto.Message)
- func (m *ProcessBundleRequest) XXX_Size() int
- func (m *ProcessBundleRequest) XXX_Unmarshal(b []byte) error
- type ProcessBundleResponse
- func (*ProcessBundleResponse) Descriptor() ([]byte, []int)
- func (m *ProcessBundleResponse) GetMetrics() *Metrics
- func (m *ProcessBundleResponse) GetSplit() *BundleSplit
- 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 (dst *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) GetFractionOfRemainder() *wrappers.DoubleValue
- func (m *ProcessBundleSplitRequest) GetInstructionReference() 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 (dst *ProcessBundleSplitRequest) XXX_Merge(src proto.Message)
- func (m *ProcessBundleSplitRequest) XXX_Size() int
- func (m *ProcessBundleSplitRequest) XXX_Unmarshal(b []byte) error
- type ProcessBundleSplitResponse
- func (*ProcessBundleSplitResponse) Descriptor() ([]byte, []int)
- 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 (dst *ProcessBundleSplitResponse) XXX_Merge(src proto.Message)
- func (m *ProcessBundleSplitResponse) XXX_Size() int
- func (m *ProcessBundleSplitResponse) XXX_Unmarshal(b []byte) error
- type ProvisionInfo
- func (*ProvisionInfo) Descriptor() ([]byte, []int)
- func (m *ProvisionInfo) GetJobId() string
- func (m *ProvisionInfo) GetJobName() string
- func (m *ProvisionInfo) GetPipelineOptions() *_struct.Struct
- func (m *ProvisionInfo) GetResourceLimits() *Resources
- func (m *ProvisionInfo) GetRetrievalToken() string
- func (m *ProvisionInfo) GetWorkerId() string
- 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 (dst *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 (dst *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 (dst *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 (dst *RemoteGrpcPort) XXX_Merge(src proto.Message)
- func (m *RemoteGrpcPort) XXX_Size() int
- func (m *RemoteGrpcPort) XXX_Unmarshal(b []byte) error
- type Resources
- func (*Resources) Descriptor() ([]byte, []int)
- func (m *Resources) GetCpu() *Resources_Cpu
- func (m *Resources) GetMemory() *Resources_Memory
- func (m *Resources) GetSemiPersistentDisk() *Resources_Disk
- func (*Resources) ProtoMessage()
- func (m *Resources) Reset()
- func (m *Resources) String() string
- func (m *Resources) XXX_DiscardUnknown()
- func (m *Resources) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Resources) XXX_Merge(src proto.Message)
- func (m *Resources) XXX_Size() int
- func (m *Resources) XXX_Unmarshal(b []byte) error
- type Resources_Cpu
- func (*Resources_Cpu) Descriptor() ([]byte, []int)
- func (m *Resources_Cpu) GetShares() float32
- func (*Resources_Cpu) ProtoMessage()
- func (m *Resources_Cpu) Reset()
- func (m *Resources_Cpu) String() string
- func (m *Resources_Cpu) XXX_DiscardUnknown()
- func (m *Resources_Cpu) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Resources_Cpu) XXX_Merge(src proto.Message)
- func (m *Resources_Cpu) XXX_Size() int
- func (m *Resources_Cpu) XXX_Unmarshal(b []byte) error
- type Resources_Disk
- func (*Resources_Disk) Descriptor() ([]byte, []int)
- func (m *Resources_Disk) GetSize() uint64
- func (*Resources_Disk) ProtoMessage()
- func (m *Resources_Disk) Reset()
- func (m *Resources_Disk) String() string
- func (m *Resources_Disk) XXX_DiscardUnknown()
- func (m *Resources_Disk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Resources_Disk) XXX_Merge(src proto.Message)
- func (m *Resources_Disk) XXX_Size() int
- func (m *Resources_Disk) XXX_Unmarshal(b []byte) error
- type Resources_Memory
- func (*Resources_Memory) Descriptor() ([]byte, []int)
- func (m *Resources_Memory) GetSize() uint64
- func (*Resources_Memory) ProtoMessage()
- func (m *Resources_Memory) Reset()
- func (m *Resources_Memory) String() string
- func (m *Resources_Memory) XXX_DiscardUnknown()
- func (m *Resources_Memory) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Resources_Memory) XXX_Merge(src proto.Message)
- func (m *Resources_Memory) XXX_Size() int
- func (m *Resources_Memory) 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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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) 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 (dst *StateKey) XXX_Merge(src proto.Message)
- func (*StateKey) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- 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) GetPtransformId() 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 (dst *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_MultimapSideInput
- func (*StateKey_MultimapSideInput) Descriptor() ([]byte, []int)
- func (m *StateKey_MultimapSideInput) GetKey() []byte
- func (m *StateKey_MultimapSideInput) GetPtransformId() string
- func (m *StateKey_MultimapSideInput) GetSideInputId() 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 (dst *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 (dst *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) GetInstructionReference() 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 (dst *StateRequest) XXX_Merge(src proto.Message)
- func (*StateRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- 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) GetCacheToken() []byte
- 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 (dst *StateResponse) XXX_Merge(src proto.Message)
- func (*StateResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *StateResponse) XXX_Size() int
- func (m *StateResponse) XXX_Unmarshal(b []byte) error
- type StateResponse_Append
- type StateResponse_Clear
- type StateResponse_Get
- type Target
- func (*Target) Descriptor() ([]byte, []int)
- func (m *Target) GetName() string
- func (m *Target) GetPrimitiveTransformReference() string
- func (*Target) ProtoMessage()
- func (m *Target) Reset()
- func (m *Target) String() string
- func (m *Target) XXX_DiscardUnknown()
- func (m *Target) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Target) XXX_Merge(src proto.Message)
- func (m *Target) XXX_Size() int
- func (m *Target) XXX_Unmarshal(b []byte) error
- type Target_List
- func (*Target_List) Descriptor() ([]byte, []int)
- func (m *Target_List) GetTarget() []*Target
- func (*Target_List) ProtoMessage()
- func (m *Target_List) Reset()
- func (m *Target_List) String() string
- func (m *Target_List) XXX_DiscardUnknown()
- func (m *Target_List) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Target_List) XXX_Merge(src proto.Message)
- func (m *Target_List) XXX_Size() int
- func (m *Target_List) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var LogEntry_Severity_Enum_name = map[int32]string{
0: "UNSPECIFIED",
1: "TRACE",
2: "DEBUG",
3: "INFO",
4: "NOTICE",
5: "WARN",
6: "ERROR",
7: "CRITICAL",
}
var LogEntry_Severity_Enum_value = map[string]int32{
"UNSPECIFIED": 0,
"TRACE": 1,
"DEBUG": 2,
"INFO": 3,
"NOTICE": 4,
"WARN": 5,
"ERROR": 6,
"CRITICAL": 7,
}
var MonitoringInfo_MonitoringInfoLabels_name = map[int32]string{
0: "TRANSFORM",
1: "PCOLLECTION",
2: "WINDOWING_STRATEGY",
3: "CODER",
4: "ENVIRONMENT",
}
var MonitoringInfo_MonitoringInfoLabels_value = map[string]int32{
"TRANSFORM": 0,
"PCOLLECTION": 1,
"WINDOWING_STRATEGY": 2,
"CODER": 3,
"ENVIRONMENT": 4,
}
Functions ¶
func RegisterBeamFnControlServer ¶
func RegisterBeamFnControlServer(s *grpc.Server, srv BeamFnControlServer)
func RegisterBeamFnDataServer ¶
func RegisterBeamFnDataServer(s *grpc.Server, srv BeamFnDataServer)
func RegisterBeamFnLoggingServer ¶
func RegisterBeamFnLoggingServer(s *grpc.Server, srv BeamFnLoggingServer)
func RegisterBeamFnStateServer ¶
func RegisterBeamFnStateServer(s *grpc.Server, srv BeamFnStateServer)
func RegisterProvisionServiceServer ¶
func RegisterProvisionServiceServer(s *grpc.Server, srv ProvisionServiceServer)
Types ¶
type BeamFnControlClient ¶
type BeamFnControlClient interface { // Instructions sent by the runner to the SDK requesting different types // of work. Control(ctx context.Context, opts ...grpc.CallOption) (BeamFnControl_ControlClient, error) }
BeamFnControlClient is the client API for BeamFnControl service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewBeamFnControlClient ¶
func NewBeamFnControlClient(cc *grpc.ClientConn) BeamFnControlClient
type BeamFnControlServer ¶
type BeamFnControlServer interface { // Instructions sent by the runner to the SDK requesting different types // of work. Control(BeamFnControl_ControlServer) error }
BeamFnControlServer is the server API for BeamFnControl service.
type BeamFnControl_ControlClient ¶
type BeamFnControl_ControlClient interface { Send(*InstructionResponse) error Recv() (*InstructionRequest, error) grpc.ClientStream }
type BeamFnControl_ControlServer ¶
type BeamFnControl_ControlServer interface { Send(*InstructionRequest) error Recv() (*InstructionResponse, error) grpc.ServerStream }
type BeamFnDataClient ¶
type BeamFnDataClient interface { // Used to send data between harnesses. Data(ctx context.Context, opts ...grpc.CallOption) (BeamFnData_DataClient, error) }
BeamFnDataClient is the client API for BeamFnData service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewBeamFnDataClient ¶
func NewBeamFnDataClient(cc *grpc.ClientConn) BeamFnDataClient
type BeamFnDataServer ¶
type BeamFnDataServer interface { // Used to send data between harnesses. Data(BeamFnData_DataServer) error }
BeamFnDataServer is the server API for BeamFnData service.
type BeamFnData_DataClient ¶
type BeamFnData_DataServer ¶
type BeamFnLoggingClient ¶
type BeamFnLoggingClient interface { // Allows for the SDK to emit log entries which the runner can // associate with the active job. Logging(ctx context.Context, opts ...grpc.CallOption) (BeamFnLogging_LoggingClient, error) }
BeamFnLoggingClient is the client API for BeamFnLogging service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewBeamFnLoggingClient ¶
func NewBeamFnLoggingClient(cc *grpc.ClientConn) BeamFnLoggingClient
type BeamFnLoggingServer ¶
type BeamFnLoggingServer interface { // Allows for the SDK to emit log entries which the runner can // associate with the active job. Logging(BeamFnLogging_LoggingServer) error }
BeamFnLoggingServer is the server API for BeamFnLogging service.
type BeamFnLogging_LoggingClient ¶
type BeamFnLogging_LoggingClient interface { Send(*LogEntry_List) error Recv() (*LogControl, error) grpc.ClientStream }
type BeamFnLogging_LoggingServer ¶
type BeamFnLogging_LoggingServer interface { Send(*LogControl) error Recv() (*LogEntry_List, error) grpc.ServerStream }
type BeamFnStateClient ¶
type BeamFnStateClient interface { // Used to get/append/clear state stored by the runner on behalf of the SDK. State(ctx context.Context, opts ...grpc.CallOption) (BeamFnState_StateClient, error) }
BeamFnStateClient is the client API for BeamFnState service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewBeamFnStateClient ¶
func NewBeamFnStateClient(cc *grpc.ClientConn) BeamFnStateClient
type BeamFnStateServer ¶
type BeamFnStateServer interface { // Used to get/append/clear state stored by the runner on behalf of the SDK. State(BeamFnState_StateServer) error }
BeamFnStateServer is the server API for BeamFnState service.
type BeamFnState_StateClient ¶
type BeamFnState_StateClient interface { Send(*StateRequest) error Recv() (*StateResponse, error) grpc.ClientStream }
type BeamFnState_StateServer ¶
type BeamFnState_StateServer interface { Send(*StateResponse) error Recv() (*StateRequest, error) grpc.ServerStream }
type BundleSplit ¶
type BundleSplit struct { // Root applications that should replace the current bundle. PrimaryRoots []*BundleSplit_Application `protobuf:"bytes,1,rep,name=primary_roots,json=primaryRoots,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 []*BundleSplit_Application `protobuf:"bytes,2,rep,name=residual_roots,json=residualRoots,proto3" json:"residual_roots,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Represents a partition of the bundle into two bundles: a "primary" and a "residual", with the following properties:
- The work in primary and residual doesn't overlap, and combined, adds up to the work in the current bundle if the split hadn't happened.
- The current bundle, if it keeps executing, will have done none of the work under residual roots.
- The current bundle, if no further splits happen, will have done exactly the work under primary_roots.
For more rigorous definitions see https://s.apache.org/beam-breaking-fusion
func (*BundleSplit) Descriptor ¶
func (*BundleSplit) Descriptor() ([]byte, []int)
func (*BundleSplit) GetPrimaryRoots ¶
func (m *BundleSplit) GetPrimaryRoots() []*BundleSplit_Application
func (*BundleSplit) GetResidualRoots ¶
func (m *BundleSplit) GetResidualRoots() []*BundleSplit_Application
func (*BundleSplit) ProtoMessage ¶
func (*BundleSplit) ProtoMessage()
func (*BundleSplit) Reset ¶
func (m *BundleSplit) Reset()
func (*BundleSplit) String ¶
func (m *BundleSplit) String() string
func (*BundleSplit) XXX_DiscardUnknown ¶
func (m *BundleSplit) XXX_DiscardUnknown()
func (*BundleSplit) XXX_Marshal ¶
func (m *BundleSplit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BundleSplit) XXX_Merge ¶
func (dst *BundleSplit) XXX_Merge(src proto.Message)
func (*BundleSplit) XXX_Size ¶
func (m *BundleSplit) XXX_Size() int
func (*BundleSplit) XXX_Unmarshal ¶
func (m *BundleSplit) XXX_Unmarshal(b []byte) error
type BundleSplit_Application ¶
type BundleSplit_Application struct { // (Required) The primitive transform to which to pass the element PtransformId string `protobuf:"bytes,1,opt,name=ptransform_id,json=ptransformId,proto3" json:"ptransform_id,omitempty"` // (Required) Name of the transform's input to which to pass the element. InputId string `protobuf:"bytes,2,opt,name=input_id,json=inputId,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"` // Approximate lower bounds on timestamps of elements that this PTransform // will produce into each of its output PCollections, when invoked on this // element. Keyed by the transform's local output name. OutputWatermarks map[string]int64 `` /* 198-byte string literal not displayed */ // Approximate fraction of all work of the current bundle (before split) // represented by invoking this Application and its downstream applications. // The sum of fraction_of_work between all primary_roots and residual_roots // must add up to approximately 1.0. FractionOfWork *wrappers.DoubleValue `protobuf:"bytes,5,opt,name=fraction_of_work,json=fractionOfWork,proto3" json:"fraction_of_work,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
One of the root applications specifying the scope of work for a bundle.
func (*BundleSplit_Application) Descriptor ¶
func (*BundleSplit_Application) Descriptor() ([]byte, []int)
func (*BundleSplit_Application) GetElement ¶
func (m *BundleSplit_Application) GetElement() []byte
func (*BundleSplit_Application) GetFractionOfWork ¶
func (m *BundleSplit_Application) GetFractionOfWork() *wrappers.DoubleValue
func (*BundleSplit_Application) GetInputId ¶
func (m *BundleSplit_Application) GetInputId() string
func (*BundleSplit_Application) GetOutputWatermarks ¶
func (m *BundleSplit_Application) GetOutputWatermarks() map[string]int64
func (*BundleSplit_Application) GetPtransformId ¶
func (m *BundleSplit_Application) GetPtransformId() string
func (*BundleSplit_Application) ProtoMessage ¶
func (*BundleSplit_Application) ProtoMessage()
func (*BundleSplit_Application) Reset ¶
func (m *BundleSplit_Application) Reset()
func (*BundleSplit_Application) String ¶
func (m *BundleSplit_Application) String() string
func (*BundleSplit_Application) XXX_DiscardUnknown ¶
func (m *BundleSplit_Application) XXX_DiscardUnknown()
func (*BundleSplit_Application) XXX_Marshal ¶
func (m *BundleSplit_Application) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BundleSplit_Application) XXX_Merge ¶
func (dst *BundleSplit_Application) XXX_Merge(src proto.Message)
func (*BundleSplit_Application) XXX_Size ¶
func (m *BundleSplit_Application) XXX_Size() int
func (*BundleSplit_Application) XXX_Unmarshal ¶
func (m *BundleSplit_Application) XXX_Unmarshal(b []byte) error
type CounterData ¶
type CounterData struct { // Types that are valid to be assigned to Value: // *CounterData_Int64Value // *CounterData_DoubleValue // *CounterData_StringValue Value isCounterData_Value `protobuf_oneof:"value"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Data associated with a Counter or Gauge metric. This is designed to be compatible with metric collection systems such as DropWizard.
func (*CounterData) Descriptor ¶
func (*CounterData) Descriptor() ([]byte, []int)
func (*CounterData) GetDoubleValue ¶
func (m *CounterData) GetDoubleValue() float64
func (*CounterData) GetInt64Value ¶
func (m *CounterData) GetInt64Value() int64
func (*CounterData) GetStringValue ¶
func (m *CounterData) GetStringValue() string
func (*CounterData) GetValue ¶
func (m *CounterData) GetValue() isCounterData_Value
func (*CounterData) ProtoMessage ¶
func (*CounterData) ProtoMessage()
func (*CounterData) Reset ¶
func (m *CounterData) Reset()
func (*CounterData) String ¶
func (m *CounterData) String() string
func (*CounterData) XXX_DiscardUnknown ¶
func (m *CounterData) XXX_DiscardUnknown()
func (*CounterData) XXX_Marshal ¶
func (m *CounterData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CounterData) XXX_Merge ¶
func (dst *CounterData) XXX_Merge(src proto.Message)
func (*CounterData) XXX_OneofFuncs ¶
func (*CounterData) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*CounterData) XXX_Size ¶
func (m *CounterData) XXX_Size() int
func (*CounterData) XXX_Unmarshal ¶
func (m *CounterData) XXX_Unmarshal(b []byte) error
type CounterData_DoubleValue ¶
type CounterData_DoubleValue struct {
DoubleValue float64 `protobuf:"fixed64,2,opt,name=double_value,json=doubleValue,proto3,oneof"`
}
type CounterData_Int64Value ¶
type CounterData_Int64Value struct {
Int64Value int64 `protobuf:"varint,1,opt,name=int64_value,json=int64Value,proto3,oneof"`
}
type CounterData_StringValue ¶
type CounterData_StringValue struct {
StringValue string `protobuf:"bytes,3,opt,name=string_value,json=stringValue,proto3,oneof"`
}
type DistributionData ¶
type DistributionData struct { // Types that are valid to be assigned to Distribution: // *DistributionData_IntDistributionData // *DistributionData_DoubleDistributionData Distribution isDistributionData_Distribution `protobuf_oneof:"distribution"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Data associated with a distribution metric. This is based off of the current DistributionData metric. This is not a stackdriver or dropwizard compatible style of distribution metric.
func (*DistributionData) Descriptor ¶
func (*DistributionData) Descriptor() ([]byte, []int)
func (*DistributionData) GetDistribution ¶
func (m *DistributionData) GetDistribution() isDistributionData_Distribution
func (*DistributionData) GetDoubleDistributionData ¶
func (m *DistributionData) GetDoubleDistributionData() *DoubleDistributionData
func (*DistributionData) GetIntDistributionData ¶
func (m *DistributionData) GetIntDistributionData() *IntDistributionData
func (*DistributionData) ProtoMessage ¶
func (*DistributionData) ProtoMessage()
func (*DistributionData) Reset ¶
func (m *DistributionData) Reset()
func (*DistributionData) String ¶
func (m *DistributionData) String() string
func (*DistributionData) XXX_DiscardUnknown ¶
func (m *DistributionData) XXX_DiscardUnknown()
func (*DistributionData) XXX_Marshal ¶
func (m *DistributionData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DistributionData) XXX_Merge ¶
func (dst *DistributionData) XXX_Merge(src proto.Message)
func (*DistributionData) XXX_OneofFuncs ¶
func (*DistributionData) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*DistributionData) XXX_Size ¶
func (m *DistributionData) XXX_Size() int
func (*DistributionData) XXX_Unmarshal ¶
func (m *DistributionData) XXX_Unmarshal(b []byte) error
type DistributionData_DoubleDistributionData ¶
type DistributionData_DoubleDistributionData struct {
DoubleDistributionData *DoubleDistributionData `protobuf:"bytes,2,opt,name=double_distribution_data,json=doubleDistributionData,proto3,oneof"`
}
type DistributionData_IntDistributionData ¶
type DistributionData_IntDistributionData struct {
IntDistributionData *IntDistributionData `protobuf:"bytes,1,opt,name=int_distribution_data,json=intDistributionData,proto3,oneof"`
}
type DoubleDistributionData ¶
type DoubleDistributionData struct { Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"` Sum float64 `protobuf:"fixed64,2,opt,name=sum,proto3" json:"sum,omitempty"` Min float64 `protobuf:"fixed64,3,opt,name=min,proto3" json:"min,omitempty"` Max float64 `protobuf:"fixed64,4,opt,name=max,proto3" json:"max,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DoubleDistributionData) Descriptor ¶
func (*DoubleDistributionData) Descriptor() ([]byte, []int)
func (*DoubleDistributionData) GetCount ¶
func (m *DoubleDistributionData) GetCount() int64
func (*DoubleDistributionData) GetMax ¶
func (m *DoubleDistributionData) GetMax() float64
func (*DoubleDistributionData) GetMin ¶
func (m *DoubleDistributionData) GetMin() float64
func (*DoubleDistributionData) GetSum ¶
func (m *DoubleDistributionData) GetSum() float64
func (*DoubleDistributionData) ProtoMessage ¶
func (*DoubleDistributionData) ProtoMessage()
func (*DoubleDistributionData) Reset ¶
func (m *DoubleDistributionData) Reset()
func (*DoubleDistributionData) String ¶
func (m *DoubleDistributionData) String() string
func (*DoubleDistributionData) XXX_DiscardUnknown ¶
func (m *DoubleDistributionData) XXX_DiscardUnknown()
func (*DoubleDistributionData) XXX_Marshal ¶
func (m *DoubleDistributionData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DoubleDistributionData) XXX_Merge ¶
func (dst *DoubleDistributionData) XXX_Merge(src proto.Message)
func (*DoubleDistributionData) XXX_Size ¶
func (m *DoubleDistributionData) XXX_Size() int
func (*DoubleDistributionData) XXX_Unmarshal ¶
func (m *DoubleDistributionData) XXX_Unmarshal(b []byte) error
type DoubleExtremaData ¶
type DoubleExtremaData struct { DoubleValues []float64 `protobuf:"fixed64,2,rep,packed,name=double_values,json=doubleValues,proto3" json:"double_values,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DoubleExtremaData) Descriptor ¶
func (*DoubleExtremaData) Descriptor() ([]byte, []int)
func (*DoubleExtremaData) GetDoubleValues ¶
func (m *DoubleExtremaData) GetDoubleValues() []float64
func (*DoubleExtremaData) ProtoMessage ¶
func (*DoubleExtremaData) ProtoMessage()
func (*DoubleExtremaData) Reset ¶
func (m *DoubleExtremaData) Reset()
func (*DoubleExtremaData) String ¶
func (m *DoubleExtremaData) String() string
func (*DoubleExtremaData) XXX_DiscardUnknown ¶
func (m *DoubleExtremaData) XXX_DiscardUnknown()
func (*DoubleExtremaData) XXX_Marshal ¶
func (m *DoubleExtremaData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DoubleExtremaData) XXX_Merge ¶
func (dst *DoubleExtremaData) XXX_Merge(src proto.Message)
func (*DoubleExtremaData) XXX_Size ¶
func (m *DoubleExtremaData) XXX_Size() int
func (*DoubleExtremaData) XXX_Unmarshal ¶
func (m *DoubleExtremaData) XXX_Unmarshal(b []byte) error
type Elements ¶
type Elements struct { // (Required) A list containing parts of logical byte streams. Data []*Elements_Data `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Messages used to represent logical byte streams. Stable
func (*Elements) Descriptor ¶
func (*Elements) GetData ¶
func (m *Elements) GetData() []*Elements_Data
func (*Elements) ProtoMessage ¶
func (*Elements) ProtoMessage()
func (*Elements) XXX_DiscardUnknown ¶
func (m *Elements) XXX_DiscardUnknown()
func (*Elements) XXX_Marshal ¶
func (*Elements) XXX_Unmarshal ¶
type Elements_Data ¶
type Elements_Data struct { // (Required) A reference to an active instruction request with the given // instruction id. InstructionReference string `protobuf:"bytes,1,opt,name=instruction_reference,json=instructionReference,proto3" json:"instruction_reference,omitempty"` // (Required) A definition representing a consumer or producer of this data. // If received by a harness, this represents the consumer within that // harness that should consume these bytes. If sent by a harness, this // represents the producer of these bytes. // // Note that a single element may span multiple Data messages. // // Note that a sending/receiving pair should share the same target // identifier. Target *Target `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"` // (Optional) Represents a part of a logical byte stream. Elements within // the logical byte stream are encoded in the nested context and // concatenated together. // // An empty data block represents the end of stream for the given // instruction and target. Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Represents multiple encoded elements in nested context for a given named instruction and target.
func (*Elements_Data) Descriptor ¶
func (*Elements_Data) Descriptor() ([]byte, []int)
func (*Elements_Data) GetData ¶
func (m *Elements_Data) GetData() []byte
func (*Elements_Data) GetInstructionReference ¶
func (m *Elements_Data) GetInstructionReference() string
func (*Elements_Data) GetTarget ¶
func (m *Elements_Data) GetTarget() *Target
func (*Elements_Data) ProtoMessage ¶
func (*Elements_Data) ProtoMessage()
func (*Elements_Data) Reset ¶
func (m *Elements_Data) Reset()
func (*Elements_Data) String ¶
func (m *Elements_Data) String() string
func (*Elements_Data) XXX_DiscardUnknown ¶
func (m *Elements_Data) XXX_DiscardUnknown()
func (*Elements_Data) XXX_Marshal ¶
func (m *Elements_Data) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Elements_Data) XXX_Merge ¶
func (dst *Elements_Data) XXX_Merge(src proto.Message)
func (*Elements_Data) XXX_Size ¶
func (m *Elements_Data) XXX_Size() int
func (*Elements_Data) XXX_Unmarshal ¶
func (m *Elements_Data) XXX_Unmarshal(b []byte) error
type ExtremaData ¶
type ExtremaData struct { // Types that are valid to be assigned to Extrema: // *ExtremaData_IntExtremaData // *ExtremaData_DoubleExtremaData Extrema isExtremaData_Extrema `protobuf_oneof:"extrema"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Extrema messages are used for calculating Top-N/Bottom-N metrics.
func (*ExtremaData) Descriptor ¶
func (*ExtremaData) Descriptor() ([]byte, []int)
func (*ExtremaData) GetDoubleExtremaData ¶
func (m *ExtremaData) GetDoubleExtremaData() *DoubleExtremaData
func (*ExtremaData) GetExtrema ¶
func (m *ExtremaData) GetExtrema() isExtremaData_Extrema
func (*ExtremaData) GetIntExtremaData ¶
func (m *ExtremaData) GetIntExtremaData() *IntExtremaData
func (*ExtremaData) ProtoMessage ¶
func (*ExtremaData) ProtoMessage()
func (*ExtremaData) Reset ¶
func (m *ExtremaData) Reset()
func (*ExtremaData) String ¶
func (m *ExtremaData) String() string
func (*ExtremaData) XXX_DiscardUnknown ¶
func (m *ExtremaData) XXX_DiscardUnknown()
func (*ExtremaData) XXX_Marshal ¶
func (m *ExtremaData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExtremaData) XXX_Merge ¶
func (dst *ExtremaData) XXX_Merge(src proto.Message)
func (*ExtremaData) XXX_OneofFuncs ¶
func (*ExtremaData) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*ExtremaData) XXX_Size ¶
func (m *ExtremaData) XXX_Size() int
func (*ExtremaData) XXX_Unmarshal ¶
func (m *ExtremaData) XXX_Unmarshal(b []byte) error
type ExtremaData_DoubleExtremaData ¶
type ExtremaData_DoubleExtremaData struct {
DoubleExtremaData *DoubleExtremaData `protobuf:"bytes,2,opt,name=double_extrema_data,json=doubleExtremaData,proto3,oneof"`
}
type ExtremaData_IntExtremaData ¶
type ExtremaData_IntExtremaData struct {
IntExtremaData *IntExtremaData `protobuf:"bytes,1,opt,name=int_extrema_data,json=intExtremaData,proto3,oneof"`
}
type GetProvisionInfoRequest ¶
type GetProvisionInfoRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A request to get the provision info of a SDK harness worker instance.
func (*GetProvisionInfoRequest) Descriptor ¶
func (*GetProvisionInfoRequest) Descriptor() ([]byte, []int)
func (*GetProvisionInfoRequest) ProtoMessage ¶
func (*GetProvisionInfoRequest) ProtoMessage()
func (*GetProvisionInfoRequest) Reset ¶
func (m *GetProvisionInfoRequest) Reset()
func (*GetProvisionInfoRequest) String ¶
func (m *GetProvisionInfoRequest) String() string
func (*GetProvisionInfoRequest) XXX_DiscardUnknown ¶
func (m *GetProvisionInfoRequest) XXX_DiscardUnknown()
func (*GetProvisionInfoRequest) XXX_Marshal ¶
func (m *GetProvisionInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetProvisionInfoRequest) XXX_Merge ¶
func (dst *GetProvisionInfoRequest) XXX_Merge(src proto.Message)
func (*GetProvisionInfoRequest) XXX_Size ¶
func (m *GetProvisionInfoRequest) XXX_Size() int
func (*GetProvisionInfoRequest) XXX_Unmarshal ¶
func (m *GetProvisionInfoRequest) XXX_Unmarshal(b []byte) error
type GetProvisionInfoResponse ¶
type GetProvisionInfoResponse struct { Info *ProvisionInfo `protobuf:"bytes,1,opt,name=info,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 (dst *GetProvisionInfoResponse) XXX_Merge(src proto.Message)
func (*GetProvisionInfoResponse) XXX_Size ¶
func (m *GetProvisionInfoResponse) XXX_Size() int
func (*GetProvisionInfoResponse) XXX_Unmarshal ¶
func (m *GetProvisionInfoResponse) XXX_Unmarshal(b []byte) error
type InstructionRequest ¶
type InstructionRequest struct { // (Required) An unique identifier provided by the runner which represents // this requests execution. The InstructionResponse MUST have the matching id. InstructionId string `protobuf:"bytes,1,opt,name=instruction_id,json=instructionId,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_Register // *InstructionRequest_ProcessBundle // *InstructionRequest_ProcessBundleProgress // *InstructionRequest_ProcessBundleSplit Request isInstructionRequest_Request `protobuf_oneof:"request"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A request sent by a runner which the SDK is asked to fulfill. For any unsupported request type, an error should be returned with a matching instruction id. Stable
func (*InstructionRequest) Descriptor ¶
func (*InstructionRequest) Descriptor() ([]byte, []int)
func (*InstructionRequest) GetInstructionId ¶
func (m *InstructionRequest) GetInstructionId() string
func (*InstructionRequest) GetProcessBundle ¶
func (m *InstructionRequest) GetProcessBundle() *ProcessBundleRequest
func (*InstructionRequest) GetProcessBundleProgress ¶
func (m *InstructionRequest) GetProcessBundleProgress() *ProcessBundleProgressRequest
func (*InstructionRequest) GetProcessBundleSplit ¶
func (m *InstructionRequest) GetProcessBundleSplit() *ProcessBundleSplitRequest
func (*InstructionRequest) GetRegister ¶
func (m *InstructionRequest) GetRegister() *RegisterRequest
func (*InstructionRequest) GetRequest ¶
func (m *InstructionRequest) GetRequest() isInstructionRequest_Request
func (*InstructionRequest) ProtoMessage ¶
func (*InstructionRequest) ProtoMessage()
func (*InstructionRequest) Reset ¶
func (m *InstructionRequest) Reset()
func (*InstructionRequest) String ¶
func (m *InstructionRequest) String() string
func (*InstructionRequest) XXX_DiscardUnknown ¶
func (m *InstructionRequest) XXX_DiscardUnknown()
func (*InstructionRequest) XXX_Marshal ¶
func (m *InstructionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InstructionRequest) XXX_Merge ¶
func (dst *InstructionRequest) XXX_Merge(src proto.Message)
func (*InstructionRequest) XXX_OneofFuncs ¶
func (*InstructionRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*InstructionRequest) XXX_Size ¶
func (m *InstructionRequest) XXX_Size() int
func (*InstructionRequest) XXX_Unmarshal ¶
func (m *InstructionRequest) XXX_Unmarshal(b []byte) error
type InstructionRequest_ProcessBundle ¶
type InstructionRequest_ProcessBundle struct {
ProcessBundle *ProcessBundleRequest `protobuf:"bytes,1001,opt,name=process_bundle,json=processBundle,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_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_Register // *InstructionResponse_ProcessBundle // *InstructionResponse_ProcessBundleProgress // *InstructionResponse_ProcessBundleSplit Response isInstructionResponse_Response `protobuf_oneof:"response"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
The response for an associated request the SDK had been asked to fulfill. Stable
func (*InstructionResponse) Descriptor ¶
func (*InstructionResponse) Descriptor() ([]byte, []int)
func (*InstructionResponse) GetError ¶
func (m *InstructionResponse) GetError() string
func (*InstructionResponse) GetInstructionId ¶
func (m *InstructionResponse) GetInstructionId() string
func (*InstructionResponse) GetProcessBundle ¶
func (m *InstructionResponse) GetProcessBundle() *ProcessBundleResponse
func (*InstructionResponse) GetProcessBundleProgress ¶
func (m *InstructionResponse) GetProcessBundleProgress() *ProcessBundleProgressResponse
func (*InstructionResponse) GetProcessBundleSplit ¶
func (m *InstructionResponse) GetProcessBundleSplit() *ProcessBundleSplitResponse
func (*InstructionResponse) GetRegister ¶
func (m *InstructionResponse) GetRegister() *RegisterResponse
func (*InstructionResponse) GetResponse ¶
func (m *InstructionResponse) GetResponse() isInstructionResponse_Response
func (*InstructionResponse) ProtoMessage ¶
func (*InstructionResponse) ProtoMessage()
func (*InstructionResponse) Reset ¶
func (m *InstructionResponse) Reset()
func (*InstructionResponse) String ¶
func (m *InstructionResponse) String() string
func (*InstructionResponse) XXX_DiscardUnknown ¶
func (m *InstructionResponse) XXX_DiscardUnknown()
func (*InstructionResponse) XXX_Marshal ¶
func (m *InstructionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InstructionResponse) XXX_Merge ¶
func (dst *InstructionResponse) XXX_Merge(src proto.Message)
func (*InstructionResponse) XXX_OneofFuncs ¶
func (*InstructionResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*InstructionResponse) XXX_Size ¶
func (m *InstructionResponse) XXX_Size() int
func (*InstructionResponse) XXX_Unmarshal ¶
func (m *InstructionResponse) XXX_Unmarshal(b []byte) error
type InstructionResponse_ProcessBundle ¶
type InstructionResponse_ProcessBundle struct {
ProcessBundle *ProcessBundleResponse `protobuf:"bytes,1001,opt,name=process_bundle,json=processBundle,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_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 IntDistributionData ¶
type IntDistributionData struct { Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"` Sum int64 `protobuf:"varint,2,opt,name=sum,proto3" json:"sum,omitempty"` Min int64 `protobuf:"varint,3,opt,name=min,proto3" json:"min,omitempty"` Max int64 `protobuf:"varint,4,opt,name=max,proto3" json:"max,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*IntDistributionData) Descriptor ¶
func (*IntDistributionData) Descriptor() ([]byte, []int)
func (*IntDistributionData) GetCount ¶
func (m *IntDistributionData) GetCount() int64
func (*IntDistributionData) GetMax ¶
func (m *IntDistributionData) GetMax() int64
func (*IntDistributionData) GetMin ¶
func (m *IntDistributionData) GetMin() int64
func (*IntDistributionData) GetSum ¶
func (m *IntDistributionData) GetSum() int64
func (*IntDistributionData) ProtoMessage ¶
func (*IntDistributionData) ProtoMessage()
func (*IntDistributionData) Reset ¶
func (m *IntDistributionData) Reset()
func (*IntDistributionData) String ¶
func (m *IntDistributionData) String() string
func (*IntDistributionData) XXX_DiscardUnknown ¶
func (m *IntDistributionData) XXX_DiscardUnknown()
func (*IntDistributionData) XXX_Marshal ¶
func (m *IntDistributionData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IntDistributionData) XXX_Merge ¶
func (dst *IntDistributionData) XXX_Merge(src proto.Message)
func (*IntDistributionData) XXX_Size ¶
func (m *IntDistributionData) XXX_Size() int
func (*IntDistributionData) XXX_Unmarshal ¶
func (m *IntDistributionData) XXX_Unmarshal(b []byte) error
type IntExtremaData ¶
type IntExtremaData struct { IntValues []int64 `protobuf:"varint,1,rep,packed,name=int_values,json=intValues,proto3" json:"int_values,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*IntExtremaData) Descriptor ¶
func (*IntExtremaData) Descriptor() ([]byte, []int)
func (*IntExtremaData) GetIntValues ¶
func (m *IntExtremaData) GetIntValues() []int64
func (*IntExtremaData) ProtoMessage ¶
func (*IntExtremaData) ProtoMessage()
func (*IntExtremaData) Reset ¶
func (m *IntExtremaData) Reset()
func (*IntExtremaData) String ¶
func (m *IntExtremaData) String() string
func (*IntExtremaData) XXX_DiscardUnknown ¶
func (m *IntExtremaData) XXX_DiscardUnknown()
func (*IntExtremaData) XXX_Marshal ¶
func (m *IntExtremaData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IntExtremaData) XXX_Merge ¶
func (dst *IntExtremaData) XXX_Merge(src proto.Message)
func (*IntExtremaData) XXX_Size ¶
func (m *IntExtremaData) XXX_Size() int
func (*IntExtremaData) XXX_Unmarshal ¶
func (m *IntExtremaData) XXX_Unmarshal(b []byte) error
type LogControl ¶
type LogControl struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LogControl) Descriptor ¶
func (*LogControl) Descriptor() ([]byte, []int)
func (*LogControl) ProtoMessage ¶
func (*LogControl) ProtoMessage()
func (*LogControl) Reset ¶
func (m *LogControl) Reset()
func (*LogControl) String ¶
func (m *LogControl) String() string
func (*LogControl) XXX_DiscardUnknown ¶
func (m *LogControl) XXX_DiscardUnknown()
func (*LogControl) XXX_Marshal ¶
func (m *LogControl) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogControl) XXX_Merge ¶
func (dst *LogControl) XXX_Merge(src proto.Message)
func (*LogControl) XXX_Size ¶
func (m *LogControl) XXX_Size() int
func (*LogControl) XXX_Unmarshal ¶
func (m *LogControl) XXX_Unmarshal(b []byte) error
type LogEntry ¶
type LogEntry struct { // (Required) The severity of the log statement. Severity LogEntry_Severity_Enum `` /* 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. InstructionReference string `protobuf:"bytes,5,opt,name=instruction_reference,json=instructionReference,proto3" json:"instruction_reference,omitempty"` // (Optional) A reference to the primitive transform this log statement is // associated with. PrimitiveTransformReference string `` /* 144-byte string literal not displayed */ // (Optional) Human-readable name of the function or method being invoked, // with optional context such as the class or package name. The format can // vary by language. For example: // qual.if.ied.Class.method (Java) // dir/package.func (Go) // module.function (Python) // file.cc:382 (C++) LogLocation string `protobuf:"bytes,7,opt,name=log_location,json=logLocation,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) Descriptor ¶
func (*LogEntry) GetInstructionReference ¶
func (*LogEntry) GetLogLocation ¶
func (*LogEntry) GetMessage ¶
func (*LogEntry) GetPrimitiveTransformReference ¶
func (*LogEntry) GetSeverity ¶
func (m *LogEntry) GetSeverity() LogEntry_Severity_Enum
func (*LogEntry) GetTimestamp ¶
func (*LogEntry) ProtoMessage ¶
func (*LogEntry) ProtoMessage()
func (*LogEntry) XXX_DiscardUnknown ¶
func (m *LogEntry) XXX_DiscardUnknown()
func (*LogEntry) XXX_Marshal ¶
func (*LogEntry) XXX_Unmarshal ¶
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 (dst *LogEntry_List) XXX_Merge(src proto.Message)
func (*LogEntry_List) XXX_Size ¶
func (m *LogEntry_List) XXX_Size() int
func (*LogEntry_List) XXX_Unmarshal ¶
func (m *LogEntry_List) XXX_Unmarshal(b []byte) error
type LogEntry_Severity ¶
type LogEntry_Severity struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
The severity of the event described in a log entry, expressed as one of the severity levels listed below. For your reference, the levels are assigned the listed numeric values. The effect of using numeric values other than those listed is undefined.
If you are writing log entries, you should map other severity encodings to one of these standard levels. For example, you might map all of Java's FINE, FINER, and FINEST levels to `Severity.DEBUG`.
This list is intentionally not comprehensive; the intent is to provide a common set of "good enough" severity levels so that logging front ends can provide filtering and searching across log types. Users of the API are free not to use all severity levels in their log messages.
func (*LogEntry_Severity) Descriptor ¶
func (*LogEntry_Severity) Descriptor() ([]byte, []int)
func (*LogEntry_Severity) ProtoMessage ¶
func (*LogEntry_Severity) ProtoMessage()
func (*LogEntry_Severity) Reset ¶
func (m *LogEntry_Severity) Reset()
func (*LogEntry_Severity) String ¶
func (m *LogEntry_Severity) String() string
func (*LogEntry_Severity) XXX_DiscardUnknown ¶
func (m *LogEntry_Severity) XXX_DiscardUnknown()
func (*LogEntry_Severity) XXX_Marshal ¶
func (m *LogEntry_Severity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogEntry_Severity) XXX_Merge ¶
func (dst *LogEntry_Severity) XXX_Merge(src proto.Message)
func (*LogEntry_Severity) XXX_Size ¶
func (m *LogEntry_Severity) XXX_Size() int
func (*LogEntry_Severity) XXX_Unmarshal ¶
func (m *LogEntry_Severity) XXX_Unmarshal(b []byte) error
type LogEntry_Severity_Enum ¶
type LogEntry_Severity_Enum int32
const ( // Unspecified level information. Will be logged at the TRACE level. LogEntry_Severity_UNSPECIFIED LogEntry_Severity_Enum = 0 // Trace level information. LogEntry_Severity_TRACE LogEntry_Severity_Enum = 1 // Debugging information. LogEntry_Severity_DEBUG LogEntry_Severity_Enum = 2 // Normal events. LogEntry_Severity_INFO LogEntry_Severity_Enum = 3 // Normal but significant events, such as start up, shut down, or // configuration. LogEntry_Severity_NOTICE LogEntry_Severity_Enum = 4 // Warning events might cause problems. LogEntry_Severity_WARN LogEntry_Severity_Enum = 5 // Error events are likely to cause problems. LogEntry_Severity_ERROR LogEntry_Severity_Enum = 6 // Critical events cause severe problems or brief outages and may // indicate that a person must take action. LogEntry_Severity_CRITICAL LogEntry_Severity_Enum = 7 )
func (LogEntry_Severity_Enum) EnumDescriptor ¶
func (LogEntry_Severity_Enum) EnumDescriptor() ([]byte, []int)
func (LogEntry_Severity_Enum) String ¶
func (x LogEntry_Severity_Enum) String() string
type Metric ¶
type Metric struct { // (Required) The data for this metric. // // Types that are valid to be assigned to Data: // *Metric_CounterData // *Metric_DistributionData // *Metric_ExtremaData Data isMetric_Data `protobuf_oneof:"data"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Metric) Descriptor ¶
func (*Metric) GetCounterData ¶
func (m *Metric) GetCounterData() *CounterData
func (*Metric) GetDistributionData ¶
func (m *Metric) GetDistributionData() *DistributionData
func (*Metric) GetExtremaData ¶
func (m *Metric) GetExtremaData() *ExtremaData
func (*Metric) ProtoMessage ¶
func (*Metric) ProtoMessage()
func (*Metric) XXX_DiscardUnknown ¶
func (m *Metric) XXX_DiscardUnknown()
func (*Metric) XXX_Marshal ¶
func (*Metric) XXX_OneofFuncs ¶
func (*Metric) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*Metric) XXX_Unmarshal ¶
type Metric_CounterData ¶
type Metric_CounterData struct {
CounterData *CounterData `protobuf:"bytes,1,opt,name=counter_data,json=counterData,proto3,oneof"`
}
type Metric_DistributionData ¶
type Metric_DistributionData struct {
DistributionData *DistributionData `protobuf:"bytes,2,opt,name=distribution_data,json=distributionData,proto3,oneof"`
}
type Metric_ExtremaData ¶
type Metric_ExtremaData struct {
ExtremaData *ExtremaData `protobuf:"bytes,3,opt,name=extrema_data,json=extremaData,proto3,oneof"`
}
type Metrics ¶
type Metrics struct { Ptransforms map[string]*Metrics_PTransform `` /* 163-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
DEPRECATED
func (*Metrics) Descriptor ¶
func (*Metrics) GetPtransforms ¶
func (m *Metrics) GetPtransforms() map[string]*Metrics_PTransform
func (*Metrics) ProtoMessage ¶
func (*Metrics) ProtoMessage()
func (*Metrics) XXX_DiscardUnknown ¶
func (m *Metrics) XXX_DiscardUnknown()
func (*Metrics) XXX_Marshal ¶
func (*Metrics) XXX_Unmarshal ¶
type Metrics_PTransform ¶
type Metrics_PTransform struct { // (Required): Metrics for processed elements. ProcessedElements *Metrics_PTransform_ProcessedElements `protobuf:"bytes,1,opt,name=processed_elements,json=processedElements,proto3" json:"processed_elements,omitempty"` // (Required): Metrics for active elements. ActiveElements *Metrics_PTransform_ActiveElements `protobuf:"bytes,2,opt,name=active_elements,json=activeElements,proto3" json:"active_elements,omitempty"` // (Optional): Map from local output name to its watermark. // The watermarks reported are tentative, to get a better sense of progress // while processing a bundle but before it is committed. At bundle commit // time, a Runner needs to also take into account the timers set to compute // the actual watermarks. Watermarks map[string]int64 `` /* 162-byte string literal not displayed */ User []*Metrics_User `protobuf:"bytes,4,rep,name=user,proto3" json:"user,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
PTransform level metrics. These metrics are split into processed and active element groups for progress reporting purposes. This allows a Runner to see what is measured, what is estimated and what can be extrapolated to be able to accurately estimate the backlog of remaining work.
func (*Metrics_PTransform) Descriptor ¶
func (*Metrics_PTransform) Descriptor() ([]byte, []int)
func (*Metrics_PTransform) GetActiveElements ¶
func (m *Metrics_PTransform) GetActiveElements() *Metrics_PTransform_ActiveElements
func (*Metrics_PTransform) GetProcessedElements ¶
func (m *Metrics_PTransform) GetProcessedElements() *Metrics_PTransform_ProcessedElements
func (*Metrics_PTransform) GetUser ¶
func (m *Metrics_PTransform) GetUser() []*Metrics_User
func (*Metrics_PTransform) GetWatermarks ¶
func (m *Metrics_PTransform) GetWatermarks() map[string]int64
func (*Metrics_PTransform) ProtoMessage ¶
func (*Metrics_PTransform) ProtoMessage()
func (*Metrics_PTransform) Reset ¶
func (m *Metrics_PTransform) Reset()
func (*Metrics_PTransform) String ¶
func (m *Metrics_PTransform) String() string
func (*Metrics_PTransform) XXX_DiscardUnknown ¶
func (m *Metrics_PTransform) XXX_DiscardUnknown()
func (*Metrics_PTransform) XXX_Marshal ¶
func (m *Metrics_PTransform) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Metrics_PTransform) XXX_Merge ¶
func (dst *Metrics_PTransform) XXX_Merge(src proto.Message)
func (*Metrics_PTransform) XXX_Size ¶
func (m *Metrics_PTransform) XXX_Size() int
func (*Metrics_PTransform) XXX_Unmarshal ¶
func (m *Metrics_PTransform) XXX_Unmarshal(b []byte) error
type Metrics_PTransform_ActiveElements ¶
type Metrics_PTransform_ActiveElements struct { // (Required) Measured *Metrics_PTransform_Measured `protobuf:"bytes,1,opt,name=measured,proto3" json:"measured,omitempty"` // (Optional) Sum of estimated fraction of known work remaining for all // active elements, as reported by this transform. // If not reported, a Runner could extrapolate this from the processed // elements. // TODO: Handle the case when known work is infinite. FractionRemaining float64 `protobuf:"fixed64,2,opt,name=fraction_remaining,json=fractionRemaining,proto3" json:"fraction_remaining,omitempty"` // (Optional) Map from local output name to sum of estimated number // of elements remaining for this output from all active elements, // as reported by this transform. // If not reported, a Runner could extrapolate this from the processed // elements. OutputElementsRemaining map[string]int64 `` /* 221-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Metrics for active elements. An element is considered active if the SDK has started but not finished processing it yet.
func (*Metrics_PTransform_ActiveElements) Descriptor ¶
func (*Metrics_PTransform_ActiveElements) Descriptor() ([]byte, []int)
func (*Metrics_PTransform_ActiveElements) GetFractionRemaining ¶
func (m *Metrics_PTransform_ActiveElements) GetFractionRemaining() float64
func (*Metrics_PTransform_ActiveElements) GetMeasured ¶
func (m *Metrics_PTransform_ActiveElements) GetMeasured() *Metrics_PTransform_Measured
func (*Metrics_PTransform_ActiveElements) GetOutputElementsRemaining ¶
func (m *Metrics_PTransform_ActiveElements) GetOutputElementsRemaining() map[string]int64
func (*Metrics_PTransform_ActiveElements) ProtoMessage ¶
func (*Metrics_PTransform_ActiveElements) ProtoMessage()
func (*Metrics_PTransform_ActiveElements) Reset ¶
func (m *Metrics_PTransform_ActiveElements) Reset()
func (*Metrics_PTransform_ActiveElements) String ¶
func (m *Metrics_PTransform_ActiveElements) String() string
func (*Metrics_PTransform_ActiveElements) XXX_DiscardUnknown ¶
func (m *Metrics_PTransform_ActiveElements) XXX_DiscardUnknown()
func (*Metrics_PTransform_ActiveElements) XXX_Marshal ¶
func (m *Metrics_PTransform_ActiveElements) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Metrics_PTransform_ActiveElements) XXX_Merge ¶
func (dst *Metrics_PTransform_ActiveElements) XXX_Merge(src proto.Message)
func (*Metrics_PTransform_ActiveElements) XXX_Size ¶
func (m *Metrics_PTransform_ActiveElements) XXX_Size() int
func (*Metrics_PTransform_ActiveElements) XXX_Unmarshal ¶
func (m *Metrics_PTransform_ActiveElements) XXX_Unmarshal(b []byte) error
type Metrics_PTransform_Measured ¶
type Metrics_PTransform_Measured struct { // (Optional) Map from local input name to number of elements processed // from this input. // If unset, assumed to be the sum of the outputs of all producers to // this transform (for ProcessedElements) and 0 (for ActiveElements). InputElementCounts map[string]int64 `` /* 206-byte string literal not displayed */ // (Required) Map from local output name to number of elements produced // for this output. OutputElementCounts map[string]int64 `` /* 209-byte string literal not displayed */ // (Optional) The total time spent so far in processing the elements in // this group, in seconds. TotalTimeSpent float64 `protobuf:"fixed64,3,opt,name=total_time_spent,json=totalTimeSpent,proto3" json:"total_time_spent,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Metrics that are measured for processed and active element groups.
func (*Metrics_PTransform_Measured) Descriptor ¶
func (*Metrics_PTransform_Measured) Descriptor() ([]byte, []int)
func (*Metrics_PTransform_Measured) GetInputElementCounts ¶
func (m *Metrics_PTransform_Measured) GetInputElementCounts() map[string]int64
func (*Metrics_PTransform_Measured) GetOutputElementCounts ¶
func (m *Metrics_PTransform_Measured) GetOutputElementCounts() map[string]int64
func (*Metrics_PTransform_Measured) GetTotalTimeSpent ¶
func (m *Metrics_PTransform_Measured) GetTotalTimeSpent() float64
func (*Metrics_PTransform_Measured) ProtoMessage ¶
func (*Metrics_PTransform_Measured) ProtoMessage()
func (*Metrics_PTransform_Measured) Reset ¶
func (m *Metrics_PTransform_Measured) Reset()
func (*Metrics_PTransform_Measured) String ¶
func (m *Metrics_PTransform_Measured) String() string
func (*Metrics_PTransform_Measured) XXX_DiscardUnknown ¶
func (m *Metrics_PTransform_Measured) XXX_DiscardUnknown()
func (*Metrics_PTransform_Measured) XXX_Marshal ¶
func (m *Metrics_PTransform_Measured) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Metrics_PTransform_Measured) XXX_Merge ¶
func (dst *Metrics_PTransform_Measured) XXX_Merge(src proto.Message)
func (*Metrics_PTransform_Measured) XXX_Size ¶
func (m *Metrics_PTransform_Measured) XXX_Size() int
func (*Metrics_PTransform_Measured) XXX_Unmarshal ¶
func (m *Metrics_PTransform_Measured) XXX_Unmarshal(b []byte) error
type Metrics_PTransform_ProcessedElements ¶
type Metrics_PTransform_ProcessedElements struct { // (Required) Measured *Metrics_PTransform_Measured `protobuf:"bytes,1,opt,name=measured,proto3" json:"measured,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Metrics for fully processed elements.
func (*Metrics_PTransform_ProcessedElements) Descriptor ¶
func (*Metrics_PTransform_ProcessedElements) Descriptor() ([]byte, []int)
func (*Metrics_PTransform_ProcessedElements) GetMeasured ¶
func (m *Metrics_PTransform_ProcessedElements) GetMeasured() *Metrics_PTransform_Measured
func (*Metrics_PTransform_ProcessedElements) ProtoMessage ¶
func (*Metrics_PTransform_ProcessedElements) ProtoMessage()
func (*Metrics_PTransform_ProcessedElements) Reset ¶
func (m *Metrics_PTransform_ProcessedElements) Reset()
func (*Metrics_PTransform_ProcessedElements) String ¶
func (m *Metrics_PTransform_ProcessedElements) String() string
func (*Metrics_PTransform_ProcessedElements) XXX_DiscardUnknown ¶
func (m *Metrics_PTransform_ProcessedElements) XXX_DiscardUnknown()
func (*Metrics_PTransform_ProcessedElements) XXX_Marshal ¶
func (m *Metrics_PTransform_ProcessedElements) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Metrics_PTransform_ProcessedElements) XXX_Merge ¶
func (dst *Metrics_PTransform_ProcessedElements) XXX_Merge(src proto.Message)
func (*Metrics_PTransform_ProcessedElements) XXX_Size ¶
func (m *Metrics_PTransform_ProcessedElements) XXX_Size() int
func (*Metrics_PTransform_ProcessedElements) XXX_Unmarshal ¶
func (m *Metrics_PTransform_ProcessedElements) XXX_Unmarshal(b []byte) error
type Metrics_User ¶
type Metrics_User struct { // (Required) The identifier for this metric. MetricName *Metrics_User_MetricName `protobuf:"bytes,1,opt,name=metric_name,json=metricName,proto3" json:"metric_name,omitempty"` // (Required) The data for this metric. // // Types that are valid to be assigned to Data: // *Metrics_User_CounterData_ // *Metrics_User_DistributionData_ // *Metrics_User_GaugeData_ Data isMetrics_User_Data `protobuf_oneof:"data"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
User defined metrics
func (*Metrics_User) Descriptor ¶
func (*Metrics_User) Descriptor() ([]byte, []int)
func (*Metrics_User) GetCounterData ¶
func (m *Metrics_User) GetCounterData() *Metrics_User_CounterData
func (*Metrics_User) GetData ¶
func (m *Metrics_User) GetData() isMetrics_User_Data
func (*Metrics_User) GetDistributionData ¶
func (m *Metrics_User) GetDistributionData() *Metrics_User_DistributionData
func (*Metrics_User) GetGaugeData ¶
func (m *Metrics_User) GetGaugeData() *Metrics_User_GaugeData
func (*Metrics_User) GetMetricName ¶
func (m *Metrics_User) GetMetricName() *Metrics_User_MetricName
func (*Metrics_User) ProtoMessage ¶
func (*Metrics_User) ProtoMessage()
func (*Metrics_User) Reset ¶
func (m *Metrics_User) Reset()
func (*Metrics_User) String ¶
func (m *Metrics_User) String() string
func (*Metrics_User) XXX_DiscardUnknown ¶
func (m *Metrics_User) XXX_DiscardUnknown()
func (*Metrics_User) XXX_Marshal ¶
func (m *Metrics_User) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Metrics_User) XXX_Merge ¶
func (dst *Metrics_User) XXX_Merge(src proto.Message)
func (*Metrics_User) XXX_OneofFuncs ¶
func (*Metrics_User) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*Metrics_User) XXX_Size ¶
func (m *Metrics_User) XXX_Size() int
func (*Metrics_User) XXX_Unmarshal ¶
func (m *Metrics_User) XXX_Unmarshal(b []byte) error
type Metrics_User_CounterData ¶
type Metrics_User_CounterData struct { Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Data associated with a counter metric.
func (*Metrics_User_CounterData) Descriptor ¶
func (*Metrics_User_CounterData) Descriptor() ([]byte, []int)
func (*Metrics_User_CounterData) GetValue ¶
func (m *Metrics_User_CounterData) GetValue() int64
func (*Metrics_User_CounterData) ProtoMessage ¶
func (*Metrics_User_CounterData) ProtoMessage()
func (*Metrics_User_CounterData) Reset ¶
func (m *Metrics_User_CounterData) Reset()
func (*Metrics_User_CounterData) String ¶
func (m *Metrics_User_CounterData) String() string
func (*Metrics_User_CounterData) XXX_DiscardUnknown ¶
func (m *Metrics_User_CounterData) XXX_DiscardUnknown()
func (*Metrics_User_CounterData) XXX_Marshal ¶
func (m *Metrics_User_CounterData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Metrics_User_CounterData) XXX_Merge ¶
func (dst *Metrics_User_CounterData) XXX_Merge(src proto.Message)
func (*Metrics_User_CounterData) XXX_Size ¶
func (m *Metrics_User_CounterData) XXX_Size() int
func (*Metrics_User_CounterData) XXX_Unmarshal ¶
func (m *Metrics_User_CounterData) XXX_Unmarshal(b []byte) error
type Metrics_User_CounterData_ ¶
type Metrics_User_CounterData_ struct {
CounterData *Metrics_User_CounterData `protobuf:"bytes,1001,opt,name=counter_data,json=counterData,proto3,oneof"`
}
type Metrics_User_DistributionData ¶
type Metrics_User_DistributionData struct { Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"` Sum int64 `protobuf:"varint,2,opt,name=sum,proto3" json:"sum,omitempty"` Min int64 `protobuf:"varint,3,opt,name=min,proto3" json:"min,omitempty"` Max int64 `protobuf:"varint,4,opt,name=max,proto3" json:"max,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Data associated with a distribution metric.
func (*Metrics_User_DistributionData) Descriptor ¶
func (*Metrics_User_DistributionData) Descriptor() ([]byte, []int)
func (*Metrics_User_DistributionData) GetCount ¶
func (m *Metrics_User_DistributionData) GetCount() int64
func (*Metrics_User_DistributionData) GetMax ¶
func (m *Metrics_User_DistributionData) GetMax() int64
func (*Metrics_User_DistributionData) GetMin ¶
func (m *Metrics_User_DistributionData) GetMin() int64
func (*Metrics_User_DistributionData) GetSum ¶
func (m *Metrics_User_DistributionData) GetSum() int64
func (*Metrics_User_DistributionData) ProtoMessage ¶
func (*Metrics_User_DistributionData) ProtoMessage()
func (*Metrics_User_DistributionData) Reset ¶
func (m *Metrics_User_DistributionData) Reset()
func (*Metrics_User_DistributionData) String ¶
func (m *Metrics_User_DistributionData) String() string
func (*Metrics_User_DistributionData) XXX_DiscardUnknown ¶
func (m *Metrics_User_DistributionData) XXX_DiscardUnknown()
func (*Metrics_User_DistributionData) XXX_Marshal ¶
func (m *Metrics_User_DistributionData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Metrics_User_DistributionData) XXX_Merge ¶
func (dst *Metrics_User_DistributionData) XXX_Merge(src proto.Message)
func (*Metrics_User_DistributionData) XXX_Size ¶
func (m *Metrics_User_DistributionData) XXX_Size() int
func (*Metrics_User_DistributionData) XXX_Unmarshal ¶
func (m *Metrics_User_DistributionData) XXX_Unmarshal(b []byte) error
type Metrics_User_DistributionData_ ¶
type Metrics_User_DistributionData_ struct {
DistributionData *Metrics_User_DistributionData `protobuf:"bytes,1002,opt,name=distribution_data,json=distributionData,proto3,oneof"`
}
type Metrics_User_GaugeData ¶
type Metrics_User_GaugeData struct { Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` Timestamp *timestamp.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Data associated with a Gauge metric.
func (*Metrics_User_GaugeData) Descriptor ¶
func (*Metrics_User_GaugeData) Descriptor() ([]byte, []int)
func (*Metrics_User_GaugeData) GetTimestamp ¶
func (m *Metrics_User_GaugeData) GetTimestamp() *timestamp.Timestamp
func (*Metrics_User_GaugeData) GetValue ¶
func (m *Metrics_User_GaugeData) GetValue() int64
func (*Metrics_User_GaugeData) ProtoMessage ¶
func (*Metrics_User_GaugeData) ProtoMessage()
func (*Metrics_User_GaugeData) Reset ¶
func (m *Metrics_User_GaugeData) Reset()
func (*Metrics_User_GaugeData) String ¶
func (m *Metrics_User_GaugeData) String() string
func (*Metrics_User_GaugeData) XXX_DiscardUnknown ¶
func (m *Metrics_User_GaugeData) XXX_DiscardUnknown()
func (*Metrics_User_GaugeData) XXX_Marshal ¶
func (m *Metrics_User_GaugeData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Metrics_User_GaugeData) XXX_Merge ¶
func (dst *Metrics_User_GaugeData) XXX_Merge(src proto.Message)
func (*Metrics_User_GaugeData) XXX_Size ¶
func (m *Metrics_User_GaugeData) XXX_Size() int
func (*Metrics_User_GaugeData) XXX_Unmarshal ¶
func (m *Metrics_User_GaugeData) XXX_Unmarshal(b []byte) error
type Metrics_User_GaugeData_ ¶
type Metrics_User_GaugeData_ struct {
GaugeData *Metrics_User_GaugeData `protobuf:"bytes,1003,opt,name=gauge_data,json=gaugeData,proto3,oneof"`
}
type Metrics_User_MetricName ¶
type Metrics_User_MetricName struct { // (Required): The namespace of this metric. Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` // (Required): The name of this metric. Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A key for identifying a metric at the most granular level.
func (*Metrics_User_MetricName) Descriptor ¶
func (*Metrics_User_MetricName) Descriptor() ([]byte, []int)
func (*Metrics_User_MetricName) GetName ¶
func (m *Metrics_User_MetricName) GetName() string
func (*Metrics_User_MetricName) GetNamespace ¶
func (m *Metrics_User_MetricName) GetNamespace() string
func (*Metrics_User_MetricName) ProtoMessage ¶
func (*Metrics_User_MetricName) ProtoMessage()
func (*Metrics_User_MetricName) Reset ¶
func (m *Metrics_User_MetricName) Reset()
func (*Metrics_User_MetricName) String ¶
func (m *Metrics_User_MetricName) String() string
func (*Metrics_User_MetricName) XXX_DiscardUnknown ¶
func (m *Metrics_User_MetricName) XXX_DiscardUnknown()
func (*Metrics_User_MetricName) XXX_Marshal ¶
func (m *Metrics_User_MetricName) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Metrics_User_MetricName) XXX_Merge ¶
func (dst *Metrics_User_MetricName) XXX_Merge(src proto.Message)
func (*Metrics_User_MetricName) XXX_Size ¶
func (m *Metrics_User_MetricName) XXX_Size() int
func (*Metrics_User_MetricName) XXX_Unmarshal ¶
func (m *Metrics_User_MetricName) XXX_Unmarshal(b []byte) error
type MonitoringInfo ¶
type MonitoringInfo struct { // The name defining the metric or monitored state. Urn string `protobuf:"bytes,1,opt,name=urn,proto3" json:"urn,omitempty"` // This is specified as a URN that implies: // A message class: (Distribution, Counter, Extrema, MonitoringDataTable). // Sub types like field formats - int64, double, string. // Aggregation methods - SUM, LATEST, TOP-N, BOTTOM-N, DISTRIBUTION // valid values are: // beam:metrics:[SumInt64|LatestInt64|Top-NInt64|Bottom-NInt64| // SumDouble|LatestDouble|Top-NDouble|Bottom-NDouble|DistributionInt64| // DistributionDouble|MonitoringDataTable] Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` // The Metric or monitored state. // // Types that are valid to be assigned to Data: // *MonitoringInfo_MonitoringTableData // *MonitoringInfo_Metric Data isMonitoringInfo_Data `protobuf_oneof:"data"` // A set of key+value labels which define the scope of the metric. // Either a well defined entity id for matching the enum names in // the MonitoringInfoLabels enum or any arbitrary label // set by a custom metric or user metric. // A monitoring system is expected to be able to aggregate the metrics together // for all updates having the same URN and labels. // Some systems such as Stackdriver will be able to aggregate the metrics // using a subset of the provided labels Labels map[string]string `` /* 153-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MonitoringInfo) Descriptor ¶
func (*MonitoringInfo) Descriptor() ([]byte, []int)
func (*MonitoringInfo) GetData ¶
func (m *MonitoringInfo) GetData() isMonitoringInfo_Data
func (*MonitoringInfo) GetLabels ¶
func (m *MonitoringInfo) GetLabels() map[string]string
func (*MonitoringInfo) GetMetric ¶
func (m *MonitoringInfo) GetMetric() *Metric
func (*MonitoringInfo) GetMonitoringTableData ¶
func (m *MonitoringInfo) GetMonitoringTableData() *MonitoringTableData
func (*MonitoringInfo) GetType ¶
func (m *MonitoringInfo) GetType() string
func (*MonitoringInfo) GetUrn ¶
func (m *MonitoringInfo) GetUrn() string
func (*MonitoringInfo) ProtoMessage ¶
func (*MonitoringInfo) ProtoMessage()
func (*MonitoringInfo) Reset ¶
func (m *MonitoringInfo) Reset()
func (*MonitoringInfo) String ¶
func (m *MonitoringInfo) String() string
func (*MonitoringInfo) XXX_DiscardUnknown ¶
func (m *MonitoringInfo) XXX_DiscardUnknown()
func (*MonitoringInfo) XXX_Marshal ¶
func (m *MonitoringInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MonitoringInfo) XXX_Merge ¶
func (dst *MonitoringInfo) XXX_Merge(src proto.Message)
func (*MonitoringInfo) XXX_OneofFuncs ¶
func (*MonitoringInfo) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*MonitoringInfo) XXX_Size ¶
func (m *MonitoringInfo) XXX_Size() int
func (*MonitoringInfo) XXX_Unmarshal ¶
func (m *MonitoringInfo) XXX_Unmarshal(b []byte) error
type MonitoringInfo_Metric ¶
type MonitoringInfo_Metric struct {
Metric *Metric `protobuf:"bytes,4,opt,name=metric,proto3,oneof"`
}
type MonitoringInfo_MonitoringInfoLabels ¶
type MonitoringInfo_MonitoringInfoLabels int32
const ( MonitoringInfo_TRANSFORM MonitoringInfo_MonitoringInfoLabels = 0 MonitoringInfo_PCOLLECTION MonitoringInfo_MonitoringInfoLabels = 1 MonitoringInfo_WINDOWING_STRATEGY MonitoringInfo_MonitoringInfoLabels = 2 MonitoringInfo_CODER MonitoringInfo_MonitoringInfoLabels = 3 MonitoringInfo_ENVIRONMENT MonitoringInfo_MonitoringInfoLabels = 4 )
func (MonitoringInfo_MonitoringInfoLabels) EnumDescriptor ¶
func (MonitoringInfo_MonitoringInfoLabels) EnumDescriptor() ([]byte, []int)
func (MonitoringInfo_MonitoringInfoLabels) String ¶
func (x MonitoringInfo_MonitoringInfoLabels) String() string
type MonitoringInfo_MonitoringTableData ¶
type MonitoringInfo_MonitoringTableData struct {
MonitoringTableData *MonitoringTableData `protobuf:"bytes,3,opt,name=monitoring_table_data,json=monitoringTableData,proto3,oneof"`
}
type MonitoringTableData ¶
type MonitoringTableData struct { // The number of column names must match the // number of values in each MonitoringRow. ColumnNames []string `protobuf:"bytes,1,rep,name=column_names,json=columnNames,proto3" json:"column_names,omitempty"` RowData []*MonitoringTableData_MonitoringRow `protobuf:"bytes,2,rep,name=row_data,json=rowData,proto3" json:"row_data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
General MonitoredState information which contains structured information which does not fit into a typical metric format. For example, a table of important files and metadata which an I/O source is reading. Note: Since MonitoredState is designed to be customizable, and allow engines to aggregate these metrics in custom ways. Engines can use custom aggregation functions for specific URNs by inspecting the column values. An SDK should always report its current state, that is all relevant MonitoredState for its PTransform at the current moment and this should be kept small. For example, an SDK can emit the oldest three files which have been waiting for data for over 1 hour. If an engine supports the URN with a custom aggregation then it can filter these and keep only the Top-3 rows based on how long the files have been waiting for data. Otherwise an engine can ignore the MonitoringTableData or union all the rows together into one large table and display them in a UI.
func (*MonitoringTableData) Descriptor ¶
func (*MonitoringTableData) Descriptor() ([]byte, []int)
func (*MonitoringTableData) GetColumnNames ¶
func (m *MonitoringTableData) GetColumnNames() []string
func (*MonitoringTableData) GetRowData ¶
func (m *MonitoringTableData) GetRowData() []*MonitoringTableData_MonitoringRow
func (*MonitoringTableData) ProtoMessage ¶
func (*MonitoringTableData) ProtoMessage()
func (*MonitoringTableData) Reset ¶
func (m *MonitoringTableData) Reset()
func (*MonitoringTableData) String ¶
func (m *MonitoringTableData) String() string
func (*MonitoringTableData) XXX_DiscardUnknown ¶
func (m *MonitoringTableData) XXX_DiscardUnknown()
func (*MonitoringTableData) XXX_Marshal ¶
func (m *MonitoringTableData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MonitoringTableData) XXX_Merge ¶
func (dst *MonitoringTableData) XXX_Merge(src proto.Message)
func (*MonitoringTableData) XXX_Size ¶
func (m *MonitoringTableData) XXX_Size() int
func (*MonitoringTableData) XXX_Unmarshal ¶
func (m *MonitoringTableData) XXX_Unmarshal(b []byte) error
type MonitoringTableData_MonitoringColumnValue ¶
type MonitoringTableData_MonitoringColumnValue struct { // Types that are valid to be assigned to Value: // *MonitoringTableData_MonitoringColumnValue_Int64Value // *MonitoringTableData_MonitoringColumnValue_DoubleValue // *MonitoringTableData_MonitoringColumnValue_StringValue // *MonitoringTableData_MonitoringColumnValue_Timestamp Value isMonitoringTableData_MonitoringColumnValue_Value `protobuf_oneof:"value"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MonitoringTableData_MonitoringColumnValue) Descriptor ¶
func (*MonitoringTableData_MonitoringColumnValue) Descriptor() ([]byte, []int)
func (*MonitoringTableData_MonitoringColumnValue) GetDoubleValue ¶
func (m *MonitoringTableData_MonitoringColumnValue) GetDoubleValue() float64
func (*MonitoringTableData_MonitoringColumnValue) GetInt64Value ¶
func (m *MonitoringTableData_MonitoringColumnValue) GetInt64Value() int64
func (*MonitoringTableData_MonitoringColumnValue) GetStringValue ¶
func (m *MonitoringTableData_MonitoringColumnValue) GetStringValue() string
func (*MonitoringTableData_MonitoringColumnValue) GetTimestamp ¶
func (m *MonitoringTableData_MonitoringColumnValue) GetTimestamp() *timestamp.Timestamp
func (*MonitoringTableData_MonitoringColumnValue) GetValue ¶
func (m *MonitoringTableData_MonitoringColumnValue) GetValue() isMonitoringTableData_MonitoringColumnValue_Value
func (*MonitoringTableData_MonitoringColumnValue) ProtoMessage ¶
func (*MonitoringTableData_MonitoringColumnValue) ProtoMessage()
func (*MonitoringTableData_MonitoringColumnValue) Reset ¶
func (m *MonitoringTableData_MonitoringColumnValue) Reset()
func (*MonitoringTableData_MonitoringColumnValue) String ¶
func (m *MonitoringTableData_MonitoringColumnValue) String() string
func (*MonitoringTableData_MonitoringColumnValue) XXX_DiscardUnknown ¶
func (m *MonitoringTableData_MonitoringColumnValue) XXX_DiscardUnknown()
func (*MonitoringTableData_MonitoringColumnValue) XXX_Marshal ¶
func (m *MonitoringTableData_MonitoringColumnValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MonitoringTableData_MonitoringColumnValue) XXX_Merge ¶
func (dst *MonitoringTableData_MonitoringColumnValue) XXX_Merge(src proto.Message)
func (*MonitoringTableData_MonitoringColumnValue) XXX_OneofFuncs ¶
func (*MonitoringTableData_MonitoringColumnValue) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*MonitoringTableData_MonitoringColumnValue) XXX_Size ¶
func (m *MonitoringTableData_MonitoringColumnValue) XXX_Size() int
func (*MonitoringTableData_MonitoringColumnValue) XXX_Unmarshal ¶
func (m *MonitoringTableData_MonitoringColumnValue) XXX_Unmarshal(b []byte) error
type MonitoringTableData_MonitoringColumnValue_DoubleValue ¶
type MonitoringTableData_MonitoringColumnValue_DoubleValue struct {
DoubleValue float64 `protobuf:"fixed64,2,opt,name=double_value,json=doubleValue,proto3,oneof"`
}
type MonitoringTableData_MonitoringColumnValue_Int64Value ¶
type MonitoringTableData_MonitoringColumnValue_Int64Value struct {
Int64Value int64 `protobuf:"varint,1,opt,name=int64_value,json=int64Value,proto3,oneof"`
}
type MonitoringTableData_MonitoringColumnValue_StringValue ¶
type MonitoringTableData_MonitoringColumnValue_StringValue struct {
StringValue string `protobuf:"bytes,3,opt,name=string_value,json=stringValue,proto3,oneof"`
}
type MonitoringTableData_MonitoringRow ¶
type MonitoringTableData_MonitoringRow struct { Values []*MonitoringTableData_MonitoringColumnValue `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MonitoringTableData_MonitoringRow) Descriptor ¶
func (*MonitoringTableData_MonitoringRow) Descriptor() ([]byte, []int)
func (*MonitoringTableData_MonitoringRow) GetValues ¶
func (m *MonitoringTableData_MonitoringRow) GetValues() []*MonitoringTableData_MonitoringColumnValue
func (*MonitoringTableData_MonitoringRow) ProtoMessage ¶
func (*MonitoringTableData_MonitoringRow) ProtoMessage()
func (*MonitoringTableData_MonitoringRow) Reset ¶
func (m *MonitoringTableData_MonitoringRow) Reset()
func (*MonitoringTableData_MonitoringRow) String ¶
func (m *MonitoringTableData_MonitoringRow) String() string
func (*MonitoringTableData_MonitoringRow) XXX_DiscardUnknown ¶
func (m *MonitoringTableData_MonitoringRow) XXX_DiscardUnknown()
func (*MonitoringTableData_MonitoringRow) XXX_Marshal ¶
func (m *MonitoringTableData_MonitoringRow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MonitoringTableData_MonitoringRow) XXX_Merge ¶
func (dst *MonitoringTableData_MonitoringRow) XXX_Merge(src proto.Message)
func (*MonitoringTableData_MonitoringRow) XXX_Size ¶
func (m *MonitoringTableData_MonitoringRow) XXX_Size() int
func (*MonitoringTableData_MonitoringRow) XXX_Unmarshal ¶
func (m *MonitoringTableData_MonitoringRow) XXX_Unmarshal(b []byte) error
type ProcessBundleDescriptor ¶
type ProcessBundleDescriptor struct { // (Required) A pipeline level unique id which can be used as a reference to // refer to this. Id string `protobuf:"bytes,1,opt,name=id,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 */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Definitions that should be used to construct the bundle processing graph.
func (*ProcessBundleDescriptor) Descriptor ¶
func (*ProcessBundleDescriptor) Descriptor() ([]byte, []int)
func (*ProcessBundleDescriptor) GetCoders ¶
func (m *ProcessBundleDescriptor) GetCoders() map[string]*pipeline_v1.Coder
func (*ProcessBundleDescriptor) GetEnvironments ¶
func (m *ProcessBundleDescriptor) GetEnvironments() map[string]*pipeline_v1.Environment
func (*ProcessBundleDescriptor) GetId ¶
func (m *ProcessBundleDescriptor) GetId() string
func (*ProcessBundleDescriptor) GetPcollections ¶
func (m *ProcessBundleDescriptor) GetPcollections() map[string]*pipeline_v1.PCollection
func (*ProcessBundleDescriptor) GetStateApiServiceDescriptor ¶
func (m *ProcessBundleDescriptor) GetStateApiServiceDescriptor() *pipeline_v1.ApiServiceDescriptor
func (*ProcessBundleDescriptor) GetTransforms ¶
func (m *ProcessBundleDescriptor) GetTransforms() map[string]*pipeline_v1.PTransform
func (*ProcessBundleDescriptor) GetWindowingStrategies ¶
func (m *ProcessBundleDescriptor) GetWindowingStrategies() map[string]*pipeline_v1.WindowingStrategy
func (*ProcessBundleDescriptor) ProtoMessage ¶
func (*ProcessBundleDescriptor) ProtoMessage()
func (*ProcessBundleDescriptor) Reset ¶
func (m *ProcessBundleDescriptor) Reset()
func (*ProcessBundleDescriptor) String ¶
func (m *ProcessBundleDescriptor) String() string
func (*ProcessBundleDescriptor) XXX_DiscardUnknown ¶
func (m *ProcessBundleDescriptor) XXX_DiscardUnknown()
func (*ProcessBundleDescriptor) XXX_Marshal ¶
func (m *ProcessBundleDescriptor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessBundleDescriptor) XXX_Merge ¶
func (dst *ProcessBundleDescriptor) XXX_Merge(src proto.Message)
func (*ProcessBundleDescriptor) XXX_Size ¶
func (m *ProcessBundleDescriptor) XXX_Size() int
func (*ProcessBundleDescriptor) XXX_Unmarshal ¶
func (m *ProcessBundleDescriptor) XXX_Unmarshal(b []byte) error
type ProcessBundleProgressRequest ¶
type ProcessBundleProgressRequest struct { // (Required) A reference to an active process bundle request with the given // instruction id. InstructionReference string `protobuf:"bytes,1,opt,name=instruction_reference,json=instructionReference,proto3" json:"instruction_reference,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A request to report progress information for a given bundle. This is an optional request to be handled and is used to support advanced SDK features such as SplittableDoFn, user level metrics etc.
func (*ProcessBundleProgressRequest) Descriptor ¶
func (*ProcessBundleProgressRequest) Descriptor() ([]byte, []int)
func (*ProcessBundleProgressRequest) GetInstructionReference ¶
func (m *ProcessBundleProgressRequest) GetInstructionReference() string
func (*ProcessBundleProgressRequest) ProtoMessage ¶
func (*ProcessBundleProgressRequest) ProtoMessage()
func (*ProcessBundleProgressRequest) Reset ¶
func (m *ProcessBundleProgressRequest) Reset()
func (*ProcessBundleProgressRequest) String ¶
func (m *ProcessBundleProgressRequest) String() string
func (*ProcessBundleProgressRequest) XXX_DiscardUnknown ¶
func (m *ProcessBundleProgressRequest) XXX_DiscardUnknown()
func (*ProcessBundleProgressRequest) XXX_Marshal ¶
func (m *ProcessBundleProgressRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessBundleProgressRequest) XXX_Merge ¶
func (dst *ProcessBundleProgressRequest) XXX_Merge(src proto.Message)
func (*ProcessBundleProgressRequest) XXX_Size ¶
func (m *ProcessBundleProgressRequest) XXX_Size() int
func (*ProcessBundleProgressRequest) XXX_Unmarshal ¶
func (m *ProcessBundleProgressRequest) XXX_Unmarshal(b []byte) error
type ProcessBundleProgressResponse ¶
type ProcessBundleProgressResponse struct { // (Required) Metrics *Metrics `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"` // (Optional) Specifies that the bundle has been split since the last // ProcessBundleProgressResponse was sent. Split *BundleSplit `protobuf:"bytes,2,opt,name=split,proto3" json:"split,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProcessBundleProgressResponse) Descriptor ¶
func (*ProcessBundleProgressResponse) Descriptor() ([]byte, []int)
func (*ProcessBundleProgressResponse) GetMetrics ¶
func (m *ProcessBundleProgressResponse) GetMetrics() *Metrics
func (*ProcessBundleProgressResponse) GetSplit ¶
func (m *ProcessBundleProgressResponse) GetSplit() *BundleSplit
func (*ProcessBundleProgressResponse) ProtoMessage ¶
func (*ProcessBundleProgressResponse) ProtoMessage()
func (*ProcessBundleProgressResponse) Reset ¶
func (m *ProcessBundleProgressResponse) Reset()
func (*ProcessBundleProgressResponse) String ¶
func (m *ProcessBundleProgressResponse) String() string
func (*ProcessBundleProgressResponse) XXX_DiscardUnknown ¶
func (m *ProcessBundleProgressResponse) XXX_DiscardUnknown()
func (*ProcessBundleProgressResponse) XXX_Marshal ¶
func (m *ProcessBundleProgressResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessBundleProgressResponse) XXX_Merge ¶
func (dst *ProcessBundleProgressResponse) XXX_Merge(src proto.Message)
func (*ProcessBundleProgressResponse) XXX_Size ¶
func (m *ProcessBundleProgressResponse) XXX_Size() int
func (*ProcessBundleProgressResponse) XXX_Unmarshal ¶
func (m *ProcessBundleProgressResponse) XXX_Unmarshal(b []byte) error
type ProcessBundleRequest ¶
type ProcessBundleRequest struct { // (Required) A reference to the process bundle descriptor that must be // instantiated and executed by the SDK harness. ProcessBundleDescriptorReference string `` /* 161-byte string literal not displayed */ // (Optional) A list of cache tokens that can be used by an SDK to reuse // cached data returned by the State API across multiple bundles. CacheTokens [][]byte `protobuf:"bytes,2,rep,name=cache_tokens,json=cacheTokens,proto3" json:"cache_tokens,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A request to process a given bundle. Stable
func (*ProcessBundleRequest) Descriptor ¶
func (*ProcessBundleRequest) Descriptor() ([]byte, []int)
func (*ProcessBundleRequest) GetCacheTokens ¶
func (m *ProcessBundleRequest) GetCacheTokens() [][]byte
func (*ProcessBundleRequest) GetProcessBundleDescriptorReference ¶
func (m *ProcessBundleRequest) GetProcessBundleDescriptorReference() string
func (*ProcessBundleRequest) ProtoMessage ¶
func (*ProcessBundleRequest) ProtoMessage()
func (*ProcessBundleRequest) Reset ¶
func (m *ProcessBundleRequest) Reset()
func (*ProcessBundleRequest) String ¶
func (m *ProcessBundleRequest) String() string
func (*ProcessBundleRequest) XXX_DiscardUnknown ¶
func (m *ProcessBundleRequest) XXX_DiscardUnknown()
func (*ProcessBundleRequest) XXX_Marshal ¶
func (m *ProcessBundleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessBundleRequest) XXX_Merge ¶
func (dst *ProcessBundleRequest) XXX_Merge(src proto.Message)
func (*ProcessBundleRequest) XXX_Size ¶
func (m *ProcessBundleRequest) XXX_Size() int
func (*ProcessBundleRequest) XXX_Unmarshal ¶
func (m *ProcessBundleRequest) XXX_Unmarshal(b []byte) error
type ProcessBundleResponse ¶
type ProcessBundleResponse struct { // (Optional) If metrics reporting is supported by the SDK, this represents // the final metrics to record for this bundle. Metrics *Metrics `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"` // (Optional) Specifies that the bundle has been split since the last // ProcessBundleProgressResponse was sent. Split *BundleSplit `protobuf:"bytes,2,opt,name=split,proto3" json:"split,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Stable
func (*ProcessBundleResponse) Descriptor ¶
func (*ProcessBundleResponse) Descriptor() ([]byte, []int)
func (*ProcessBundleResponse) GetMetrics ¶
func (m *ProcessBundleResponse) GetMetrics() *Metrics
func (*ProcessBundleResponse) GetSplit ¶
func (m *ProcessBundleResponse) GetSplit() *BundleSplit
func (*ProcessBundleResponse) ProtoMessage ¶
func (*ProcessBundleResponse) ProtoMessage()
func (*ProcessBundleResponse) Reset ¶
func (m *ProcessBundleResponse) Reset()
func (*ProcessBundleResponse) String ¶
func (m *ProcessBundleResponse) String() string
func (*ProcessBundleResponse) XXX_DiscardUnknown ¶
func (m *ProcessBundleResponse) XXX_DiscardUnknown()
func (*ProcessBundleResponse) XXX_Marshal ¶
func (m *ProcessBundleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessBundleResponse) XXX_Merge ¶
func (dst *ProcessBundleResponse) XXX_Merge(src proto.Message)
func (*ProcessBundleResponse) XXX_Size ¶
func (m *ProcessBundleResponse) XXX_Size() int
func (*ProcessBundleResponse) XXX_Unmarshal ¶
func (m *ProcessBundleResponse) XXX_Unmarshal(b []byte) error
type ProcessBundleSplitRequest ¶
type ProcessBundleSplitRequest struct { // (Required) A reference to an active process bundle request with the given // instruction id. InstructionReference string `protobuf:"bytes,1,opt,name=instruction_reference,json=instructionReference,proto3" json:"instruction_reference,omitempty"` // Specifies that the runner would like the bundle to split itself using // BundleSplit, and give up some of the work that the bundle hasn't started // doing yet, so that it can be done in a separate bundle (perhaps in // parallel with the current bundle). // // The value is the fraction of unstarted work to keep. E.g. 0 means give up // as much as possible of unstarted work (e.g. checkpoint), 0.5 means give // up about half of the unstarted work, etc. // This is a hint and the value is approximate. // // The value is relative to the current scope of work of the bundle. FractionOfRemainder *wrappers.DoubleValue `protobuf:"bytes,2,opt,name=fraction_of_remainder,json=fractionOfRemainder,proto3" json:"fraction_of_remainder,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProcessBundleSplitRequest) Descriptor ¶
func (*ProcessBundleSplitRequest) Descriptor() ([]byte, []int)
func (*ProcessBundleSplitRequest) GetFractionOfRemainder ¶
func (m *ProcessBundleSplitRequest) GetFractionOfRemainder() *wrappers.DoubleValue
func (*ProcessBundleSplitRequest) GetInstructionReference ¶
func (m *ProcessBundleSplitRequest) GetInstructionReference() string
func (*ProcessBundleSplitRequest) ProtoMessage ¶
func (*ProcessBundleSplitRequest) ProtoMessage()
func (*ProcessBundleSplitRequest) Reset ¶
func (m *ProcessBundleSplitRequest) Reset()
func (*ProcessBundleSplitRequest) String ¶
func (m *ProcessBundleSplitRequest) String() string
func (*ProcessBundleSplitRequest) XXX_DiscardUnknown ¶
func (m *ProcessBundleSplitRequest) XXX_DiscardUnknown()
func (*ProcessBundleSplitRequest) XXX_Marshal ¶
func (m *ProcessBundleSplitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessBundleSplitRequest) XXX_Merge ¶
func (dst *ProcessBundleSplitRequest) XXX_Merge(src proto.Message)
func (*ProcessBundleSplitRequest) XXX_Size ¶
func (m *ProcessBundleSplitRequest) XXX_Size() int
func (*ProcessBundleSplitRequest) XXX_Unmarshal ¶
func (m *ProcessBundleSplitRequest) XXX_Unmarshal(b []byte) error
type ProcessBundleSplitResponse ¶
type ProcessBundleSplitResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProcessBundleSplitResponse) Descriptor ¶
func (*ProcessBundleSplitResponse) Descriptor() ([]byte, []int)
func (*ProcessBundleSplitResponse) ProtoMessage ¶
func (*ProcessBundleSplitResponse) ProtoMessage()
func (*ProcessBundleSplitResponse) Reset ¶
func (m *ProcessBundleSplitResponse) Reset()
func (*ProcessBundleSplitResponse) String ¶
func (m *ProcessBundleSplitResponse) String() string
func (*ProcessBundleSplitResponse) XXX_DiscardUnknown ¶
func (m *ProcessBundleSplitResponse) XXX_DiscardUnknown()
func (*ProcessBundleSplitResponse) XXX_Marshal ¶
func (m *ProcessBundleSplitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessBundleSplitResponse) XXX_Merge ¶
func (dst *ProcessBundleSplitResponse) XXX_Merge(src proto.Message)
func (*ProcessBundleSplitResponse) XXX_Size ¶
func (m *ProcessBundleSplitResponse) XXX_Size() int
func (*ProcessBundleSplitResponse) XXX_Unmarshal ¶
func (m *ProcessBundleSplitResponse) XXX_Unmarshal(b []byte) error
type ProvisionInfo ¶
type ProvisionInfo struct { // (required) The job ID. JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"` // (required) The job name. JobName string `protobuf:"bytes,2,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"` // (required) The worker ID. Often this will be the hostname. // // This is independent of the id passed to the SDK harness via the 'id' // argument in the Beam container contract. WorkerId string `protobuf:"bytes,5,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"` // (required) Pipeline options. For non-template jobs, the options are // identical to what is passed to job submission. PipelineOptions *_struct.Struct `protobuf:"bytes,3,opt,name=pipeline_options,json=pipelineOptions,proto3" json:"pipeline_options,omitempty"` // (optional) Resource limits that the SDK harness worker should respect. // Runners may -- but are not required to -- enforce any limits provided. ResourceLimits *Resources `protobuf:"bytes,4,opt,name=resource_limits,json=resourceLimits,proto3" json:"resource_limits,omitempty"` // (required) The artifact retrieval token produced by // ArtifactStagingService.CommitManifestResponse. RetrievalToken string `protobuf:"bytes,6,opt,name=retrieval_token,json=retrievalToken,proto3" json:"retrieval_token,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Runtime provisioning information for a SDK harness worker instance, such as pipeline options, resource constraints and other job metadata
func (*ProvisionInfo) Descriptor ¶
func (*ProvisionInfo) Descriptor() ([]byte, []int)
func (*ProvisionInfo) GetJobId ¶
func (m *ProvisionInfo) GetJobId() string
func (*ProvisionInfo) GetJobName ¶
func (m *ProvisionInfo) GetJobName() string
func (*ProvisionInfo) GetPipelineOptions ¶
func (m *ProvisionInfo) GetPipelineOptions() *_struct.Struct
func (*ProvisionInfo) GetResourceLimits ¶
func (m *ProvisionInfo) GetResourceLimits() *Resources
func (*ProvisionInfo) GetRetrievalToken ¶
func (m *ProvisionInfo) GetRetrievalToken() string
func (*ProvisionInfo) GetWorkerId ¶
func (m *ProvisionInfo) GetWorkerId() string
func (*ProvisionInfo) ProtoMessage ¶
func (*ProvisionInfo) ProtoMessage()
func (*ProvisionInfo) Reset ¶
func (m *ProvisionInfo) Reset()
func (*ProvisionInfo) String ¶
func (m *ProvisionInfo) String() string
func (*ProvisionInfo) XXX_DiscardUnknown ¶
func (m *ProvisionInfo) XXX_DiscardUnknown()
func (*ProvisionInfo) XXX_Marshal ¶
func (m *ProvisionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProvisionInfo) XXX_Merge ¶
func (dst *ProvisionInfo) XXX_Merge(src proto.Message)
func (*ProvisionInfo) XXX_Size ¶
func (m *ProvisionInfo) XXX_Size() int
func (*ProvisionInfo) XXX_Unmarshal ¶
func (m *ProvisionInfo) XXX_Unmarshal(b []byte) error
type ProvisionServiceClient ¶
type ProvisionServiceClient interface { // Get provision information for the SDK harness worker instance. GetProvisionInfo(ctx context.Context, in *GetProvisionInfoRequest, opts ...grpc.CallOption) (*GetProvisionInfoResponse, error) }
ProvisionServiceClient is the client API for ProvisionService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewProvisionServiceClient ¶
func NewProvisionServiceClient(cc *grpc.ClientConn) ProvisionServiceClient
type ProvisionServiceServer ¶
type ProvisionServiceServer interface { // Get provision information for the SDK harness worker instance. GetProvisionInfo(context.Context, *GetProvisionInfoRequest) (*GetProvisionInfoResponse, error) }
ProvisionServiceServer is the server API for ProvisionService service.
type RegisterRequest ¶
type RegisterRequest struct { // (Optional) The set of descriptors used to process bundles. ProcessBundleDescriptor []*ProcessBundleDescriptor `` /* 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 (dst *RegisterRequest) XXX_Merge(src proto.Message)
func (*RegisterRequest) XXX_Size ¶
func (m *RegisterRequest) XXX_Size() int
func (*RegisterRequest) XXX_Unmarshal ¶
func (m *RegisterRequest) XXX_Unmarshal(b []byte) error
type RegisterResponse ¶
type RegisterResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Stable
func (*RegisterResponse) Descriptor ¶
func (*RegisterResponse) Descriptor() ([]byte, []int)
func (*RegisterResponse) ProtoMessage ¶
func (*RegisterResponse) ProtoMessage()
func (*RegisterResponse) Reset ¶
func (m *RegisterResponse) Reset()
func (*RegisterResponse) String ¶
func (m *RegisterResponse) String() string
func (*RegisterResponse) XXX_DiscardUnknown ¶
func (m *RegisterResponse) XXX_DiscardUnknown()
func (*RegisterResponse) XXX_Marshal ¶
func (m *RegisterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RegisterResponse) XXX_Merge ¶
func (dst *RegisterResponse) XXX_Merge(src proto.Message)
func (*RegisterResponse) XXX_Size ¶
func (m *RegisterResponse) XXX_Size() int
func (*RegisterResponse) XXX_Unmarshal ¶
func (m *RegisterResponse) XXX_Unmarshal(b []byte) error
type RemoteGrpcPort ¶
type RemoteGrpcPort struct { // (Required) An API descriptor which describes where to // connect to including any authentication that is required. ApiServiceDescriptor *pipeline_v1.ApiServiceDescriptor `protobuf:"bytes,1,opt,name=api_service_descriptor,json=apiServiceDescriptor,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 (dst *RemoteGrpcPort) XXX_Merge(src proto.Message)
func (*RemoteGrpcPort) XXX_Size ¶
func (m *RemoteGrpcPort) XXX_Size() int
func (*RemoteGrpcPort) XXX_Unmarshal ¶
func (m *RemoteGrpcPort) XXX_Unmarshal(b []byte) error
type Resources ¶
type Resources struct { // (optional) Memory usage limits. SDKs can use this value to configure // internal buffer sizes and language specific sizes. Memory *Resources_Memory `protobuf:"bytes,1,opt,name=memory,proto3" json:"memory,omitempty"` // (optional) CPU usage limits. Cpu *Resources_Cpu `protobuf:"bytes,2,opt,name=cpu,proto3" json:"cpu,omitempty"` // (optional) Disk size limits for the semi-persistent location. SemiPersistentDisk *Resources_Disk `protobuf:"bytes,3,opt,name=semi_persistent_disk,json=semiPersistentDisk,proto3" json:"semi_persistent_disk,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Resources specify limits for local resources, such memory and cpu. It is used to inform SDK harnesses of their allocated footprint.
func (*Resources) Descriptor ¶
func (*Resources) GetCpu ¶
func (m *Resources) GetCpu() *Resources_Cpu
func (*Resources) GetMemory ¶
func (m *Resources) GetMemory() *Resources_Memory
func (*Resources) GetSemiPersistentDisk ¶
func (m *Resources) GetSemiPersistentDisk() *Resources_Disk
func (*Resources) ProtoMessage ¶
func (*Resources) ProtoMessage()
func (*Resources) XXX_DiscardUnknown ¶
func (m *Resources) XXX_DiscardUnknown()
func (*Resources) XXX_Marshal ¶
func (*Resources) XXX_Unmarshal ¶
type Resources_Cpu ¶
type Resources_Cpu struct { // (optional) Shares of a cpu to use. Fractional values, such as "0.2" // or "2.5", are fine. Any value <= 0 means unspecified. XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
CPU limits.
func (*Resources_Cpu) Descriptor ¶
func (*Resources_Cpu) Descriptor() ([]byte, []int)
func (*Resources_Cpu) GetShares ¶
func (m *Resources_Cpu) GetShares() float32
func (*Resources_Cpu) ProtoMessage ¶
func (*Resources_Cpu) ProtoMessage()
func (*Resources_Cpu) Reset ¶
func (m *Resources_Cpu) Reset()
func (*Resources_Cpu) String ¶
func (m *Resources_Cpu) String() string
func (*Resources_Cpu) XXX_DiscardUnknown ¶
func (m *Resources_Cpu) XXX_DiscardUnknown()
func (*Resources_Cpu) XXX_Marshal ¶
func (m *Resources_Cpu) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Resources_Cpu) XXX_Merge ¶
func (dst *Resources_Cpu) XXX_Merge(src proto.Message)
func (*Resources_Cpu) XXX_Size ¶
func (m *Resources_Cpu) XXX_Size() int
func (*Resources_Cpu) XXX_Unmarshal ¶
func (m *Resources_Cpu) XXX_Unmarshal(b []byte) error
type Resources_Disk ¶
type Resources_Disk struct { // (optional) Hard limit in bytes. A zero value means unspecified. Size uint64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Disk limits.
func (*Resources_Disk) Descriptor ¶
func (*Resources_Disk) Descriptor() ([]byte, []int)
func (*Resources_Disk) GetSize ¶
func (m *Resources_Disk) GetSize() uint64
func (*Resources_Disk) ProtoMessage ¶
func (*Resources_Disk) ProtoMessage()
func (*Resources_Disk) Reset ¶
func (m *Resources_Disk) Reset()
func (*Resources_Disk) String ¶
func (m *Resources_Disk) String() string
func (*Resources_Disk) XXX_DiscardUnknown ¶
func (m *Resources_Disk) XXX_DiscardUnknown()