Documentation ¶
Index ¶
- Variables
- func RegisterTimeseriesServer(s grpc.ServiceRegistrar, srv TimeseriesServer)
- type CompletionEventDescriptor
- func (*CompletionEventDescriptor) Descriptor() ([]byte, []int)deprecated
- func (x *CompletionEventDescriptor) GetAttrMatchers() map[string]string
- func (*CompletionEventDescriptor) ProtoMessage()
- func (x *CompletionEventDescriptor) ProtoReflect() protoreflect.Message
- func (x *CompletionEventDescriptor) Reset()
- func (x *CompletionEventDescriptor) String() string
- type Event
- func (*Event) Descriptor() ([]byte, []int)deprecated
- func (x *Event) GetAttributes() map[string]string
- func (x *Event) GetData() []byte
- func (x *Event) GetVHiveMetadata() *VHiveMetadata
- func (*Event) ProtoMessage()
- func (x *Event) ProtoReflect() protoreflect.Message
- func (x *Event) Reset()
- func (x *Event) String() string
- type EventRecord
- func (*EventRecord) Descriptor() ([]byte, []int)deprecated
- func (x *EventRecord) GetEvent() *Event
- func (x *EventRecord) GetIsCompletion() bool
- func (x *EventRecord) GetRecordedOn() *timestamp.Timestamp
- func (*EventRecord) ProtoMessage()
- func (x *EventRecord) ProtoReflect() protoreflect.Message
- func (x *EventRecord) Reset()
- func (x *EventRecord) String() string
- type ExperimentDefinition
- func (*ExperimentDefinition) Descriptor() ([]byte, []int)deprecated
- func (x *ExperimentDefinition) GetWorkflowDefinitions() map[string]*WorkflowDefinition
- func (*ExperimentDefinition) ProtoMessage()
- func (x *ExperimentDefinition) ProtoReflect() protoreflect.Message
- func (x *ExperimentDefinition) Reset()
- func (x *ExperimentDefinition) String() string
- type ExperimentResult
- func (*ExperimentResult) Descriptor() ([]byte, []int)deprecated
- func (x *ExperimentResult) GetWorkflowResults() map[string]*WorkflowResult
- func (*ExperimentResult) ProtoMessage()
- func (x *ExperimentResult) ProtoReflect() protoreflect.Message
- func (x *ExperimentResult) Reset()
- func (x *ExperimentResult) String() string
- type InvocationDescriptor
- func (*InvocationDescriptor) Descriptor() ([]byte, []int)deprecated
- func (x *InvocationDescriptor) GetDuration() *duration.Duration
- func (x *InvocationDescriptor) GetEventRecords() []*EventRecord
- func (x *InvocationDescriptor) GetId() string
- func (x *InvocationDescriptor) GetInvokedOn() *timestamp.Timestamp
- func (x *InvocationDescriptor) GetStatus() InvocationStatus
- func (*InvocationDescriptor) ProtoMessage()
- func (x *InvocationDescriptor) ProtoReflect() protoreflect.Message
- func (x *InvocationDescriptor) Reset()
- func (x *InvocationDescriptor) String() string
- type InvocationStatus
- func (InvocationStatus) Descriptor() protoreflect.EnumDescriptor
- func (x InvocationStatus) Enum() *InvocationStatus
- func (InvocationStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x InvocationStatus) Number() protoreflect.EnumNumber
- func (x InvocationStatus) String() string
- func (InvocationStatus) Type() protoreflect.EnumType
- type TimeseriesClient
- type TimeseriesServer
- type UnimplementedTimeseriesServer
- type UnsafeTimeseriesServer
- type VHiveMetadata
- func (*VHiveMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *VHiveMetadata) GetInvocationId() string
- func (x *VHiveMetadata) GetInvokedOn() *timestamp.Timestamp
- func (x *VHiveMetadata) GetWorkflowId() string
- func (*VHiveMetadata) ProtoMessage()
- func (x *VHiveMetadata) ProtoReflect() protoreflect.Message
- func (x *VHiveMetadata) Reset()
- func (x *VHiveMetadata) String() string
- type WorkflowDefinition
- func (*WorkflowDefinition) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowDefinition) GetCompletionEventDescriptors() []*CompletionEventDescriptor
- func (x *WorkflowDefinition) GetId() string
- func (*WorkflowDefinition) ProtoMessage()
- func (x *WorkflowDefinition) ProtoReflect() protoreflect.Message
- func (x *WorkflowDefinition) Reset()
- func (x *WorkflowDefinition) String() string
- type WorkflowResult
- func (*WorkflowResult) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowResult) GetInvocations() []*InvocationDescriptor
- func (*WorkflowResult) ProtoMessage()
- func (x *WorkflowResult) ProtoReflect() protoreflect.Message
- func (x *WorkflowResult) Reset()
- func (x *WorkflowResult) String() string
Constants ¶
This section is empty.
Variables ¶
var ( InvocationStatus_name = map[int32]string{ 0: "NULL", 1: "COMPLETED", 2: "CANCELLED", } InvocationStatus_value = map[string]int32{ "NULL": 0, "COMPLETED": 1, "CANCELLED": 2, } )
Enum value maps for InvocationStatus.
var File_timeseries_proto protoreflect.FileDescriptor
var Timeseries_ServiceDesc = grpc.ServiceDesc{ ServiceName: "Timeseries", HandlerType: (*TimeseriesServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "StartExperiment", Handler: _Timeseries_StartExperiment_Handler, }, { MethodName: "EndExperiment", Handler: _Timeseries_EndExperiment_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "timeseries.proto", }
Timeseries_ServiceDesc is the grpc.ServiceDesc for Timeseries service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterTimeseriesServer ¶
func RegisterTimeseriesServer(s grpc.ServiceRegistrar, srv TimeseriesServer)
Types ¶
type CompletionEventDescriptor ¶
type CompletionEventDescriptor struct { // attrMatchers is a mapping from CloudEvent attribute names to their // values. A given CloudEvent is deemed a *completion event* iff all // the entries in the map match. // EXAMPLE: // attrMatchers: { // "source": "/us-east-1.aws.amazon.com/easelab/worker-1", // "type" : "com.amazon.aws.ec2.monitoring.iops", // } AttrMatchers map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*CompletionEventDescriptor) Descriptor
deprecated
func (*CompletionEventDescriptor) Descriptor() ([]byte, []int)
Deprecated: Use CompletionEventDescriptor.ProtoReflect.Descriptor instead.
func (*CompletionEventDescriptor) GetAttrMatchers ¶
func (x *CompletionEventDescriptor) GetAttrMatchers() map[string]string
func (*CompletionEventDescriptor) ProtoMessage ¶
func (*CompletionEventDescriptor) ProtoMessage()
func (*CompletionEventDescriptor) ProtoReflect ¶
func (x *CompletionEventDescriptor) ProtoReflect() protoreflect.Message
func (*CompletionEventDescriptor) Reset ¶
func (x *CompletionEventDescriptor) Reset()
func (*CompletionEventDescriptor) String ¶
func (x *CompletionEventDescriptor) String() string
type Event ¶
type Event struct { VHiveMetadata *VHiveMetadata `protobuf:"bytes,1,opt,name=vHiveMetadata,proto3" json:"vHiveMetadata,omitempty"` // extensions is the mapping of extension attribute names to their values. Attributes map[string]string `` /* 161-byte string literal not displayed */ // data is the main payload of the CloudEvent. Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*Event) Descriptor
deprecated
func (*Event) GetAttributes ¶
func (*Event) GetVHiveMetadata ¶
func (x *Event) GetVHiveMetadata() *VHiveMetadata
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
type EventRecord ¶
type EventRecord struct { // event that is recorded. Event *Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"` // recordedOn is the record timestamp. RecordedOn *timestamp.Timestamp `protobuf:"bytes,2,opt,name=recordedOn,proto3" json:"recordedOn,omitempty"` // isCompletion indicates whether the event was a completion event or not. IsCompletion bool `protobuf:"varint,3,opt,name=isCompletion,proto3" json:"isCompletion,omitempty"` // contains filtered or unexported fields }
func (*EventRecord) Descriptor
deprecated
func (*EventRecord) Descriptor() ([]byte, []int)
Deprecated: Use EventRecord.ProtoReflect.Descriptor instead.
func (*EventRecord) GetEvent ¶
func (x *EventRecord) GetEvent() *Event
func (*EventRecord) GetIsCompletion ¶
func (x *EventRecord) GetIsCompletion() bool
func (*EventRecord) GetRecordedOn ¶
func (x *EventRecord) GetRecordedOn() *timestamp.Timestamp
func (*EventRecord) ProtoMessage ¶
func (*EventRecord) ProtoMessage()
func (*EventRecord) ProtoReflect ¶
func (x *EventRecord) ProtoReflect() protoreflect.Message
func (*EventRecord) Reset ¶
func (x *EventRecord) Reset()
func (*EventRecord) String ¶
func (x *EventRecord) String() string
type ExperimentDefinition ¶
type ExperimentDefinition struct { WorkflowDefinitions map[string]*WorkflowDefinition `` /* 179-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ExperimentDefinition) Descriptor
deprecated
func (*ExperimentDefinition) Descriptor() ([]byte, []int)
Deprecated: Use ExperimentDefinition.ProtoReflect.Descriptor instead.
func (*ExperimentDefinition) GetWorkflowDefinitions ¶
func (x *ExperimentDefinition) GetWorkflowDefinitions() map[string]*WorkflowDefinition
func (*ExperimentDefinition) ProtoMessage ¶
func (*ExperimentDefinition) ProtoMessage()
func (*ExperimentDefinition) ProtoReflect ¶
func (x *ExperimentDefinition) ProtoReflect() protoreflect.Message
func (*ExperimentDefinition) Reset ¶
func (x *ExperimentDefinition) Reset()
func (*ExperimentDefinition) String ¶
func (x *ExperimentDefinition) String() string
type ExperimentResult ¶
type ExperimentResult struct { // invocations is the list of invocations in the experiment. WorkflowResults map[string]*WorkflowResult `` /* 171-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ExperimentResult) Descriptor
deprecated
func (*ExperimentResult) Descriptor() ([]byte, []int)
Deprecated: Use ExperimentResult.ProtoReflect.Descriptor instead.
func (*ExperimentResult) GetWorkflowResults ¶
func (x *ExperimentResult) GetWorkflowResults() map[string]*WorkflowResult
func (*ExperimentResult) ProtoMessage ¶
func (*ExperimentResult) ProtoMessage()
func (*ExperimentResult) ProtoReflect ¶
func (x *ExperimentResult) ProtoReflect() protoreflect.Message
func (*ExperimentResult) Reset ¶
func (x *ExperimentResult) Reset()
func (*ExperimentResult) String ¶
func (x *ExperimentResult) String() string
type InvocationDescriptor ¶
type InvocationDescriptor struct { // id of the invocation. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // invokedOn is the timestamp of the starting request to the producer. InvokedOn *timestamp.Timestamp `protobuf:"bytes,2,opt,name=invokedOn,proto3" json:"invokedOn,omitempty"` // duration of the invocation, calculated as: // MAX{completion event arrivals} - invokedOn Duration *duration.Duration `protobuf:"bytes,3,opt,name=duration,proto3" json:"duration,omitempty"` // eventRecords is the list of recorded events with some recording metadata. EventRecords []*EventRecord `protobuf:"bytes,4,rep,name=eventRecords,proto3" json:"eventRecords,omitempty"` // status of the invocation. Status InvocationStatus `protobuf:"varint,5,opt,name=status,proto3,enum=InvocationStatus" json:"status,omitempty"` // contains filtered or unexported fields }
func (*InvocationDescriptor) Descriptor
deprecated
func (*InvocationDescriptor) Descriptor() ([]byte, []int)
Deprecated: Use InvocationDescriptor.ProtoReflect.Descriptor instead.
func (*InvocationDescriptor) GetDuration ¶
func (x *InvocationDescriptor) GetDuration() *duration.Duration
func (*InvocationDescriptor) GetEventRecords ¶
func (x *InvocationDescriptor) GetEventRecords() []*EventRecord
func (*InvocationDescriptor) GetId ¶
func (x *InvocationDescriptor) GetId() string
func (*InvocationDescriptor) GetInvokedOn ¶
func (x *InvocationDescriptor) GetInvokedOn() *timestamp.Timestamp
func (*InvocationDescriptor) GetStatus ¶
func (x *InvocationDescriptor) GetStatus() InvocationStatus
func (*InvocationDescriptor) ProtoMessage ¶
func (*InvocationDescriptor) ProtoMessage()
func (*InvocationDescriptor) ProtoReflect ¶
func (x *InvocationDescriptor) ProtoReflect() protoreflect.Message
func (*InvocationDescriptor) Reset ¶
func (x *InvocationDescriptor) Reset()
func (*InvocationDescriptor) String ¶
func (x *InvocationDescriptor) String() string
type InvocationStatus ¶
type InvocationStatus int32
const ( // Status has not been set. InvocationStatus_NULL InvocationStatus = 0 // All the expected completion events have been received on time. InvocationStatus_COMPLETED InvocationStatus = 1 // The experiment has been cancelled manually by the user. InvocationStatus_CANCELLED InvocationStatus = 2 )
func (InvocationStatus) Descriptor ¶
func (InvocationStatus) Descriptor() protoreflect.EnumDescriptor
func (InvocationStatus) Enum ¶
func (x InvocationStatus) Enum() *InvocationStatus
func (InvocationStatus) EnumDescriptor
deprecated
func (InvocationStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use InvocationStatus.Descriptor instead.
func (InvocationStatus) Number ¶
func (x InvocationStatus) Number() protoreflect.EnumNumber
func (InvocationStatus) String ¶
func (x InvocationStatus) String() string
func (InvocationStatus) Type ¶
func (InvocationStatus) Type() protoreflect.EnumType
type TimeseriesClient ¶
type TimeseriesClient interface { // Invoker methods // ============== StartExperiment(ctx context.Context, in *ExperimentDefinition, opts ...grpc.CallOption) (*empty.Empty, error) EndExperiment(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ExperimentResult, error) }
TimeseriesClient is the client API for Timeseries service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewTimeseriesClient ¶
func NewTimeseriesClient(cc grpc.ClientConnInterface) TimeseriesClient
type TimeseriesServer ¶
type TimeseriesServer interface { // Invoker methods // ============== StartExperiment(context.Context, *ExperimentDefinition) (*empty.Empty, error) EndExperiment(context.Context, *empty.Empty) (*ExperimentResult, error) // contains filtered or unexported methods }
TimeseriesServer is the server API for Timeseries service. All implementations must embed UnimplementedTimeseriesServer for forward compatibility
type UnimplementedTimeseriesServer ¶
type UnimplementedTimeseriesServer struct { }
UnimplementedTimeseriesServer must be embedded to have forward compatible implementations.
func (UnimplementedTimeseriesServer) EndExperiment ¶
func (UnimplementedTimeseriesServer) EndExperiment(context.Context, *empty.Empty) (*ExperimentResult, error)
func (UnimplementedTimeseriesServer) StartExperiment ¶
func (UnimplementedTimeseriesServer) StartExperiment(context.Context, *ExperimentDefinition) (*empty.Empty, error)
type UnsafeTimeseriesServer ¶
type UnsafeTimeseriesServer interface {
// contains filtered or unexported methods
}
UnsafeTimeseriesServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TimeseriesServer will result in compilation errors.
type VHiveMetadata ¶
type VHiveMetadata struct { // id of the workflow. WorkflowId string `protobuf:"bytes,1,opt,name=workflowId,proto3" json:"workflowId,omitempty"` // id of the invocation. InvocationId string `protobuf:"bytes,2,opt,name=invocationId,proto3" json:"invocationId,omitempty"` // invokedOn is the timestamp of the starting request to the producer. InvokedOn *timestamp.Timestamp `protobuf:"bytes,3,opt,name=invokedOn,proto3" json:"invokedOn,omitempty"` // contains filtered or unexported fields }
func (*VHiveMetadata) Descriptor
deprecated
func (*VHiveMetadata) Descriptor() ([]byte, []int)
Deprecated: Use VHiveMetadata.ProtoReflect.Descriptor instead.
func (*VHiveMetadata) GetInvocationId ¶
func (x *VHiveMetadata) GetInvocationId() string
func (*VHiveMetadata) GetInvokedOn ¶
func (x *VHiveMetadata) GetInvokedOn() *timestamp.Timestamp
func (*VHiveMetadata) GetWorkflowId ¶
func (x *VHiveMetadata) GetWorkflowId() string
func (*VHiveMetadata) ProtoMessage ¶
func (*VHiveMetadata) ProtoMessage()
func (*VHiveMetadata) ProtoReflect ¶
func (x *VHiveMetadata) ProtoReflect() protoreflect.Message
func (*VHiveMetadata) Reset ¶
func (x *VHiveMetadata) Reset()
func (*VHiveMetadata) String ¶
func (x *VHiveMetadata) String() string
type WorkflowDefinition ¶
type WorkflowDefinition struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // completionEventDescriptors is the list of descriptors for identifying // completion events. CompletionEventDescriptors []*CompletionEventDescriptor `protobuf:"bytes,2,rep,name=completionEventDescriptors,proto3" json:"completionEventDescriptors,omitempty"` // contains filtered or unexported fields }
func (*WorkflowDefinition) Descriptor
deprecated
func (*WorkflowDefinition) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowDefinition.ProtoReflect.Descriptor instead.
func (*WorkflowDefinition) GetCompletionEventDescriptors ¶
func (x *WorkflowDefinition) GetCompletionEventDescriptors() []*CompletionEventDescriptor
func (*WorkflowDefinition) GetId ¶
func (x *WorkflowDefinition) GetId() string
func (*WorkflowDefinition) ProtoMessage ¶
func (*WorkflowDefinition) ProtoMessage()
func (*WorkflowDefinition) ProtoReflect ¶
func (x *WorkflowDefinition) ProtoReflect() protoreflect.Message
func (*WorkflowDefinition) Reset ¶
func (x *WorkflowDefinition) Reset()
func (*WorkflowDefinition) String ¶
func (x *WorkflowDefinition) String() string
type WorkflowResult ¶
type WorkflowResult struct { // invocations is the list of invocations in the experiment. Invocations []*InvocationDescriptor `protobuf:"bytes,1,rep,name=invocations,proto3" json:"invocations,omitempty"` // contains filtered or unexported fields }
func (*WorkflowResult) Descriptor
deprecated
func (*WorkflowResult) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowResult.ProtoReflect.Descriptor instead.
func (*WorkflowResult) GetInvocations ¶
func (x *WorkflowResult) GetInvocations() []*InvocationDescriptor
func (*WorkflowResult) ProtoMessage ¶
func (*WorkflowResult) ProtoMessage()
func (*WorkflowResult) ProtoReflect ¶
func (x *WorkflowResult) ProtoReflect() protoreflect.Message
func (*WorkflowResult) Reset ¶
func (x *WorkflowResult) Reset()
func (*WorkflowResult) String ¶
func (x *WorkflowResult) String() string