Documentation ¶
Index ¶
- Variables
- type ActivateComponentReply
- type ActivateComponentRequest
- func (*ActivateComponentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ActivateComponentRequest) GetComponent() string
- func (x *ActivateComponentRequest) GetRouted() bool
- func (*ActivateComponentRequest) ProtoMessage()
- func (x *ActivateComponentRequest) ProtoReflect() protoreflect.Message
- func (x *ActivateComponentRequest) Reset()
- func (x *ActivateComponentRequest) String() string
- type AppConfig
- func (*AppConfig) Descriptor() ([]byte, []int)deprecated
- func (x *AppConfig) GetArgs() []string
- func (x *AppConfig) GetBinary() string
- func (x *AppConfig) GetColocate() []*ComponentGroup
- func (x *AppConfig) GetEnv() []string
- func (x *AppConfig) GetName() string
- func (x *AppConfig) GetRolloutNanos() int64
- func (x *AppConfig) GetSections() map[string]string
- func (*AppConfig) ProtoMessage()
- func (x *AppConfig) ProtoReflect() protoreflect.Message
- func (x *AppConfig) Reset()
- func (x *AppConfig) String() string
- type Assignment
- func (*Assignment) Descriptor() ([]byte, []int)deprecated
- func (x *Assignment) GetSlices() []*Assignment_Slice
- func (x *Assignment) GetVersion() uint64
- func (*Assignment) ProtoMessage()
- func (x *Assignment) ProtoReflect() protoreflect.Message
- func (x *Assignment) Reset()
- func (x *Assignment) String() string
- type Assignment_Slice
- func (*Assignment_Slice) Descriptor() ([]byte, []int)deprecated
- func (x *Assignment_Slice) GetReplicas() []string
- func (x *Assignment_Slice) GetStart() uint64
- func (*Assignment_Slice) ProtoMessage()
- func (x *Assignment_Slice) ProtoReflect() protoreflect.Message
- func (x *Assignment_Slice) Reset()
- func (x *Assignment_Slice) String() string
- type ComponentGroup
- type Deployment
- func (*Deployment) Descriptor() ([]byte, []int)deprecated
- func (x *Deployment) GetApp() *AppConfig
- func (x *Deployment) GetId() string
- func (x *Deployment) GetSingleProcess() bool
- func (*Deployment) ProtoMessage()
- func (x *Deployment) ProtoReflect() protoreflect.Message
- func (x *Deployment) Reset()
- func (x *Deployment) String() string
- type ExportListenerReply
- func (*ExportListenerReply) Descriptor() ([]byte, []int)deprecated
- func (x *ExportListenerReply) GetError() string
- func (x *ExportListenerReply) GetProxyAddress() string
- func (*ExportListenerReply) ProtoMessage()
- func (x *ExportListenerReply) ProtoReflect() protoreflect.Message
- func (x *ExportListenerReply) Reset()
- func (x *ExportListenerReply) String() string
- type ExportListenerRequest
- func (*ExportListenerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExportListenerRequest) GetAddress() string
- func (x *ExportListenerRequest) GetListener() string
- func (*ExportListenerRequest) ProtoMessage()
- func (x *ExportListenerRequest) ProtoReflect() protoreflect.Message
- func (x *ExportListenerRequest) Reset()
- func (x *ExportListenerRequest) String() string
- type GetAntipodeAgentInfoReply
- func (*GetAntipodeAgentInfoReply) Descriptor() ([]byte, []int)deprecated
- func (x *GetAntipodeAgentInfoReply) GetDatastore() string
- func (x *GetAntipodeAgentInfoReply) GetDatastoreType() string
- func (x *GetAntipodeAgentInfoReply) GetHost() string
- func (x *GetAntipodeAgentInfoReply) GetPassword() string
- func (x *GetAntipodeAgentInfoReply) GetPort() string
- func (x *GetAntipodeAgentInfoReply) GetQueue() string
- func (x *GetAntipodeAgentInfoReply) GetUser() string
- func (*GetAntipodeAgentInfoReply) ProtoMessage()
- func (x *GetAntipodeAgentInfoReply) ProtoReflect() protoreflect.Message
- func (x *GetAntipodeAgentInfoReply) Reset()
- func (x *GetAntipodeAgentInfoReply) String() string
- type GetAntipodeAgentInfoRequest
- func (*GetAntipodeAgentInfoRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetAntipodeAgentInfoRequest) GetName() string
- func (*GetAntipodeAgentInfoRequest) ProtoMessage()
- func (x *GetAntipodeAgentInfoRequest) ProtoReflect() protoreflect.Message
- func (x *GetAntipodeAgentInfoRequest) Reset()
- func (x *GetAntipodeAgentInfoRequest) String() string
- type GetHealthReply
- type GetHealthRequest
- type GetListenerAddressReply
- func (*GetListenerAddressReply) Descriptor() ([]byte, []int)deprecated
- func (x *GetListenerAddressReply) GetAddress() string
- func (*GetListenerAddressReply) ProtoMessage()
- func (x *GetListenerAddressReply) ProtoReflect() protoreflect.Message
- func (x *GetListenerAddressReply) Reset()
- func (x *GetListenerAddressReply) String() string
- type GetListenerAddressRequest
- func (*GetListenerAddressRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetListenerAddressRequest) GetName() string
- func (*GetListenerAddressRequest) ProtoMessage()
- func (x *GetListenerAddressRequest) ProtoReflect() protoreflect.Message
- func (x *GetListenerAddressRequest) Reset()
- func (x *GetListenerAddressRequest) String() string
- type GetLoadReply
- type GetLoadRequest
- type GetMetricsReply
- type GetMetricsRequest
- type GetProfileReply
- type GetProfileRequest
- func (*GetProfileRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetProfileRequest) GetCpuDurationNs() int64
- func (x *GetProfileRequest) GetProfileType() ProfileType
- func (*GetProfileRequest) ProtoMessage()
- func (x *GetProfileRequest) ProtoReflect() protoreflect.Message
- func (x *GetProfileRequest) Reset()
- func (x *GetProfileRequest) String() string
- type GetSelfCertificateReply
- func (*GetSelfCertificateReply) Descriptor() ([]byte, []int)deprecated
- func (x *GetSelfCertificateReply) GetCert() []byte
- func (x *GetSelfCertificateReply) GetKey() []byte
- func (*GetSelfCertificateReply) ProtoMessage()
- func (x *GetSelfCertificateReply) ProtoReflect() protoreflect.Message
- func (x *GetSelfCertificateReply) Reset()
- func (x *GetSelfCertificateReply) String() string
- type GetSelfCertificateRequest
- type HealthStatus
- func (HealthStatus) Descriptor() protoreflect.EnumDescriptor
- func (x HealthStatus) Enum() *HealthStatus
- func (HealthStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x HealthStatus) Number() protoreflect.EnumNumber
- func (x HealthStatus) String() string
- func (HealthStatus) Type() protoreflect.EnumType
- type InitWeaveletReply
- func (*InitWeaveletReply) Descriptor() ([]byte, []int)deprecated
- func (x *InitWeaveletReply) GetDialAddr() string
- func (x *InitWeaveletReply) GetVersion() *SemVer
- func (*InitWeaveletReply) ProtoMessage()
- func (x *InitWeaveletReply) ProtoReflect() protoreflect.Message
- func (x *InitWeaveletReply) Reset()
- func (x *InitWeaveletReply) String() string
- type InitWeaveletRequest
- func (*InitWeaveletRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InitWeaveletRequest) GetSections() map[string]string
- func (*InitWeaveletRequest) ProtoMessage()
- func (x *InitWeaveletRequest) ProtoReflect() protoreflect.Message
- func (x *InitWeaveletRequest) Reset()
- func (x *InitWeaveletRequest) String() string
- type LoadReport
- type LoadReport_ComponentLoad
- func (*LoadReport_ComponentLoad) Descriptor() ([]byte, []int)deprecated
- func (x *LoadReport_ComponentLoad) GetLoad() []*LoadReport_SliceLoad
- func (x *LoadReport_ComponentLoad) GetVersion() uint64
- func (*LoadReport_ComponentLoad) ProtoMessage()
- func (x *LoadReport_ComponentLoad) ProtoReflect() protoreflect.Message
- func (x *LoadReport_ComponentLoad) Reset()
- func (x *LoadReport_ComponentLoad) String() string
- type LoadReport_SliceLoad
- func (*LoadReport_SliceLoad) Descriptor() ([]byte, []int)deprecated
- func (x *LoadReport_SliceLoad) GetEnd() uint64
- func (x *LoadReport_SliceLoad) GetLoad() float64
- func (x *LoadReport_SliceLoad) GetSize() uint64
- func (x *LoadReport_SliceLoad) GetSplits() []*LoadReport_SubsliceLoad
- func (x *LoadReport_SliceLoad) GetStart() uint64
- func (*LoadReport_SliceLoad) ProtoMessage()
- func (x *LoadReport_SliceLoad) ProtoReflect() protoreflect.Message
- func (x *LoadReport_SliceLoad) Reset()
- func (x *LoadReport_SliceLoad) String() string
- type LoadReport_SubsliceLoad
- func (*LoadReport_SubsliceLoad) Descriptor() ([]byte, []int)deprecated
- func (x *LoadReport_SubsliceLoad) GetLoad() float64
- func (x *LoadReport_SubsliceLoad) GetStart() uint64
- func (*LoadReport_SubsliceLoad) ProtoMessage()
- func (x *LoadReport_SubsliceLoad) ProtoReflect() protoreflect.Message
- func (x *LoadReport_SubsliceLoad) Reset()
- func (x *LoadReport_SubsliceLoad) String() string
- type LogEntry
- func (*LogEntry) Descriptor() ([]byte, []int)deprecated
- func (x *LogEntry) GetApp() string
- func (x *LogEntry) GetAttrs() []string
- func (x *LogEntry) GetComponent() string
- func (x *LogEntry) GetFile() string
- func (x *LogEntry) GetLevel() string
- func (x *LogEntry) GetLine() int32
- func (x *LogEntry) GetMsg() string
- func (x *LogEntry) GetNode() string
- func (x *LogEntry) GetTimeMicros() int64
- func (x *LogEntry) GetVersion() string
- func (*LogEntry) ProtoMessage()
- func (x *LogEntry) ProtoReflect() protoreflect.Message
- func (x *LogEntry) Reset()
- func (x *LogEntry) String() string
- type LogEntryBatch
- type MetricDef
- func (*MetricDef) Descriptor() ([]byte, []int)deprecated
- func (x *MetricDef) GetBounds() []float64
- func (x *MetricDef) GetHelp() string
- func (x *MetricDef) GetId() uint64
- func (x *MetricDef) GetLabels() map[string]string
- func (x *MetricDef) GetName() string
- func (x *MetricDef) GetTyp() MetricType
- func (*MetricDef) ProtoMessage()
- func (x *MetricDef) ProtoReflect() protoreflect.Message
- func (x *MetricDef) Reset()
- func (x *MetricDef) String() string
- type MetricSnapshot
- func (*MetricSnapshot) Descriptor() ([]byte, []int)deprecated
- func (x *MetricSnapshot) GetBounds() []float64
- func (x *MetricSnapshot) GetCounts() []uint64
- func (x *MetricSnapshot) GetHelp() string
- func (x *MetricSnapshot) GetId() uint64
- func (x *MetricSnapshot) GetLabels() map[string]string
- func (x *MetricSnapshot) GetName() string
- func (x *MetricSnapshot) GetTyp() MetricType
- func (x *MetricSnapshot) GetValue() float64
- func (*MetricSnapshot) ProtoMessage()
- func (x *MetricSnapshot) ProtoReflect() protoreflect.Message
- func (x *MetricSnapshot) Reset()
- func (x *MetricSnapshot) String() string
- type MetricType
- type MetricUpdate
- func (*MetricUpdate) Descriptor() ([]byte, []int)deprecated
- func (x *MetricUpdate) GetDefs() []*MetricDef
- func (x *MetricUpdate) GetValues() []*MetricValue
- func (*MetricUpdate) ProtoMessage()
- func (x *MetricUpdate) ProtoReflect() protoreflect.Message
- func (x *MetricUpdate) Reset()
- func (x *MetricUpdate) String() string
- type MetricValue
- func (*MetricValue) Descriptor() ([]byte, []int)deprecated
- func (x *MetricValue) GetCounts() []uint64
- func (x *MetricValue) GetId() uint64
- func (x *MetricValue) GetValue() float64
- func (*MetricValue) ProtoMessage()
- func (x *MetricValue) ProtoReflect() protoreflect.Message
- func (x *MetricValue) Reset()
- func (x *MetricValue) String() string
- type ProfileType
- func (ProfileType) Descriptor() protoreflect.EnumDescriptor
- func (x ProfileType) Enum() *ProfileType
- func (ProfileType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ProfileType) Number() protoreflect.EnumNumber
- func (x ProfileType) String() string
- func (ProfileType) Type() protoreflect.EnumType
- type RoutingInfo
- func (*RoutingInfo) Descriptor() ([]byte, []int)deprecated
- func (x *RoutingInfo) GetAssignment() *Assignment
- func (x *RoutingInfo) GetComponent() string
- func (x *RoutingInfo) GetLocal() bool
- func (x *RoutingInfo) GetReplicas() []string
- func (*RoutingInfo) ProtoMessage()
- func (x *RoutingInfo) ProtoReflect() protoreflect.Message
- func (x *RoutingInfo) Reset()
- func (x *RoutingInfo) String() string
- type SemVer
- type Span
- func (*Span) Descriptor() ([]byte, []int)deprecated
- func (x *Span) GetAttributes() []*Span_Attribute
- func (x *Span) GetChildSpanCount() int64
- func (x *Span) GetDroppedAttributeCount() int64
- func (x *Span) GetDroppedEventCount() int64
- func (x *Span) GetDroppedLinkCount() int64
- func (x *Span) GetEndMicros() int64
- func (x *Span) GetEvents() []*Span_Event
- func (x *Span) GetKind() Span_Kind
- func (x *Span) GetLibrary() *Span_Library
- func (x *Span) GetLinks() []*Span_Link
- func (x *Span) GetName() string
- func (x *Span) GetParentSpanId() []byte
- func (x *Span) GetResource() *Span_Resource
- func (x *Span) GetScope() *Span_Scope
- func (x *Span) GetSpanId() []byte
- func (x *Span) GetStartMicros() int64
- func (x *Span) GetStatus() *Span_Status
- func (x *Span) GetTraceId() []byte
- func (*Span) ProtoMessage()
- func (x *Span) ProtoReflect() protoreflect.Message
- func (x *Span) Reset()
- func (x *Span) String() string
- type Span_Attribute
- func (*Span_Attribute) Descriptor() ([]byte, []int)deprecated
- func (x *Span_Attribute) GetKey() string
- func (x *Span_Attribute) GetValue() *Span_Attribute_Value
- func (*Span_Attribute) ProtoMessage()
- func (x *Span_Attribute) ProtoReflect() protoreflect.Message
- func (x *Span_Attribute) Reset()
- func (x *Span_Attribute) String() string
- type Span_Attribute_Value
- func (*Span_Attribute_Value) Descriptor() ([]byte, []int)deprecated
- func (x *Span_Attribute_Value) GetNum() uint64
- func (x *Span_Attribute_Value) GetNums() *Span_Attribute_Value_NumberList
- func (x *Span_Attribute_Value) GetStr() string
- func (x *Span_Attribute_Value) GetStrs() *Span_Attribute_Value_StringList
- func (x *Span_Attribute_Value) GetType() Span_Attribute_Value_Type
- func (m *Span_Attribute_Value) GetValue() isSpan_Attribute_Value_Value
- func (*Span_Attribute_Value) ProtoMessage()
- func (x *Span_Attribute_Value) ProtoReflect() protoreflect.Message
- func (x *Span_Attribute_Value) Reset()
- func (x *Span_Attribute_Value) String() string
- type Span_Attribute_Value_Num
- type Span_Attribute_Value_NumberList
- func (*Span_Attribute_Value_NumberList) Descriptor() ([]byte, []int)deprecated
- func (x *Span_Attribute_Value_NumberList) GetNums() []uint64
- func (*Span_Attribute_Value_NumberList) ProtoMessage()
- func (x *Span_Attribute_Value_NumberList) ProtoReflect() protoreflect.Message
- func (x *Span_Attribute_Value_NumberList) Reset()
- func (x *Span_Attribute_Value_NumberList) String() string
- type Span_Attribute_Value_Nums
- type Span_Attribute_Value_Str
- type Span_Attribute_Value_StringList
- func (*Span_Attribute_Value_StringList) Descriptor() ([]byte, []int)deprecated
- func (x *Span_Attribute_Value_StringList) GetStrs() []string
- func (*Span_Attribute_Value_StringList) ProtoMessage()
- func (x *Span_Attribute_Value_StringList) ProtoReflect() protoreflect.Message
- func (x *Span_Attribute_Value_StringList) Reset()
- func (x *Span_Attribute_Value_StringList) String() string
- type Span_Attribute_Value_Strs
- type Span_Attribute_Value_Type
- func (Span_Attribute_Value_Type) Descriptor() protoreflect.EnumDescriptor
- func (x Span_Attribute_Value_Type) Enum() *Span_Attribute_Value_Type
- func (Span_Attribute_Value_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x Span_Attribute_Value_Type) Number() protoreflect.EnumNumber
- func (x Span_Attribute_Value_Type) String() string
- func (Span_Attribute_Value_Type) Type() protoreflect.EnumType
- type Span_Event
- func (*Span_Event) Descriptor() ([]byte, []int)deprecated
- func (x *Span_Event) GetAttributes() []*Span_Attribute
- func (x *Span_Event) GetDroppedAttributeCount() int64
- func (x *Span_Event) GetName() string
- func (x *Span_Event) GetTimeMicros() int64
- func (*Span_Event) ProtoMessage()
- func (x *Span_Event) ProtoReflect() protoreflect.Message
- func (x *Span_Event) Reset()
- func (x *Span_Event) String() string
- type Span_Kind
- type Span_Library
- func (*Span_Library) Descriptor() ([]byte, []int)deprecated
- func (x *Span_Library) GetName() string
- func (x *Span_Library) GetSchemaUrl() string
- func (x *Span_Library) GetVersion() string
- func (*Span_Library) ProtoMessage()
- func (x *Span_Library) ProtoReflect() protoreflect.Message
- func (x *Span_Library) Reset()
- func (x *Span_Library) String() string
- type Span_Link
- func (*Span_Link) Descriptor() ([]byte, []int)deprecated
- func (x *Span_Link) GetAttributes() []*Span_Attribute
- func (x *Span_Link) GetDroppedAttributeCount() int64
- func (x *Span_Link) GetSpanId() []byte
- func (x *Span_Link) GetTraceId() []byte
- func (*Span_Link) ProtoMessage()
- func (x *Span_Link) ProtoReflect() protoreflect.Message
- func (x *Span_Link) Reset()
- func (x *Span_Link) String() string
- type Span_Resource
- func (*Span_Resource) Descriptor() ([]byte, []int)deprecated
- func (x *Span_Resource) GetAttributes() []*Span_Attribute
- func (x *Span_Resource) GetSchemaUrl() string
- func (*Span_Resource) ProtoMessage()
- func (x *Span_Resource) ProtoReflect() protoreflect.Message
- func (x *Span_Resource) Reset()
- func (x *Span_Resource) String() string
- type Span_Scope
- func (*Span_Scope) Descriptor() ([]byte, []int)deprecated
- func (x *Span_Scope) GetName() string
- func (x *Span_Scope) GetSchemaUrl() string
- func (x *Span_Scope) GetVersion() string
- func (*Span_Scope) ProtoMessage()
- func (x *Span_Scope) ProtoReflect() protoreflect.Message
- func (x *Span_Scope) Reset()
- func (x *Span_Scope) String() string
- type Span_Status
- func (*Span_Status) Descriptor() ([]byte, []int)deprecated
- func (x *Span_Status) GetCode() Span_Status_Code
- func (x *Span_Status) GetError() string
- func (*Span_Status) ProtoMessage()
- func (x *Span_Status) ProtoReflect() protoreflect.Message
- func (x *Span_Status) Reset()
- func (x *Span_Status) String() string
- type Span_Status_Code
- func (Span_Status_Code) Descriptor() protoreflect.EnumDescriptor
- func (x Span_Status_Code) Enum() *Span_Status_Code
- func (Span_Status_Code) EnumDescriptor() ([]byte, []int)deprecated
- func (x Span_Status_Code) Number() protoreflect.EnumNumber
- func (x Span_Status_Code) String() string
- func (Span_Status_Code) Type() protoreflect.EnumType
- type TraceSpans
- type UpdateComponentsReply
- type UpdateComponentsRequest
- func (*UpdateComponentsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateComponentsRequest) GetComponents() []string
- func (*UpdateComponentsRequest) ProtoMessage()
- func (x *UpdateComponentsRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateComponentsRequest) Reset()
- func (x *UpdateComponentsRequest) String() string
- type UpdateRoutingInfoReply
- type UpdateRoutingInfoRequest
- func (*UpdateRoutingInfoRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateRoutingInfoRequest) GetRoutingInfo() *RoutingInfo
- func (*UpdateRoutingInfoRequest) ProtoMessage()
- func (x *UpdateRoutingInfoRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateRoutingInfoRequest) Reset()
- func (x *UpdateRoutingInfoRequest) String() string
- type VerifyClientCertificateReply
- func (*VerifyClientCertificateReply) Descriptor() ([]byte, []int)deprecated
- func (x *VerifyClientCertificateReply) GetComponents() []string
- func (*VerifyClientCertificateReply) ProtoMessage()
- func (x *VerifyClientCertificateReply) ProtoReflect() protoreflect.Message
- func (x *VerifyClientCertificateReply) Reset()
- func (x *VerifyClientCertificateReply) String() string
- type VerifyClientCertificateRequest
- func (*VerifyClientCertificateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *VerifyClientCertificateRequest) GetCertChain() [][]byte
- func (*VerifyClientCertificateRequest) ProtoMessage()
- func (x *VerifyClientCertificateRequest) ProtoReflect() protoreflect.Message
- func (x *VerifyClientCertificateRequest) Reset()
- func (x *VerifyClientCertificateRequest) String() string
- type VerifyServerCertificateReply
- func (*VerifyServerCertificateReply) Descriptor() ([]byte, []int)deprecated
- func (*VerifyServerCertificateReply) ProtoMessage()
- func (x *VerifyServerCertificateReply) ProtoReflect() protoreflect.Message
- func (x *VerifyServerCertificateReply) Reset()
- func (x *VerifyServerCertificateReply) String() string
- type VerifyServerCertificateRequest
- func (*VerifyServerCertificateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *VerifyServerCertificateRequest) GetCertChain() [][]byte
- func (x *VerifyServerCertificateRequest) GetTargetComponent() string
- func (*VerifyServerCertificateRequest) ProtoMessage()
- func (x *VerifyServerCertificateRequest) ProtoReflect() protoreflect.Message
- func (x *VerifyServerCertificateRequest) Reset()
- func (x *VerifyServerCertificateRequest) String() string
- type WeaveletArgs
- func (*WeaveletArgs) Descriptor() ([]byte, []int)deprecated
- func (x *WeaveletArgs) GetApp() string
- func (x *WeaveletArgs) GetControlSocket() string
- func (x *WeaveletArgs) GetDeploymentId() string
- func (x *WeaveletArgs) GetId() string
- func (x *WeaveletArgs) GetInternalAddress() string
- func (x *WeaveletArgs) GetMtls() bool
- func (x *WeaveletArgs) GetRedirects() []*WeaveletArgs_Redirect
- func (x *WeaveletArgs) GetRunMain() bool
- func (*WeaveletArgs) ProtoMessage()
- func (x *WeaveletArgs) ProtoReflect() protoreflect.Message
- func (x *WeaveletArgs) Reset()
- func (x *WeaveletArgs) String() string
- type WeaveletArgs_Redirect
- func (*WeaveletArgs_Redirect) Descriptor() ([]byte, []int)deprecated
- func (x *WeaveletArgs_Redirect) GetAddress() string
- func (x *WeaveletArgs_Redirect) GetComponent() string
- func (x *WeaveletArgs_Redirect) GetTarget() string
- func (*WeaveletArgs_Redirect) ProtoMessage()
- func (x *WeaveletArgs_Redirect) ProtoReflect() protoreflect.Message
- func (x *WeaveletArgs_Redirect) Reset()
- func (x *WeaveletArgs_Redirect) String() string
Constants ¶
This section is empty.
Variables ¶
var ( HealthStatus_name = map[int32]string{ 0: "UNKNOWN", 1: "HEALTHY", 2: "UNHEALTHY", 3: "TERMINATED", } HealthStatus_value = map[string]int32{ "UNKNOWN": 0, "HEALTHY": 1, "UNHEALTHY": 2, "TERMINATED": 3, } )
Enum value maps for HealthStatus.
var ( MetricType_name = map[int32]string{ 0: "INVALID", 1: "COUNTER", 2: "GAUGE", 3: "HISTOGRAM", } MetricType_value = map[string]int32{ "INVALID": 0, "COUNTER": 1, "GAUGE": 2, "HISTOGRAM": 3, } )
Enum value maps for MetricType.
var ( ProfileType_name = map[int32]string{ 0: "Unspecified", 1: "Heap", 2: "CPU", } ProfileType_value = map[string]int32{ "Unspecified": 0, "Heap": 1, "CPU": 2, } )
Enum value maps for ProfileType.
var ( Span_Kind_name = map[int32]string{ 0: "UNSPECIFIED", 1: "INTERNAL", 2: "SERVER", 3: "CLIENT", 4: "PRODUCER", 5: "CONSUMER", } Span_Kind_value = map[string]int32{ "UNSPECIFIED": 0, "INTERNAL": 1, "SERVER": 2, "CLIENT": 3, "PRODUCER": 4, "CONSUMER": 5, } )
Enum value maps for Span_Kind.
var ( Span_Attribute_Value_Type_name = map[int32]string{ 0: "INVALID", 1: "BOOL", 2: "INT64", 3: "FLOAT64", 4: "STRING", 5: "BOOLLIST", 6: "INT64LIST", 7: "FLOAT64LIST", 8: "STRINGLIST", } Span_Attribute_Value_Type_value = map[string]int32{ "INVALID": 0, "BOOL": 1, "INT64": 2, "FLOAT64": 3, "STRING": 4, "BOOLLIST": 5, "INT64LIST": 6, "FLOAT64LIST": 7, "STRINGLIST": 8, } )
Enum value maps for Span_Attribute_Value_Type.
var ( Span_Status_Code_name = map[int32]string{ 0: "UNSET", 1: "ERROR", 2: "OK", } Span_Status_Code_value = map[string]int32{ "UNSET": 0, "ERROR": 1, "OK": 2, } )
Enum value maps for Span_Status_Code.
var File_runtime_protos_config_proto protoreflect.FileDescriptor
var File_runtime_protos_runtime_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type ActivateComponentReply ¶
type ActivateComponentReply struct {
// contains filtered or unexported fields
}
ActivateComponentReply is a reply to an ActivateComponentRequest.
func (*ActivateComponentReply) Descriptor
deprecated
func (*ActivateComponentReply) Descriptor() ([]byte, []int)
Deprecated: Use ActivateComponentReply.ProtoReflect.Descriptor instead.
func (*ActivateComponentReply) ProtoMessage ¶
func (*ActivateComponentReply) ProtoMessage()
func (*ActivateComponentReply) ProtoReflect ¶
func (x *ActivateComponentReply) ProtoReflect() protoreflect.Message
func (*ActivateComponentReply) Reset ¶
func (x *ActivateComponentReply) Reset()
func (*ActivateComponentReply) String ¶
func (x *ActivateComponentReply) String() string
type ActivateComponentRequest ¶
type ActivateComponentRequest struct { Component string `protobuf:"bytes,1,opt,name=component,proto3" json:"component,omitempty"` // component name Routed bool `protobuf:"varint,2,opt,name=routed,proto3" json:"routed,omitempty"` // is the component routed? // contains filtered or unexported fields }
ActivateComponentRequest is a request from a weavelet to ensure that the provided component is running somewhere. An ActivateComponentRequest also implicitly signals that a weavelet is interested in receiving routing info for the component via UpdateRoutingInfoRequest.
func (*ActivateComponentRequest) Descriptor
deprecated
func (*ActivateComponentRequest) Descriptor() ([]byte, []int)
Deprecated: Use ActivateComponentRequest.ProtoReflect.Descriptor instead.
func (*ActivateComponentRequest) GetComponent ¶
func (x *ActivateComponentRequest) GetComponent() string
func (*ActivateComponentRequest) GetRouted ¶
func (x *ActivateComponentRequest) GetRouted() bool
func (*ActivateComponentRequest) ProtoMessage ¶
func (*ActivateComponentRequest) ProtoMessage()
func (*ActivateComponentRequest) ProtoReflect ¶
func (x *ActivateComponentRequest) ProtoReflect() protoreflect.Message
func (*ActivateComponentRequest) Reset ¶
func (x *ActivateComponentRequest) Reset()
func (*ActivateComponentRequest) String ¶
func (x *ActivateComponentRequest) String() string
type AppConfig ¶
type AppConfig struct { // Application name (derived from binary if missing). Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // File name of the binary that implements the app. Binary string `protobuf:"bytes,2,opt,name=binary,proto3" json:"binary,omitempty"` // Arguments to pass to the binary. Args []string `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"` // Environment variables available to the binary. Every entry should be of the // form "key=value". If a key appears more than once, only the last value of // the key is used. Env []string `protobuf:"bytes,4,rep,name=env,proto3" json:"env,omitempty"` // Groups of components that must be co-located in the same OS process. // // This grouping allows the developer a level of control on where the Service // Weaver runtime will place each component. For example, suppose that the // application binary contains six components: A, B, C, D, E, and F. // Furthermore, suppose that the developer specifies the following grouping in // the config. // // colocate = [[A, B], [C, D, E]] // // In that case, no matter what algorithm the Service Weaver runtime uses to // place the components, components A and B will always be grouped together, // and components C, D, and E will always be grouped together. This means that // a pair of replicas of the components can share in-memory state and // communicate efficiently with each other (though not with other replicas). // // The placement algorithm the Service Weaver runtime uses varies across // deployment environment. For example, a multiprocess deployer may choose to // place each component into its own group, for maximum parallelism. A // singleprocess deployer, on the other hand, may choose to group all of the // components together. Regardless of which deployment environment is used, // however, this configuration option guarantees that specified components // will end up in the same group. // // Components are identified using their full package paths, e.g.: // // "github.com/my/project/package/ComponentName" // // with the exception of the component associated with the application main(), // which is identified using the name "main". Colocate []*ComponentGroup `protobuf:"bytes,5,rep,name=colocate,proto3" json:"colocate,omitempty"` // A knob that lets the user specifies how many nanoseconds it expects for // the rollout to take. This is used internally by Service Weaver to figure // out the rollout strategy. // // If not specified, Service Weaver will pick a default value. RolloutNanos int64 `protobuf:"varint,6,opt,name=rollout_nanos,json=rolloutNanos,proto3" json:"rollout_nanos,omitempty"` // All config sections (includes [serviceweaver], [<deployer>], and // [<component>] sections). Sections map[string]string `` /* 157-byte string literal not displayed */ // contains filtered or unexported fields }
AppConfig holds configuration for a Service Weaver application.
func (*AppConfig) Descriptor
deprecated
func (*AppConfig) GetColocate ¶
func (x *AppConfig) GetColocate() []*ComponentGroup
func (*AppConfig) GetRolloutNanos ¶
func (*AppConfig) GetSections ¶
func (*AppConfig) ProtoMessage ¶
func (*AppConfig) ProtoMessage()
func (*AppConfig) ProtoReflect ¶
func (x *AppConfig) ProtoReflect() protoreflect.Message
type Assignment ¶
type Assignment struct { Slices []*Assignment_Slice `protobuf:"bytes,1,rep,name=slices,proto3" json:"slices,omitempty"` // The assignment for a component can change over time. Every one of these // assignments is given a monotonically increasing version. Versions are // unique for a given component, but not unique across components. Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
Assignment partitions a key space (e.g., the hash space [0, 2^64)) into a set of subregions, called slices, and assigns each slice to a set of replicas.
func (*Assignment) Descriptor
deprecated
func (*Assignment) Descriptor() ([]byte, []int)
Deprecated: Use Assignment.ProtoReflect.Descriptor instead.
func (*Assignment) GetSlices ¶
func (x *Assignment) GetSlices() []*Assignment_Slice
func (*Assignment) GetVersion ¶
func (x *Assignment) GetVersion() uint64
func (*Assignment) ProtoMessage ¶
func (*Assignment) ProtoMessage()
func (*Assignment) ProtoReflect ¶
func (x *Assignment) ProtoReflect() protoreflect.Message
func (*Assignment) Reset ¶
func (x *Assignment) Reset()
func (*Assignment) String ¶
func (x *Assignment) String() string
type Assignment_Slice ¶
type Assignment_Slice struct { // Inclusive start key. Strictly greater than the `start` value for the // previous entry in the current assignment. // // The first slice should always set start to 0. Start uint64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"` // Replicas assigned to host this slice. Every address is of the form // "<net>://<addr>" (e.g., "tcp://host:1234", "unix:///tmp/unix.sock"). Replicas []string `protobuf:"bytes,2,rep,name=replicas,proto3" json:"replicas,omitempty"` // contains filtered or unexported fields }
A slice of the key space and the replicas to which it is assigned.
func (*Assignment_Slice) Descriptor
deprecated
func (*Assignment_Slice) Descriptor() ([]byte, []int)
Deprecated: Use Assignment_Slice.ProtoReflect.Descriptor instead.
func (*Assignment_Slice) GetReplicas ¶
func (x *Assignment_Slice) GetReplicas() []string
func (*Assignment_Slice) GetStart ¶
func (x *Assignment_Slice) GetStart() uint64
func (*Assignment_Slice) ProtoMessage ¶
func (*Assignment_Slice) ProtoMessage()
func (*Assignment_Slice) ProtoReflect ¶
func (x *Assignment_Slice) ProtoReflect() protoreflect.Message
func (*Assignment_Slice) Reset ¶
func (x *Assignment_Slice) Reset()
func (*Assignment_Slice) String ¶
func (x *Assignment_Slice) String() string
type ComponentGroup ¶
type ComponentGroup struct { Components []string `protobuf:"bytes,1,rep,name=components,proto3" json:"components,omitempty"` // contains filtered or unexported fields }
A group of components.
func (*ComponentGroup) Descriptor
deprecated
func (*ComponentGroup) Descriptor() ([]byte, []int)
Deprecated: Use ComponentGroup.ProtoReflect.Descriptor instead.
func (*ComponentGroup) GetComponents ¶
func (x *ComponentGroup) GetComponents() []string
func (*ComponentGroup) ProtoMessage ¶
func (*ComponentGroup) ProtoMessage()
func (*ComponentGroup) ProtoReflect ¶
func (x *ComponentGroup) ProtoReflect() protoreflect.Message
func (*ComponentGroup) Reset ¶
func (x *ComponentGroup) Reset()
func (*ComponentGroup) String ¶
func (x *ComponentGroup) String() string
type Deployment ¶
type Deployment struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Unique identifier for the deployment. // Application configuration. App *AppConfig `protobuf:"bytes,2,opt,name=app,proto3" json:"app,omitempty"` // Run as a single process locally. SingleProcess bool `protobuf:"varint,10,opt,name=single_process,json=singleProcess,proto3" json:"single_process,omitempty"` // contains filtered or unexported fields }
Deployment holds internal information necessary for an application deployment.
TODO(mwhittaker): Delete this proto.
func (*Deployment) Descriptor
deprecated
func (*Deployment) Descriptor() ([]byte, []int)
Deprecated: Use Deployment.ProtoReflect.Descriptor instead.
func (*Deployment) GetApp ¶
func (x *Deployment) GetApp() *AppConfig
func (*Deployment) GetId ¶
func (x *Deployment) GetId() string
func (*Deployment) GetSingleProcess ¶
func (x *Deployment) GetSingleProcess() bool
func (*Deployment) ProtoMessage ¶
func (*Deployment) ProtoMessage()
func (*Deployment) ProtoReflect ¶
func (x *Deployment) ProtoReflect() protoreflect.Message
func (*Deployment) Reset ¶
func (x *Deployment) Reset()
func (*Deployment) String ¶
func (x *Deployment) String() string
type ExportListenerReply ¶
type ExportListenerReply struct { // The address of the proxy that forwards traffic to the listener, or empty if // there is no proxy. ProxyAddress string `protobuf:"bytes,1,opt,name=proxy_address,json=proxyAddress,proto3" json:"proxy_address,omitempty"` // If non-empty, a non-retriable error. // // TODO(mwhittaker): This field exists as a hack to avoid a weavelet retrying // this error. In the future, we should have a more robust way to avoid // retrying certain errors. Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
ExportListenerReply is a reply to an ExportListenerRequest.
func (*ExportListenerReply) Descriptor
deprecated
func (*ExportListenerReply) Descriptor() ([]byte, []int)
Deprecated: Use ExportListenerReply.ProtoReflect.Descriptor instead.
func (*ExportListenerReply) GetError ¶
func (x *ExportListenerReply) GetError() string
func (*ExportListenerReply) GetProxyAddress ¶
func (x *ExportListenerReply) GetProxyAddress() string
func (*ExportListenerReply) ProtoMessage ¶
func (*ExportListenerReply) ProtoMessage()
func (*ExportListenerReply) ProtoReflect ¶
func (x *ExportListenerReply) ProtoReflect() protoreflect.Message
func (*ExportListenerReply) Reset ¶
func (x *ExportListenerReply) Reset()
func (*ExportListenerReply) String ¶
func (x *ExportListenerReply) String() string
type ExportListenerRequest ¶
type ExportListenerRequest struct { Listener string `protobuf:"bytes,1,opt,name=listener,proto3" json:"listener,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` // contains filtered or unexported fields }
ExportListenerRequest is a request from a weavelet to export the provided listener. Exporting a listener typically, but not always, involves running a proxy that forwards traffic to the provided address.
func (*ExportListenerRequest) Descriptor
deprecated
func (*ExportListenerRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExportListenerRequest.ProtoReflect.Descriptor instead.
func (*ExportListenerRequest) GetAddress ¶
func (x *ExportListenerRequest) GetAddress() string
func (*ExportListenerRequest) GetListener ¶
func (x *ExportListenerRequest) GetListener() string
func (*ExportListenerRequest) ProtoMessage ¶
func (*ExportListenerRequest) ProtoMessage()
func (*ExportListenerRequest) ProtoReflect ¶
func (x *ExportListenerRequest) ProtoReflect() protoreflect.Message
func (*ExportListenerRequest) Reset ¶
func (x *ExportListenerRequest) Reset()
func (*ExportListenerRequest) String ¶
func (x *ExportListenerRequest) String() string
type GetAntipodeAgentInfoReply ¶ added in v0.4.85
type GetAntipodeAgentInfoReply struct { DatastoreType string `protobuf:"bytes,1,opt,name=datastoreType,proto3" json:"datastoreType,omitempty"` // the type of the datastore e.g. "redis" Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"` // the datastore host Port string `protobuf:"bytes,3,opt,name=port,proto3" json:"port,omitempty"` // the datastore port User string `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"` // the datastore user Password string `protobuf:"bytes,5,opt,name=password,proto3" json:"password,omitempty"` // the datastore password Datastore string `protobuf:"bytes,6,opt,name=datastore,proto3" json:"datastore,omitempty"` // the datastore name Queue string `protobuf:"bytes,7,opt,name=queue,proto3" json:"queue,omitempty"` // the datastore queue // contains filtered or unexported fields }
GetAntipodeAgentInfoReply is a reply to a GetAntipodeAgentInfoRequest.
func (*GetAntipodeAgentInfoReply) Descriptor
deprecated
added in
v0.4.85
func (*GetAntipodeAgentInfoReply) Descriptor() ([]byte, []int)
Deprecated: Use GetAntipodeAgentInfoReply.ProtoReflect.Descriptor instead.
func (*GetAntipodeAgentInfoReply) GetDatastore ¶ added in v0.4.85
func (x *GetAntipodeAgentInfoReply) GetDatastore() string
func (*GetAntipodeAgentInfoReply) GetDatastoreType ¶ added in v0.4.85
func (x *GetAntipodeAgentInfoReply) GetDatastoreType() string
func (*GetAntipodeAgentInfoReply) GetHost ¶ added in v0.4.85
func (x *GetAntipodeAgentInfoReply) GetHost() string
func (*GetAntipodeAgentInfoReply) GetPassword ¶ added in v0.4.85
func (x *GetAntipodeAgentInfoReply) GetPassword() string
func (*GetAntipodeAgentInfoReply) GetPort ¶ added in v0.4.85
func (x *GetAntipodeAgentInfoReply) GetPort() string
func (*GetAntipodeAgentInfoReply) GetQueue ¶ added in v0.4.85
func (x *GetAntipodeAgentInfoReply) GetQueue() string
func (*GetAntipodeAgentInfoReply) GetUser ¶ added in v0.4.85
func (x *GetAntipodeAgentInfoReply) GetUser() string
func (*GetAntipodeAgentInfoReply) ProtoMessage ¶ added in v0.4.85
func (*GetAntipodeAgentInfoReply) ProtoMessage()
func (*GetAntipodeAgentInfoReply) ProtoReflect ¶ added in v0.4.85
func (x *GetAntipodeAgentInfoReply) ProtoReflect() protoreflect.Message
func (*GetAntipodeAgentInfoReply) Reset ¶ added in v0.4.85
func (x *GetAntipodeAgentInfoReply) Reset()
func (*GetAntipodeAgentInfoReply) String ¶ added in v0.4.85
func (x *GetAntipodeAgentInfoReply) String() string
type GetAntipodeAgentInfoRequest ¶ added in v0.4.85
type GetAntipodeAgentInfoRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // antipode agent name // contains filtered or unexported fields }
GetAntipodeAgentInfoRequest is a request from a weavelet for the information the weavelet needs to initialize an antipode agent.
func (*GetAntipodeAgentInfoRequest) Descriptor
deprecated
added in
v0.4.85
func (*GetAntipodeAgentInfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetAntipodeAgentInfoRequest.ProtoReflect.Descriptor instead.
func (*GetAntipodeAgentInfoRequest) GetName ¶ added in v0.4.85
func (x *GetAntipodeAgentInfoRequest) GetName() string
func (*GetAntipodeAgentInfoRequest) ProtoMessage ¶ added in v0.4.85
func (*GetAntipodeAgentInfoRequest) ProtoMessage()
func (*GetAntipodeAgentInfoRequest) ProtoReflect ¶ added in v0.4.85
func (x *GetAntipodeAgentInfoRequest) ProtoReflect() protoreflect.Message
func (*GetAntipodeAgentInfoRequest) Reset ¶ added in v0.4.85
func (x *GetAntipodeAgentInfoRequest) Reset()
func (*GetAntipodeAgentInfoRequest) String ¶ added in v0.4.85
func (x *GetAntipodeAgentInfoRequest) String() string
type GetHealthReply ¶
type GetHealthReply struct { Status HealthStatus `protobuf:"varint,1,opt,name=status,proto3,enum=runtime.HealthStatus" json:"status,omitempty"` // contains filtered or unexported fields }
GetHealthReply is a reply to a GetHealthRequest.
func (*GetHealthReply) Descriptor
deprecated
func (*GetHealthReply) Descriptor() ([]byte, []int)
Deprecated: Use GetHealthReply.ProtoReflect.Descriptor instead.
func (*GetHealthReply) GetStatus ¶
func (x *GetHealthReply) GetStatus() HealthStatus
func (*GetHealthReply) ProtoMessage ¶
func (*GetHealthReply) ProtoMessage()
func (*GetHealthReply) ProtoReflect ¶
func (x *GetHealthReply) ProtoReflect() protoreflect.Message
func (*GetHealthReply) Reset ¶
func (x *GetHealthReply) Reset()
func (*GetHealthReply) String ¶
func (x *GetHealthReply) String() string
type GetHealthRequest ¶
type GetHealthRequest struct {
// contains filtered or unexported fields
}
GetHealthRequest is a request from an envelope for a weavelet's health.
func (*GetHealthRequest) Descriptor
deprecated
func (*GetHealthRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetHealthRequest.ProtoReflect.Descriptor instead.
func (*GetHealthRequest) ProtoMessage ¶
func (*GetHealthRequest) ProtoMessage()
func (*GetHealthRequest) ProtoReflect ¶
func (x *GetHealthRequest) ProtoReflect() protoreflect.Message
func (*GetHealthRequest) Reset ¶
func (x *GetHealthRequest) Reset()
func (*GetHealthRequest) String ¶
func (x *GetHealthRequest) String() string
type GetListenerAddressReply ¶
type GetListenerAddressReply struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` // address to listen on // contains filtered or unexported fields }
GetListenerAddressReply is a reply to a GetListenerAddressRequest.
func (*GetListenerAddressReply) Descriptor
deprecated
func (*GetListenerAddressReply) Descriptor() ([]byte, []int)
Deprecated: Use GetListenerAddressReply.ProtoReflect.Descriptor instead.
func (*GetListenerAddressReply) GetAddress ¶
func (x *GetListenerAddressReply) GetAddress() string
func (*GetListenerAddressReply) ProtoMessage ¶
func (*GetListenerAddressReply) ProtoMessage()
func (*GetListenerAddressReply) ProtoReflect ¶
func (x *GetListenerAddressReply) ProtoReflect() protoreflect.Message
func (*GetListenerAddressReply) Reset ¶
func (x *GetListenerAddressReply) Reset()
func (*GetListenerAddressReply) String ¶
func (x *GetListenerAddressReply) String() string
type GetListenerAddressRequest ¶
type GetListenerAddressRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // listener name // contains filtered or unexported fields }
GetListenerAddressRequest is a request from a weavelet for the address the weavelet should listen on for a particular listener.
Imagine a weavelet calls GetListener with LocalAdress localhost:9000. Here are some examples of how different deployers may handle a GetListenerAddressRequest.
- The singleprocess deployer may instruct the weavelet to listen directly on localhost:9000.
- The multiprocess deployer may instruct the weavelet to listen on localhost:0. It will separately start a proxy on localhost:9000.
- The SSH deployer may instruct the weavelet to listen on $HOSTNAME:0. It will separately start a proxy on localhost:9000.
func (*GetListenerAddressRequest) Descriptor
deprecated
func (*GetListenerAddressRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetListenerAddressRequest.ProtoReflect.Descriptor instead.
func (*GetListenerAddressRequest) GetName ¶
func (x *GetListenerAddressRequest) GetName() string
func (*GetListenerAddressRequest) ProtoMessage ¶
func (*GetListenerAddressRequest) ProtoMessage()
func (*GetListenerAddressRequest) ProtoReflect ¶
func (x *GetListenerAddressRequest) ProtoReflect() protoreflect.Message
func (*GetListenerAddressRequest) Reset ¶
func (x *GetListenerAddressRequest) Reset()
func (*GetListenerAddressRequest) String ¶
func (x *GetListenerAddressRequest) String() string
type GetLoadReply ¶
type GetLoadReply struct { Load *LoadReport `protobuf:"bytes,1,opt,name=load,proto3" json:"load,omitempty"` // contains filtered or unexported fields }
GetLoadReply is a reply to a GetLoadRequest.
func (*GetLoadReply) Descriptor
deprecated
func (*GetLoadReply) Descriptor() ([]byte, []int)
Deprecated: Use GetLoadReply.ProtoReflect.Descriptor instead.
func (*GetLoadReply) GetLoad ¶
func (x *GetLoadReply) GetLoad() *LoadReport
func (*GetLoadReply) ProtoMessage ¶
func (*GetLoadReply) ProtoMessage()
func (*GetLoadReply) ProtoReflect ¶
func (x *GetLoadReply) ProtoReflect() protoreflect.Message
func (*GetLoadReply) Reset ¶
func (x *GetLoadReply) Reset()
func (*GetLoadReply) String ¶
func (x *GetLoadReply) String() string
type GetLoadRequest ¶
type GetLoadRequest struct {
// contains filtered or unexported fields
}
GetLoadRequest is a request from an envelope for a weavelet's load report.
func (*GetLoadRequest) Descriptor
deprecated
func (*GetLoadRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetLoadRequest.ProtoReflect.Descriptor instead.
func (*GetLoadRequest) ProtoMessage ¶
func (*GetLoadRequest) ProtoMessage()
func (*GetLoadRequest) ProtoReflect ¶
func (x *GetLoadRequest) ProtoReflect() protoreflect.Message
func (*GetLoadRequest) Reset ¶
func (x *GetLoadRequest) Reset()
func (*GetLoadRequest) String ¶
func (x *GetLoadRequest) String() string
type GetMetricsReply ¶
type GetMetricsReply struct { Update *MetricUpdate `protobuf:"bytes,1,opt,name=update,proto3" json:"update,omitempty"` // contains filtered or unexported fields }
GetMetricsReply is a reply to a GetMetricsRequest. It only contains information about the metrics that have changed since the prior GetMetricsRequest.
func (*GetMetricsReply) Descriptor
deprecated
func (*GetMetricsReply) Descriptor() ([]byte, []int)
Deprecated: Use GetMetricsReply.ProtoReflect.Descriptor instead.
func (*GetMetricsReply) GetUpdate ¶
func (x *GetMetricsReply) GetUpdate() *MetricUpdate
func (*GetMetricsReply) ProtoMessage ¶
func (*GetMetricsReply) ProtoMessage()
func (*GetMetricsReply) ProtoReflect ¶
func (x *GetMetricsReply) ProtoReflect() protoreflect.Message
func (*GetMetricsReply) Reset ¶
func (x *GetMetricsReply) Reset()
func (*GetMetricsReply) String ¶
func (x *GetMetricsReply) String() string
type GetMetricsRequest ¶
type GetMetricsRequest struct {
// contains filtered or unexported fields
}
GetMetricsRequest is a request from an envelope for a weavelet's metrics. There can only be one outstanding GetMetricsRequest at a time.
func (*GetMetricsRequest) Descriptor
deprecated
func (*GetMetricsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetMetricsRequest.ProtoReflect.Descriptor instead.
func (*GetMetricsRequest) ProtoMessage ¶
func (*GetMetricsRequest) ProtoMessage()
func (*GetMetricsRequest) ProtoReflect ¶
func (x *GetMetricsRequest) ProtoReflect() protoreflect.Message
func (*GetMetricsRequest) Reset ¶
func (x *GetMetricsRequest) Reset()
func (*GetMetricsRequest) String ¶
func (x *GetMetricsRequest) String() string
type GetProfileReply ¶
type GetProfileReply struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // encoded profile data // contains filtered or unexported fields }
GetProfileReply is a reply to a GetProfileRequest.
func (*GetProfileReply) Descriptor
deprecated
func (*GetProfileReply) Descriptor() ([]byte, []int)
Deprecated: Use GetProfileReply.ProtoReflect.Descriptor instead.
func (*GetProfileReply) GetData ¶
func (x *GetProfileReply) GetData() []byte
func (*GetProfileReply) ProtoMessage ¶
func (*GetProfileReply) ProtoMessage()
func (*GetProfileReply) ProtoReflect ¶
func (x *GetProfileReply) ProtoReflect() protoreflect.Message
func (*GetProfileReply) Reset ¶
func (x *GetProfileReply) Reset()
func (*GetProfileReply) String ¶
func (x *GetProfileReply) String() string
type GetProfileRequest ¶
type GetProfileRequest struct { // Type of the profile (e.g., heap, cpu). ProfileType ProfileType `protobuf:"varint,1,opt,name=profile_type,json=profileType,proto3,enum=runtime.ProfileType" json:"profile_type,omitempty"` // Duration of CPU profiles, in nanoseconds. CpuDurationNs int64 `protobuf:"varint,2,opt,name=cpu_duration_ns,json=cpuDurationNs,proto3" json:"cpu_duration_ns,omitempty"` // contains filtered or unexported fields }
GetProfileRequest is a request from an envelope for a weavelet to collect and return a profile. Some profile types only support a single profile request at a time and an error will be returned if another profile request is active.
func (*GetProfileRequest) Descriptor
deprecated
func (*GetProfileRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetProfileRequest.ProtoReflect.Descriptor instead.
func (*GetProfileRequest) GetCpuDurationNs ¶
func (x *GetProfileRequest) GetCpuDurationNs() int64
func (*GetProfileRequest) GetProfileType ¶
func (x *GetProfileRequest) GetProfileType() ProfileType
func (*GetProfileRequest) ProtoMessage ¶
func (*GetProfileRequest) ProtoMessage()
func (*GetProfileRequest) ProtoReflect ¶
func (x *GetProfileRequest) ProtoReflect() protoreflect.Message
func (*GetProfileRequest) Reset ¶
func (x *GetProfileRequest) Reset()
func (*GetProfileRequest) String ¶
func (x *GetProfileRequest) String() string
type GetSelfCertificateReply ¶
type GetSelfCertificateReply struct { // PEM-encoded blocks containing (1) the certificate identifying the // weavelet and (2) the corresponding private key. Used for enforcing mTLS // security across components. Cert []byte `protobuf:"bytes,1,opt,name=cert,proto3" json:"cert,omitempty"` // certificate identifying the weavelet Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` // private key corresponding to cert // contains filtered or unexported fields }
GetSelfCertificateReply is a reply to a GetSelfCertificateRequest.
func (*GetSelfCertificateReply) Descriptor
deprecated
func (*GetSelfCertificateReply) Descriptor() ([]byte, []int)
Deprecated: Use GetSelfCertificateReply.ProtoReflect.Descriptor instead.
func (*GetSelfCertificateReply) GetCert ¶
func (x *GetSelfCertificateReply) GetCert() []byte
func (*GetSelfCertificateReply) GetKey ¶
func (x *GetSelfCertificateReply) GetKey() []byte
func (*GetSelfCertificateReply) ProtoMessage ¶
func (*GetSelfCertificateReply) ProtoMessage()
func (*GetSelfCertificateReply) ProtoReflect ¶
func (x *GetSelfCertificateReply) ProtoReflect() protoreflect.Message
func (*GetSelfCertificateReply) Reset ¶
func (x *GetSelfCertificateReply) Reset()
func (*GetSelfCertificateReply) String ¶
func (x *GetSelfCertificateReply) String() string
type GetSelfCertificateRequest ¶
type GetSelfCertificateRequest struct {
// contains filtered or unexported fields
}
GetSelfCertificateRequest is a request from a weavelet for its certificate and the corresponding private key.
func (*GetSelfCertificateRequest) Descriptor
deprecated
func (*GetSelfCertificateRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSelfCertificateRequest.ProtoReflect.Descriptor instead.
func (*GetSelfCertificateRequest) ProtoMessage ¶
func (*GetSelfCertificateRequest) ProtoMessage()
func (*GetSelfCertificateRequest) ProtoReflect ¶
func (x *GetSelfCertificateRequest) ProtoReflect() protoreflect.Message
func (*GetSelfCertificateRequest) Reset ¶
func (x *GetSelfCertificateRequest) Reset()
func (*GetSelfCertificateRequest) String ¶
func (x *GetSelfCertificateRequest) String() string
type HealthStatus ¶
type HealthStatus int32
HealthStatus specifies the health of a weavelet.
const ( HealthStatus_UNKNOWN HealthStatus = 0 HealthStatus_HEALTHY HealthStatus = 1 HealthStatus_UNHEALTHY HealthStatus = 2 HealthStatus_TERMINATED HealthStatus = 3 )
func (HealthStatus) Descriptor ¶
func (HealthStatus) Descriptor() protoreflect.EnumDescriptor
func (HealthStatus) Enum ¶
func (x HealthStatus) Enum() *HealthStatus
func (HealthStatus) EnumDescriptor
deprecated
func (HealthStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use HealthStatus.Descriptor instead.
func (HealthStatus) Number ¶
func (x HealthStatus) Number() protoreflect.EnumNumber
func (HealthStatus) String ¶
func (x HealthStatus) String() string
func (HealthStatus) Type ¶
func (HealthStatus) Type() protoreflect.EnumType
type InitWeaveletReply ¶
type InitWeaveletReply struct { // Internal TCP address of the weavelet. This address will be passed to other // weavelets as part of their RoutingInfo. DialAddr string `protobuf:"bytes,1,opt,name=dial_addr,json=dialAddr,proto3" json:"dial_addr,omitempty"` // The deployer API version of the weavelet. Version *SemVer `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
InitWeaveletReply is the information provided by a weavelet to an envelope during the initial envelope-weavelet handshake.
func (*InitWeaveletReply) Descriptor
deprecated
func (*InitWeaveletReply) Descriptor() ([]byte, []int)
Deprecated: Use InitWeaveletReply.ProtoReflect.Descriptor instead.
func (*InitWeaveletReply) GetDialAddr ¶
func (x *InitWeaveletReply) GetDialAddr() string
func (*InitWeaveletReply) GetVersion ¶
func (x *InitWeaveletReply) GetVersion() *SemVer
func (*InitWeaveletReply) ProtoMessage ¶
func (*InitWeaveletReply) ProtoMessage()
func (*InitWeaveletReply) ProtoReflect ¶
func (x *InitWeaveletReply) ProtoReflect() protoreflect.Message
func (*InitWeaveletReply) Reset ¶
func (x *InitWeaveletReply) Reset()
func (*InitWeaveletReply) String ¶
func (x *InitWeaveletReply) String() string
type InitWeaveletRequest ¶
type InitWeaveletRequest struct { Sections map[string]string `` // See AppConfig.Sections. /* 157-byte string literal not displayed */ // contains filtered or unexported fields }
InitWeaveletRequest holds the initialization info passed to the weavelet by the envelope.
func (*InitWeaveletRequest) Descriptor
deprecated
func (*InitWeaveletRequest) Descriptor() ([]byte, []int)
Deprecated: Use InitWeaveletRequest.ProtoReflect.Descriptor instead.
func (*InitWeaveletRequest) GetSections ¶
func (x *InitWeaveletRequest) GetSections() map[string]string
func (*InitWeaveletRequest) ProtoMessage ¶
func (*InitWeaveletRequest) ProtoMessage()
func (*InitWeaveletRequest) ProtoReflect ¶
func (x *InitWeaveletRequest) ProtoReflect() protoreflect.Message
func (*InitWeaveletRequest) Reset ¶
func (x *InitWeaveletRequest) Reset()
func (*InitWeaveletRequest) String ¶
func (x *InitWeaveletRequest) String() string
type LoadReport ¶
type LoadReport struct { Loads map[string]*LoadReport_ComponentLoad `` // load for routed components /* 151-byte string literal not displayed */ // contains filtered or unexported fields }
LoadReport contains load information for all routed components hosted by a particular weavelet.
func (*LoadReport) Descriptor
deprecated
func (*LoadReport) Descriptor() ([]byte, []int)
Deprecated: Use LoadReport.ProtoReflect.Descriptor instead.
func (*LoadReport) GetLoads ¶
func (x *LoadReport) GetLoads() map[string]*LoadReport_ComponentLoad
func (*LoadReport) ProtoMessage ¶
func (*LoadReport) ProtoMessage()
func (*LoadReport) ProtoReflect ¶
func (x *LoadReport) ProtoReflect() protoreflect.Message
func (*LoadReport) Reset ¶
func (x *LoadReport) Reset()
func (*LoadReport) String ¶
func (x *LoadReport) String() string
type LoadReport_ComponentLoad ¶
type LoadReport_ComponentLoad struct { // TODO(mwhittaker): In full generality, load is a generic // application-specific double-valued measurement (e.g., total number of // requests, size of components in memory). For now to simplify things, we // assume load is measured as requests per second. Load []*LoadReport_SliceLoad `protobuf:"bytes,1,rep,name=load,proto3" json:"load,omitempty"` // TODO(mwhittaker): For now, load is reported with respect to a given // assignment. When the assignment changes, the load is reset. This approach // works for rate-based load like requests per second, but not other // non-rate based load like size of cached components. Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
ComponentLoad includes load information for a component. The component's key space is divided into a number of slices, each of which is associated with a particular double-valued load.
TODO(mwhittaker): In the short term, a weavelet will report one SliceLoad for every slice it is assigned. In the future, however, we may report load in more advanced ways.
func (*LoadReport_ComponentLoad) Descriptor
deprecated
func (*LoadReport_ComponentLoad) Descriptor() ([]byte, []int)
Deprecated: Use LoadReport_ComponentLoad.ProtoReflect.Descriptor instead.
func (*LoadReport_ComponentLoad) GetLoad ¶
func (x *LoadReport_ComponentLoad) GetLoad() []*LoadReport_SliceLoad
func (*LoadReport_ComponentLoad) GetVersion ¶
func (x *LoadReport_ComponentLoad) GetVersion() uint64
func (*LoadReport_ComponentLoad) ProtoMessage ¶
func (*LoadReport_ComponentLoad) ProtoMessage()
func (*LoadReport_ComponentLoad) ProtoReflect ¶
func (x *LoadReport_ComponentLoad) ProtoReflect() protoreflect.Message
func (*LoadReport_ComponentLoad) Reset ¶
func (x *LoadReport_ComponentLoad) Reset()
func (*LoadReport_ComponentLoad) String ¶
func (x *LoadReport_ComponentLoad) String() string
type LoadReport_SliceLoad ¶
type LoadReport_SliceLoad struct { Start uint64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"` // inclusive End uint64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"` // exclusive Load float64 `protobuf:"fixed64,3,opt,name=load,proto3" json:"load,omitempty"` Splits []*LoadReport_SubsliceLoad `protobuf:"bytes,4,rep,name=splits,proto3" json:"splits,omitempty"` // The "size" of the slice. Given a slice [a, b), it's tempting to think // the slice has size b - a. This has a couple of problems. // // 1. Even if a slice is large, only a few keys in the slice may be // used. For example, a weavelet with slice [0, 2^60) may only // receive requests for keys in the range [0, 100). // 2. a and b are not necessarily numeric. Imagine we are performing // range sharding on strings and have the slice ["ccbae", // "hhaefi"). What is the size of this slice? // // We instead measure the "size" of a slice as an estimate of the number // of keys accessed in the slice. For example, if a slice [0, 1000) // receives requests for keys 0, 1, 2, 3, and 10, then the size of the // slice is 5. Size uint64 `protobuf:"varint,5,opt,name=size,proto3" json:"size,omitempty"` // contains filtered or unexported fields }
SliceLoad includes the load of a slice, [start, end).
func (*LoadReport_SliceLoad) Descriptor
deprecated
func (*LoadReport_SliceLoad) Descriptor() ([]byte, []int)
Deprecated: Use LoadReport_SliceLoad.ProtoReflect.Descriptor instead.
func (*LoadReport_SliceLoad) GetEnd ¶
func (x *LoadReport_SliceLoad) GetEnd() uint64
func (*LoadReport_SliceLoad) GetLoad ¶
func (x *LoadReport_SliceLoad) GetLoad() float64
func (*LoadReport_SliceLoad) GetSize ¶
func (x *LoadReport_SliceLoad) GetSize() uint64
func (*LoadReport_SliceLoad) GetSplits ¶
func (x *LoadReport_SliceLoad) GetSplits() []*LoadReport_SubsliceLoad
func (*LoadReport_SliceLoad) GetStart ¶
func (x *LoadReport_SliceLoad) GetStart() uint64
func (*LoadReport_SliceLoad) ProtoMessage ¶
func (*LoadReport_SliceLoad) ProtoMessage()
func (*LoadReport_SliceLoad) ProtoReflect ¶
func (x *LoadReport_SliceLoad) ProtoReflect() protoreflect.Message
func (*LoadReport_SliceLoad) Reset ¶
func (x *LoadReport_SliceLoad) Reset()
func (*LoadReport_SliceLoad) String ¶
func (x *LoadReport_SliceLoad) String() string
type LoadReport_SubsliceLoad ¶
type LoadReport_SubsliceLoad struct { Start uint64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"` Load float64 `protobuf:"fixed64,2,opt,name=load,proto3" json:"load,omitempty"` // contains filtered or unexported fields }
SubsliceLoad divides the load of a slice into smaller subslices. For example, given a slice [0, 100) and load 9.0, we may have the following subslices:
SubsliceLoad{Start: 0, Load: 3.0} // [0, 20) SubsliceLoad{Start: 20, Load: 3.0} // [20, 80) SubsliceLoad{Start: 80, Load: 3.0} // [80, 100)
TODO(mwhittaker): In the future, we likely want to report hot keys as their own slice. Change SubsliceLoad to support that.
func (*LoadReport_SubsliceLoad) Descriptor
deprecated
func (*LoadReport_SubsliceLoad) Descriptor() ([]byte, []int)
Deprecated: Use LoadReport_SubsliceLoad.ProtoReflect.Descriptor instead.
func (*LoadReport_SubsliceLoad) GetLoad ¶
func (x *LoadReport_SubsliceLoad) GetLoad() float64
func (*LoadReport_SubsliceLoad) GetStart ¶
func (x *LoadReport_SubsliceLoad) GetStart() uint64
func (*LoadReport_SubsliceLoad) ProtoMessage ¶
func (*LoadReport_SubsliceLoad) ProtoMessage()
func (*LoadReport_SubsliceLoad) ProtoReflect ¶
func (x *LoadReport_SubsliceLoad) ProtoReflect() protoreflect.Message
func (*LoadReport_SubsliceLoad) Reset ¶
func (x *LoadReport_SubsliceLoad) Reset()
func (*LoadReport_SubsliceLoad) String ¶
func (x *LoadReport_SubsliceLoad) String() string
type LogEntry ¶
type LogEntry struct { App string `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"` // application name Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // deployment id Component string `protobuf:"bytes,3,opt,name=component,proto3" json:"component,omitempty"` // component name Node string `protobuf:"bytes,4,opt,name=node,proto3" json:"node,omitempty"` // weavelet id TimeMicros int64 `protobuf:"fixed64,5,opt,name=time_micros,json=timeMicros,proto3" json:"time_micros,omitempty"` // time when logged (microseconds since epoch) Level string `protobuf:"bytes,6,opt,name=level,proto3" json:"level,omitempty"` // log level (e.g., debug, info, error) File string `protobuf:"bytes,7,opt,name=file,proto3" json:"file,omitempty"` // source file Line int32 `protobuf:"varint,8,opt,name=line,proto3" json:"line,omitempty"` // source line Msg string `protobuf:"bytes,9,opt,name=msg,proto3" json:"msg,omitempty"` // user provided message // User-provided attributes and their associated values. The storage format // is a name followed by its value, i.e.: // // name1, value1, name2, value2, name3, value3, ... Attrs []string `protobuf:"bytes,10,rep,name=attrs,proto3" json:"attrs,omitempty"` // contains filtered or unexported fields }
LogEntry is a log entry. Every log entry consists of a message (the thing the user logged) and a set of metadata describing the message.
func (*LogEntry) Descriptor
deprecated
func (*LogEntry) GetComponent ¶
func (*LogEntry) GetTimeMicros ¶
func (*LogEntry) GetVersion ¶
func (*LogEntry) ProtoMessage ¶
func (*LogEntry) ProtoMessage()
func (*LogEntry) ProtoReflect ¶
func (x *LogEntry) ProtoReflect() protoreflect.Message
type LogEntryBatch ¶
type LogEntryBatch struct { Entries []*LogEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"` // contains filtered or unexported fields }
LogEntryBatch is a list of log entries.
func (*LogEntryBatch) Descriptor
deprecated
func (*LogEntryBatch) Descriptor() ([]byte, []int)
Deprecated: Use LogEntryBatch.ProtoReflect.Descriptor instead.
func (*LogEntryBatch) GetEntries ¶
func (x *LogEntryBatch) GetEntries() []*LogEntry
func (*LogEntryBatch) ProtoMessage ¶
func (*LogEntryBatch) ProtoMessage()
func (*LogEntryBatch) ProtoReflect ¶
func (x *LogEntryBatch) ProtoReflect() protoreflect.Message
func (*LogEntryBatch) Reset ¶
func (x *LogEntryBatch) Reset()
func (*LogEntryBatch) String ¶
func (x *LogEntryBatch) String() string
type MetricDef ¶
type MetricDef struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // metric's unique id Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // name of the metric Typ MetricType `protobuf:"varint,3,opt,name=typ,proto3,enum=runtime.MetricType" json:"typ,omitempty"` // type of metric Help string `protobuf:"bytes,4,opt,name=help,proto3" json:"help,omitempty"` // metric's help message Labels map[string]string `` // metric labels /* 153-byte string literal not displayed */ Bounds []float64 `protobuf:"fixed64,6,rep,packed,name=bounds,proto3" json:"bounds,omitempty"` // histogram bucket bounds // contains filtered or unexported fields }
MetricDef is the definition of a new metric.
func (*MetricDef) Descriptor
deprecated
func (*MetricDef) GetTyp ¶
func (x *MetricDef) GetTyp() MetricType
func (*MetricDef) ProtoMessage ¶
func (*MetricDef) ProtoMessage()
func (*MetricDef) ProtoReflect ¶
func (x *MetricDef) ProtoReflect() protoreflect.Message
type MetricSnapshot ¶
type MetricSnapshot struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // metric's unique id Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // name of the metric Typ MetricType `protobuf:"varint,3,opt,name=typ,proto3,enum=runtime.MetricType" json:"typ,omitempty"` // type of metric Help string `protobuf:"bytes,4,opt,name=help,proto3" json:"help,omitempty"` // metric's help message Labels map[string]string `` // metric labels /* 153-byte string literal not displayed */ Bounds []float64 `protobuf:"fixed64,6,rep,packed,name=bounds,proto3" json:"bounds,omitempty"` // histogram bucket bounds Value float64 `protobuf:"fixed64,7,opt,name=value,proto3" json:"value,omitempty"` // value for counter and gauge, sum for histogram Counts []uint64 `protobuf:"varint,8,rep,packed,name=counts,proto3" json:"counts,omitempty"` // histogram counts // contains filtered or unexported fields }
MetricSnapshot is a snapshot of a metric. It is the union of a MetricDef and a MetricValue.
TODO(mwhittaker): Move out of runtime.proto. It's not used by the pipe.
func (*MetricSnapshot) Descriptor
deprecated
func (*MetricSnapshot) Descriptor() ([]byte, []int)
Deprecated: Use MetricSnapshot.ProtoReflect.Descriptor instead.
func (*MetricSnapshot) GetBounds ¶
func (x *MetricSnapshot) GetBounds() []float64
func (*MetricSnapshot) GetCounts ¶
func (x *MetricSnapshot) GetCounts() []uint64
func (*MetricSnapshot) GetHelp ¶
func (x *MetricSnapshot) GetHelp() string
func (*MetricSnapshot) GetId ¶
func (x *MetricSnapshot) GetId() uint64
func (*MetricSnapshot) GetLabels ¶
func (x *MetricSnapshot) GetLabels() map[string]string
func (*MetricSnapshot) GetName ¶
func (x *MetricSnapshot) GetName() string
func (*MetricSnapshot) GetTyp ¶
func (x *MetricSnapshot) GetTyp() MetricType
func (*MetricSnapshot) GetValue ¶
func (x *MetricSnapshot) GetValue() float64
func (*MetricSnapshot) ProtoMessage ¶
func (*MetricSnapshot) ProtoMessage()
func (*MetricSnapshot) ProtoReflect ¶
func (x *MetricSnapshot) ProtoReflect() protoreflect.Message
func (*MetricSnapshot) Reset ¶
func (x *MetricSnapshot) Reset()
func (*MetricSnapshot) String ¶
func (x *MetricSnapshot) String() string
type MetricType ¶
type MetricType int32
MetricType specifies a particular kind of metric.
const ( MetricType_INVALID MetricType = 0 MetricType_COUNTER MetricType = 1 MetricType_GAUGE MetricType = 2 MetricType_HISTOGRAM MetricType = 3 )
func (MetricType) Descriptor ¶
func (MetricType) Descriptor() protoreflect.EnumDescriptor
func (MetricType) Enum ¶
func (x MetricType) Enum() *MetricType
func (MetricType) EnumDescriptor
deprecated
func (MetricType) EnumDescriptor() ([]byte, []int)
Deprecated: Use MetricType.Descriptor instead.
func (MetricType) Number ¶
func (x MetricType) Number() protoreflect.EnumNumber
func (MetricType) String ¶
func (x MetricType) String() string
func (MetricType) Type ¶
func (MetricType) Type() protoreflect.EnumType
type MetricUpdate ¶
type MetricUpdate struct { // Metric definitions and updated values. // // All metrics are identified by their globally unique id. Two endpoints // exchanging metric updates must ensure that a received metric value has been // preceded by a metric definition with the same id, either in the current // update or an earlier one. Defs []*MetricDef `protobuf:"bytes,1,rep,name=defs,proto3" json:"defs,omitempty"` // metric definitions Values []*MetricValue `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"` // metric values // contains filtered or unexported fields }
MetricUpdate contains metric updates.
func (*MetricUpdate) Descriptor
deprecated
func (*MetricUpdate) Descriptor() ([]byte, []int)
Deprecated: Use MetricUpdate.ProtoReflect.Descriptor instead.
func (*MetricUpdate) GetDefs ¶
func (x *MetricUpdate) GetDefs() []*MetricDef
func (*MetricUpdate) GetValues ¶
func (x *MetricUpdate) GetValues() []*MetricValue
func (*MetricUpdate) ProtoMessage ¶
func (*MetricUpdate) ProtoMessage()
func (*MetricUpdate) ProtoReflect ¶
func (x *MetricUpdate) ProtoReflect() protoreflect.Message
func (*MetricUpdate) Reset ¶
func (x *MetricUpdate) Reset()
func (*MetricUpdate) String ¶
func (x *MetricUpdate) String() string
type MetricValue ¶
type MetricValue struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // metric's unique id. Value float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"` // value for counter and gauge, sum for histogram Counts []uint64 `protobuf:"varint,3,rep,packed,name=counts,proto3" json:"counts,omitempty"` // histogram counts // contains filtered or unexported fields }
MetricValue is the value associated with a metric.
func (*MetricValue) Descriptor
deprecated
func (*MetricValue) Descriptor() ([]byte, []int)
Deprecated: Use MetricValue.ProtoReflect.Descriptor instead.
func (*MetricValue) GetCounts ¶
func (x *MetricValue) GetCounts() []uint64
func (*MetricValue) GetId ¶
func (x *MetricValue) GetId() uint64
func (*MetricValue) GetValue ¶
func (x *MetricValue) GetValue() float64
func (*MetricValue) ProtoMessage ¶
func (*MetricValue) ProtoMessage()
func (*MetricValue) ProtoReflect ¶
func (x *MetricValue) ProtoReflect() protoreflect.Message
func (*MetricValue) Reset ¶
func (x *MetricValue) Reset()
func (*MetricValue) String ¶
func (x *MetricValue) String() string
type ProfileType ¶
type ProfileType int32
ProfileType specifies a type of profile.
const ( ProfileType_Unspecified ProfileType = 0 ProfileType_Heap ProfileType = 1 ProfileType_CPU ProfileType = 2 )
func (ProfileType) Descriptor ¶
func (ProfileType) Descriptor() protoreflect.EnumDescriptor
func (ProfileType) Enum ¶
func (x ProfileType) Enum() *ProfileType
func (ProfileType) EnumDescriptor
deprecated
func (ProfileType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ProfileType.Descriptor instead.
func (ProfileType) Number ¶
func (x ProfileType) Number() protoreflect.EnumNumber
func (ProfileType) String ¶
func (x ProfileType) String() string
func (ProfileType) Type ¶
func (ProfileType) Type() protoreflect.EnumType
type RoutingInfo ¶
type RoutingInfo struct { Component string `protobuf:"bytes,1,opt,name=component,proto3" json:"component,omitempty"` // If true, perform method calls on the component locally. Replicas and // assignment are ignored. Currently, local must always be true or always be // false for a given component. Local bool `protobuf:"varint,2,opt,name=local,proto3" json:"local,omitempty"` // The addresses of the weavelets hosting a replica of the component. Every // address is of the form "<net>://<addr>" (e.g., "tcp://host:1234", // "unix:///tmp/unix.sock"). For non-local components, a weavelet will execute // method calls on one of these replicas. Replicas []string `protobuf:"bytes,3,rep,name=replicas,proto3" json:"replicas,omitempty"` // Routing assignment, if the component is routed. Assignment *Assignment `protobuf:"bytes,4,opt,name=assignment,proto3" json:"assignment,omitempty"` // contains filtered or unexported fields }
RoutingInfo contains routing information for a component. A weavelet uses a RoutingInfo to know where to send a remote method call.
func (*RoutingInfo) Descriptor
deprecated
func (*RoutingInfo) Descriptor() ([]byte, []int)
Deprecated: Use RoutingInfo.ProtoReflect.Descriptor instead.
func (*RoutingInfo) GetAssignment ¶
func (x *RoutingInfo) GetAssignment() *Assignment
func (*RoutingInfo) GetComponent ¶
func (x *RoutingInfo) GetComponent() string
func (*RoutingInfo) GetLocal ¶
func (x *RoutingInfo) GetLocal() bool
func (*RoutingInfo) GetReplicas ¶
func (x *RoutingInfo) GetReplicas() []string
func (*RoutingInfo) ProtoMessage ¶
func (*RoutingInfo) ProtoMessage()
func (*RoutingInfo) ProtoReflect ¶
func (x *RoutingInfo) ProtoReflect() protoreflect.Message
func (*RoutingInfo) Reset ¶
func (x *RoutingInfo) Reset()
func (*RoutingInfo) String ¶
func (x *RoutingInfo) String() string
type SemVer ¶
type SemVer struct { Major int64 `protobuf:"varint,1,opt,name=major,proto3" json:"major,omitempty"` Minor int64 `protobuf:"varint,2,opt,name=minor,proto3" json:"minor,omitempty"` Patch int64 `protobuf:"varint,3,opt,name=patch,proto3" json:"patch,omitempty"` // contains filtered or unexported fields }
SemVer represents a [semantic version]1 of the form "<major>.<minor>.<patch>". For example, the semver "0.12.3" has major=0, minor=12, and patch=3.
func (*SemVer) Descriptor
deprecated
func (*SemVer) ProtoMessage ¶
func (*SemVer) ProtoMessage()
func (*SemVer) ProtoReflect ¶
func (x *SemVer) ProtoReflect() protoreflect.Message
type Span ¶
type Span struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Span name TraceId []byte `protobuf:"bytes,2,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` // Span trace id, 16 bytes long. SpanId []byte `protobuf:"bytes,3,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"` // Unique span id, 8 bytes long. ParentSpanId []byte `protobuf:"bytes,4,opt,name=parent_span_id,json=parentSpanId,proto3" json:"parent_span_id,omitempty"` // Parent span id, 8 bytes long Kind Span_Kind `protobuf:"varint,5,opt,name=kind,proto3,enum=runtime.Span_Kind" json:"kind,omitempty"` StartMicros int64 `protobuf:"fixed64,6,opt,name=start_micros,json=startMicros,proto3" json:"start_micros,omitempty"` // Span start time (microseconds since epoch) EndMicros int64 `protobuf:"fixed64,7,opt,name=end_micros,json=endMicros,proto3" json:"end_micros,omitempty"` // Span end time (microseconds since epoch) Attributes []*Span_Attribute `protobuf:"bytes,8,rep,name=attributes,proto3" json:"attributes,omitempty"` Links []*Span_Link `protobuf:"bytes,9,rep,name=links,proto3" json:"links,omitempty"` // Links to other spans Events []*Span_Event `protobuf:"bytes,10,rep,name=events,proto3" json:"events,omitempty"` // Events that occured in the span's lifetime Status *Span_Status `protobuf:"bytes,11,opt,name=status,proto3" json:"status,omitempty"` // Span status Scope *Span_Scope `protobuf:"bytes,18,opt,name=scope,proto3" json:"scope,omitempty"` Library *Span_Library `protobuf:"bytes,12,opt,name=library,proto3" json:"library,omitempty"` // Instrumentation library that created the span Resource *Span_Resource `protobuf:"bytes,13,opt,name=resource,proto3" json:"resource,omitempty"` // Number of span attributes dropped due to limits being reached. DroppedAttributeCount int64 `` /* 128-byte string literal not displayed */ // Number of links dropped due to limits being reached. DroppedLinkCount int64 `protobuf:"varint,15,opt,name=dropped_link_count,json=droppedLinkCount,proto3" json:"dropped_link_count,omitempty"` // Number of events dropped due to limits being reached. DroppedEventCount int64 `protobuf:"varint,16,opt,name=dropped_event_count,json=droppedEventCount,proto3" json:"dropped_event_count,omitempty"` // Number of spans that consider this span a direct parent. ChildSpanCount int64 `protobuf:"varint,17,opt,name=child_span_count,json=childSpanCount,proto3" json:"child_span_count,omitempty"` // contains filtered or unexported fields }
Span is a proto-based representation of an open-telemetry Span [1].
[1]: https://opentelemetry.io/docs/concepts/signals/traces/#spans TODO(spetrovic): Rename to TraceSpan.
func (*Span) Descriptor
deprecated
func (*Span) GetAttributes ¶
func (x *Span) GetAttributes() []*Span_Attribute
func (*Span) GetChildSpanCount ¶
func (*Span) GetDroppedAttributeCount ¶
func (*Span) GetDroppedEventCount ¶
func (*Span) GetDroppedLinkCount ¶
func (*Span) GetEndMicros ¶
func (*Span) GetEvents ¶
func (x *Span) GetEvents() []*Span_Event
func (*Span) GetLibrary ¶
func (x *Span) GetLibrary() *Span_Library
func (*Span) GetParentSpanId ¶
func (*Span) GetResource ¶
func (x *Span) GetResource() *Span_Resource
func (*Span) GetScope ¶
func (x *Span) GetScope() *Span_Scope
func (*Span) GetStartMicros ¶
func (*Span) GetStatus ¶
func (x *Span) GetStatus() *Span_Status
func (*Span) GetTraceId ¶
func (*Span) ProtoMessage ¶
func (*Span) ProtoMessage()
func (*Span) ProtoReflect ¶
func (x *Span) ProtoReflect() protoreflect.Message
type Span_Attribute ¶
type Span_Attribute struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value *Span_Attribute_Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
Span attributes.
func (*Span_Attribute) Descriptor
deprecated
func (*Span_Attribute) Descriptor() ([]byte, []int)
Deprecated: Use Span_Attribute.ProtoReflect.Descriptor instead.
func (*Span_Attribute) GetKey ¶
func (x *Span_Attribute) GetKey() string
func (*Span_Attribute) GetValue ¶
func (x *Span_Attribute) GetValue() *Span_Attribute_Value
func (*Span_Attribute) ProtoMessage ¶
func (*Span_Attribute) ProtoMessage()
func (*Span_Attribute) ProtoReflect ¶
func (x *Span_Attribute) ProtoReflect() protoreflect.Message
func (*Span_Attribute) Reset ¶
func (x *Span_Attribute) Reset()
func (*Span_Attribute) String ¶
func (x *Span_Attribute) String() string
type Span_Attribute_Value ¶
type Span_Attribute_Value struct { Type Span_Attribute_Value_Type `protobuf:"varint,1,opt,name=type,proto3,enum=runtime.Span_Attribute_Value_Type" json:"type,omitempty"` // Attribute type // Types that are assignable to Value: // // *Span_Attribute_Value_Num // *Span_Attribute_Value_Str // *Span_Attribute_Value_Nums // *Span_Attribute_Value_Strs Value isSpan_Attribute_Value_Value `protobuf_oneof:"value"` // contains filtered or unexported fields }
func (*Span_Attribute_Value) Descriptor
deprecated
func (*Span_Attribute_Value) Descriptor() ([]byte, []int)
Deprecated: Use Span_Attribute_Value.ProtoReflect.Descriptor instead.
func (*Span_Attribute_Value) GetNum ¶
func (x *Span_Attribute_Value) GetNum() uint64
func (*Span_Attribute_Value) GetNums ¶
func (x *Span_Attribute_Value) GetNums() *Span_Attribute_Value_NumberList
func (*Span_Attribute_Value) GetStr ¶
func (x *Span_Attribute_Value) GetStr() string
func (*Span_Attribute_Value) GetStrs ¶
func (x *Span_Attribute_Value) GetStrs() *Span_Attribute_Value_StringList
func (*Span_Attribute_Value) GetType ¶
func (x *Span_Attribute_Value) GetType() Span_Attribute_Value_Type
func (*Span_Attribute_Value) GetValue ¶
func (m *Span_Attribute_Value) GetValue() isSpan_Attribute_Value_Value
func (*Span_Attribute_Value) ProtoMessage ¶
func (*Span_Attribute_Value) ProtoMessage()
func (*Span_Attribute_Value) ProtoReflect ¶
func (x *Span_Attribute_Value) ProtoReflect() protoreflect.Message
func (*Span_Attribute_Value) Reset ¶
func (x *Span_Attribute_Value) Reset()
func (*Span_Attribute_Value) String ¶
func (x *Span_Attribute_Value) String() string
type Span_Attribute_Value_Num ¶
type Span_Attribute_Value_Num struct {
Num uint64 `protobuf:"varint,2,opt,name=num,proto3,oneof"`
}
type Span_Attribute_Value_NumberList ¶
type Span_Attribute_Value_NumberList struct { Nums []uint64 `protobuf:"varint,1,rep,packed,name=nums,proto3" json:"nums,omitempty"` // contains filtered or unexported fields }
func (*Span_Attribute_Value_NumberList) Descriptor
deprecated
func (*Span_Attribute_Value_NumberList) Descriptor() ([]byte, []int)
Deprecated: Use Span_Attribute_Value_NumberList.ProtoReflect.Descriptor instead.
func (*Span_Attribute_Value_NumberList) GetNums ¶
func (x *Span_Attribute_Value_NumberList) GetNums() []uint64
func (*Span_Attribute_Value_NumberList) ProtoMessage ¶
func (*Span_Attribute_Value_NumberList) ProtoMessage()
func (*Span_Attribute_Value_NumberList) ProtoReflect ¶
func (x *Span_Attribute_Value_NumberList) ProtoReflect() protoreflect.Message
func (*Span_Attribute_Value_NumberList) Reset ¶
func (x *Span_Attribute_Value_NumberList) Reset()
func (*Span_Attribute_Value_NumberList) String ¶
func (x *Span_Attribute_Value_NumberList) String() string
type Span_Attribute_Value_Nums ¶
type Span_Attribute_Value_Nums struct {
Nums *Span_Attribute_Value_NumberList `protobuf:"bytes,4,opt,name=nums,proto3,oneof"`
}
type Span_Attribute_Value_Str ¶
type Span_Attribute_Value_Str struct {
Str string `protobuf:"bytes,3,opt,name=str,proto3,oneof"`
}
type Span_Attribute_Value_StringList ¶
type Span_Attribute_Value_StringList struct { Strs []string `protobuf:"bytes,2,rep,name=strs,proto3" json:"strs,omitempty"` // contains filtered or unexported fields }
func (*Span_Attribute_Value_StringList) Descriptor
deprecated
func (*Span_Attribute_Value_StringList) Descriptor() ([]byte, []int)
Deprecated: Use Span_Attribute_Value_StringList.ProtoReflect.Descriptor instead.
func (*Span_Attribute_Value_StringList) GetStrs ¶
func (x *Span_Attribute_Value_StringList) GetStrs() []string
func (*Span_Attribute_Value_StringList) ProtoMessage ¶
func (*Span_Attribute_Value_StringList) ProtoMessage()
func (*Span_Attribute_Value_StringList) ProtoReflect ¶
func (x *Span_Attribute_Value_StringList) ProtoReflect() protoreflect.Message
func (*Span_Attribute_Value_StringList) Reset ¶
func (x *Span_Attribute_Value_StringList) Reset()
func (*Span_Attribute_Value_StringList) String ¶
func (x *Span_Attribute_Value_StringList) String() string
type Span_Attribute_Value_Strs ¶
type Span_Attribute_Value_Strs struct {
Strs *Span_Attribute_Value_StringList `protobuf:"bytes,5,opt,name=strs,proto3,oneof"`
}
type Span_Attribute_Value_Type ¶
type Span_Attribute_Value_Type int32
Type describes the type of the value.
const ( Span_Attribute_Value_INVALID Span_Attribute_Value_Type = 0 // Used when no value is set Span_Attribute_Value_BOOL Span_Attribute_Value_Type = 1 Span_Attribute_Value_INT64 Span_Attribute_Value_Type = 2 Span_Attribute_Value_FLOAT64 Span_Attribute_Value_Type = 3 Span_Attribute_Value_STRING Span_Attribute_Value_Type = 4 Span_Attribute_Value_BOOLLIST Span_Attribute_Value_Type = 5 Span_Attribute_Value_INT64LIST Span_Attribute_Value_Type = 6 Span_Attribute_Value_FLOAT64LIST Span_Attribute_Value_Type = 7 Span_Attribute_Value_STRINGLIST Span_Attribute_Value_Type = 8 )
func (Span_Attribute_Value_Type) Descriptor ¶
func (Span_Attribute_Value_Type) Descriptor() protoreflect.EnumDescriptor
func (Span_Attribute_Value_Type) Enum ¶
func (x Span_Attribute_Value_Type) Enum() *Span_Attribute_Value_Type
func (Span_Attribute_Value_Type) EnumDescriptor
deprecated
func (Span_Attribute_Value_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use Span_Attribute_Value_Type.Descriptor instead.
func (Span_Attribute_Value_Type) Number ¶
func (x Span_Attribute_Value_Type) Number() protoreflect.EnumNumber
func (Span_Attribute_Value_Type) String ¶
func (x Span_Attribute_Value_Type) String() string
func (Span_Attribute_Value_Type) Type ¶
func (Span_Attribute_Value_Type) Type() protoreflect.EnumType
type Span_Event ¶
type Span_Event struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Even name TimeMicros int64 `protobuf:"fixed64,2,opt,name=time_micros,json=timeMicros,proto3" json:"time_micros,omitempty"` // Time event was recorded (micros since epoch) Attributes []*Span_Attribute `protobuf:"bytes,3,rep,name=attributes,proto3" json:"attributes,omitempty"` // Event attributes // Number of attributes dropped due to limits being reached. DroppedAttributeCount int64 `` /* 127-byte string literal not displayed */ // contains filtered or unexported fields }
Event represent an event that occurred in the span's lifetime.
func (*Span_Event) Descriptor
deprecated
func (*Span_Event) Descriptor() ([]byte, []int)
Deprecated: Use Span_Event.ProtoReflect.Descriptor instead.
func (*Span_Event) GetAttributes ¶
func (x *Span_Event) GetAttributes() []*Span_Attribute
func (*Span_Event) GetDroppedAttributeCount ¶
func (x *Span_Event) GetDroppedAttributeCount() int64
func (*Span_Event) GetName ¶
func (x *Span_Event) GetName() string
func (*Span_Event) GetTimeMicros ¶
func (x *Span_Event) GetTimeMicros() int64
func (*Span_Event) ProtoMessage ¶
func (*Span_Event) ProtoMessage()
func (*Span_Event) ProtoReflect ¶
func (x *Span_Event) ProtoReflect() protoreflect.Message
func (*Span_Event) Reset ¶
func (x *Span_Event) Reset()
func (*Span_Event) String ¶
func (x *Span_Event) String() string
type Span_Kind ¶
type Span_Kind int32
Span's role in the trace.
func (Span_Kind) Descriptor ¶
func (Span_Kind) Descriptor() protoreflect.EnumDescriptor
func (Span_Kind) EnumDescriptor
deprecated
func (Span_Kind) Number ¶
func (x Span_Kind) Number() protoreflect.EnumNumber
func (Span_Kind) Type ¶
func (Span_Kind) Type() protoreflect.EnumType
type Span_Library ¶
type Span_Library struct { // Name of the instrumentation library, typically the package name of // the library. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // The version of the instrumentation library SchemaUrl string `protobuf:"bytes,3,opt,name=schema_url,json=schemaUrl,proto3" json:"schema_url,omitempty"` // Schema url of the telemetry emitted by library // contains filtered or unexported fields }
Library stores information about the instrumentation library that created the span.
func (*Span_Library) Descriptor
deprecated
func (*Span_Library) Descriptor() ([]byte, []int)
Deprecated: Use Span_Library.ProtoReflect.Descriptor instead.
func (*Span_Library) GetName ¶
func (x *Span_Library) GetName() string
func (*Span_Library) GetSchemaUrl ¶
func (x *Span_Library) GetSchemaUrl() string
func (*Span_Library) GetVersion ¶
func (x *Span_Library) GetVersion() string
func (*Span_Library) ProtoMessage ¶
func (*Span_Library) ProtoMessage()
func (*Span_Library) ProtoReflect ¶
func (x *Span_Library) ProtoReflect() protoreflect.Message
func (*Span_Library) Reset ¶
func (x *Span_Library) Reset()
func (*Span_Library) String ¶
func (x *Span_Library) String() string
type Span_Link ¶
type Span_Link struct { TraceId []byte `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` // Span trace id SpanId []byte `protobuf:"bytes,2,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"` // Unique span id Attributes []*Span_Attribute `protobuf:"bytes,3,rep,name=attributes,proto3" json:"attributes,omitempty"` // Span attributes // Number of span attributes dropped due to limits being reached DroppedAttributeCount int64 `` /* 127-byte string literal not displayed */ // contains filtered or unexported fields }
Link represents the link a span has to another span.
func (*Span_Link) Descriptor
deprecated
func (*Span_Link) GetAttributes ¶
func (x *Span_Link) GetAttributes() []*Span_Attribute
func (*Span_Link) GetDroppedAttributeCount ¶
func (*Span_Link) GetTraceId ¶
func (*Span_Link) ProtoMessage ¶
func (*Span_Link) ProtoMessage()
func (*Span_Link) ProtoReflect ¶
func (x *Span_Link) ProtoReflect() protoreflect.Message
type Span_Resource ¶
type Span_Resource struct { // URL that describes the shape and a composition of data for this span. SchemaUrl string `protobuf:"bytes,1,opt,name=schema_url,json=schemaUrl,proto3" json:"schema_url,omitempty"` Attributes []*Span_Attribute `protobuf:"bytes,2,rep,name=attributes,proto3" json:"attributes,omitempty"` // Resource attributes // contains filtered or unexported fields }
Resource describes an entity (e.g., a Service Weaver component) this span belongs to.
func (*Span_Resource) Descriptor
deprecated
func (*Span_Resource) Descriptor() ([]byte, []int)
Deprecated: Use Span_Resource.ProtoReflect.Descriptor instead.
func (*Span_Resource) GetAttributes ¶
func (x *Span_Resource) GetAttributes() []*Span_Attribute
func (*Span_Resource) GetSchemaUrl ¶
func (x *Span_Resource) GetSchemaUrl() string
func (*Span_Resource) ProtoMessage ¶
func (*Span_Resource) ProtoMessage()
func (*Span_Resource) ProtoReflect ¶
func (x *Span_Resource) ProtoReflect() protoreflect.Message
func (*Span_Resource) Reset ¶
func (x *Span_Resource) Reset()
func (*Span_Resource) String ¶
func (x *Span_Resource) String() string
type Span_Scope ¶
type Span_Scope struct { // Name of the instrumentation library, typically the package name of // the library. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // The version of the instrumentation scope SchemaUrl string `protobuf:"bytes,3,opt,name=schema_url,json=schemaUrl,proto3" json:"schema_url,omitempty"` // Schema url of the telemetry emitted by scope // contains filtered or unexported fields }
Scope stores information about the instrumentation scope that created the span.
func (*Span_Scope) Descriptor
deprecated
func (*Span_Scope) Descriptor() ([]byte, []int)
Deprecated: Use Span_Scope.ProtoReflect.Descriptor instead.
func (*Span_Scope) GetName ¶
func (x *Span_Scope) GetName() string
func (*Span_Scope) GetSchemaUrl ¶
func (x *Span_Scope) GetSchemaUrl() string
func (*Span_Scope) GetVersion ¶
func (x *Span_Scope) GetVersion() string
func (*Span_Scope) ProtoMessage ¶
func (*Span_Scope) ProtoMessage()
func (*Span_Scope) ProtoReflect ¶
func (x *Span_Scope) ProtoReflect() protoreflect.Message
func (*Span_Scope) Reset ¶
func (x *Span_Scope) Reset()
func (*Span_Scope) String ¶
func (x *Span_Scope) String() string
type Span_Status ¶
type Span_Status struct { Code Span_Status_Code `protobuf:"varint,1,opt,name=code,proto3,enum=runtime.Span_Status_Code" json:"code,omitempty"` // Span status code Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // Error text; set only for an ERROR code // contains filtered or unexported fields }
Status represents the status for a span.
func (*Span_Status) Descriptor
deprecated
func (*Span_Status) Descriptor() ([]byte, []int)
Deprecated: Use Span_Status.ProtoReflect.Descriptor instead.
func (*Span_Status) GetCode ¶
func (x *Span_Status) GetCode() Span_Status_Code
func (*Span_Status) GetError ¶
func (x *Span_Status) GetError() string
func (*Span_Status) ProtoMessage ¶
func (*Span_Status) ProtoMessage()
func (*Span_Status) ProtoReflect ¶
func (x *Span_Status) ProtoReflect() protoreflect.Message
func (*Span_Status) Reset ¶
func (x *Span_Status) Reset()
func (*Span_Status) String ¶
func (x *Span_Status) String() string
type Span_Status_Code ¶
type Span_Status_Code int32
const ( Span_Status_UNSET Span_Status_Code = 0 Span_Status_ERROR Span_Status_Code = 1 Span_Status_OK Span_Status_Code = 2 )
func (Span_Status_Code) Descriptor ¶
func (Span_Status_Code) Descriptor() protoreflect.EnumDescriptor
func (Span_Status_Code) Enum ¶
func (x Span_Status_Code) Enum() *Span_Status_Code
func (Span_Status_Code) EnumDescriptor
deprecated
func (Span_Status_Code) EnumDescriptor() ([]byte, []int)
Deprecated: Use Span_Status_Code.Descriptor instead.
func (Span_Status_Code) Number ¶
func (x Span_Status_Code) Number() protoreflect.EnumNumber
func (Span_Status_Code) String ¶
func (x Span_Status_Code) String() string
func (Span_Status_Code) Type ¶
func (Span_Status_Code) Type() protoreflect.EnumType
type TraceSpans ¶
type TraceSpans struct { Span []*Span `protobuf:"bytes,1,rep,name=span,proto3" json:"span,omitempty"` // contains filtered or unexported fields }
TraceSpans is a list of Span messages.
func (*TraceSpans) Descriptor
deprecated
func (*TraceSpans) Descriptor() ([]byte, []int)
Deprecated: Use TraceSpans.ProtoReflect.Descriptor instead.
func (*TraceSpans) GetSpan ¶
func (x *TraceSpans) GetSpan() []*Span
func (*TraceSpans) ProtoMessage ¶
func (*TraceSpans) ProtoMessage()
func (*TraceSpans) ProtoReflect ¶
func (x *TraceSpans) ProtoReflect() protoreflect.Message
func (*TraceSpans) Reset ¶
func (x *TraceSpans) Reset()
func (*TraceSpans) String ¶
func (x *TraceSpans) String() string
type UpdateComponentsReply ¶
type UpdateComponentsReply struct {
// contains filtered or unexported fields
}
UpdateComponentsReply is a reply to an UpdateComponentsRequest.
func (*UpdateComponentsReply) Descriptor
deprecated
func (*UpdateComponentsReply) Descriptor() ([]byte, []int)
Deprecated: Use UpdateComponentsReply.ProtoReflect.Descriptor instead.
func (*UpdateComponentsReply) ProtoMessage ¶
func (*UpdateComponentsReply) ProtoMessage()
func (*UpdateComponentsReply) ProtoReflect ¶
func (x *UpdateComponentsReply) ProtoReflect() protoreflect.Message
func (*UpdateComponentsReply) Reset ¶
func (x *UpdateComponentsReply) Reset()
func (*UpdateComponentsReply) String ¶
func (x *UpdateComponentsReply) String() string
type UpdateComponentsRequest ¶
type UpdateComponentsRequest struct { Components []string `protobuf:"bytes,1,rep,name=components,proto3" json:"components,omitempty"` // contains filtered or unexported fields }
UpdateComponentsRequest is a request from an envelope to the weavelet to update the set of components it should be running. Currently, the set of components must only ever increase over time.
func (*UpdateComponentsRequest) Descriptor
deprecated
func (*UpdateComponentsRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateComponentsRequest.ProtoReflect.Descriptor instead.
func (*UpdateComponentsRequest) GetComponents ¶
func (x *UpdateComponentsRequest) GetComponents() []string
func (*UpdateComponentsRequest) ProtoMessage ¶
func (*UpdateComponentsRequest) ProtoMessage()
func (*UpdateComponentsRequest) ProtoReflect ¶
func (x *UpdateComponentsRequest) ProtoReflect() protoreflect.Message
func (*UpdateComponentsRequest) Reset ¶
func (x *UpdateComponentsRequest) Reset()
func (*UpdateComponentsRequest) String ¶
func (x *UpdateComponentsRequest) String() string
type UpdateRoutingInfoReply ¶
type UpdateRoutingInfoReply struct {
// contains filtered or unexported fields
}
UpdateRoutingInfoReply is a reply to an UpdateRoutingInfoRequest.
func (*UpdateRoutingInfoReply) Descriptor
deprecated
func (*UpdateRoutingInfoReply) Descriptor() ([]byte, []int)
Deprecated: Use UpdateRoutingInfoReply.ProtoReflect.Descriptor instead.
func (*UpdateRoutingInfoReply) ProtoMessage ¶
func (*UpdateRoutingInfoReply) ProtoMessage()
func (*UpdateRoutingInfoReply) ProtoReflect ¶
func (x *UpdateRoutingInfoReply) ProtoReflect() protoreflect.Message
func (*UpdateRoutingInfoReply) Reset ¶
func (x *UpdateRoutingInfoReply) Reset()
func (*UpdateRoutingInfoReply) String ¶
func (x *UpdateRoutingInfoReply) String() string
type UpdateRoutingInfoRequest ¶
type UpdateRoutingInfoRequest struct { RoutingInfo *RoutingInfo `protobuf:"bytes,1,opt,name=routing_info,json=routingInfo,proto3" json:"routing_info,omitempty"` // contains filtered or unexported fields }
UpdateRoutingInfoRequest is a request from an envelope to the weavelet to update its routing information for a particular component.
func (*UpdateRoutingInfoRequest) Descriptor
deprecated
func (*UpdateRoutingInfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateRoutingInfoRequest.ProtoReflect.Descriptor instead.
func (*UpdateRoutingInfoRequest) GetRoutingInfo ¶
func (x *UpdateRoutingInfoRequest) GetRoutingInfo() *RoutingInfo
func (*UpdateRoutingInfoRequest) ProtoMessage ¶
func (*UpdateRoutingInfoRequest) ProtoMessage()
func (*UpdateRoutingInfoRequest) ProtoReflect ¶
func (x *UpdateRoutingInfoRequest) ProtoReflect() protoreflect.Message
func (*UpdateRoutingInfoRequest) Reset ¶
func (x *UpdateRoutingInfoRequest) Reset()
func (*UpdateRoutingInfoRequest) String ¶
func (x *UpdateRoutingInfoRequest) String() string
type VerifyClientCertificateReply ¶
type VerifyClientCertificateReply struct { // The set of components hosted by the weavelet that the client is allowed to // invoke methods on. Components []string `protobuf:"bytes,1,rep,name=components,proto3" json:"components,omitempty"` // contains filtered or unexported fields }
VerifyClientCertificateReply is a reply to a VerifyClientCertificateRequest. If the client certificate cannot be verified, an error should be returned rather than an empty reply.
func (*VerifyClientCertificateReply) Descriptor
deprecated
func (*VerifyClientCertificateReply) Descriptor() ([]byte, []int)
Deprecated: Use VerifyClientCertificateReply.ProtoReflect.Descriptor instead.
func (*VerifyClientCertificateReply) GetComponents ¶
func (x *VerifyClientCertificateReply) GetComponents() []string
func (*VerifyClientCertificateReply) ProtoMessage ¶
func (*VerifyClientCertificateReply) ProtoMessage()
func (*VerifyClientCertificateReply) ProtoReflect ¶
func (x *VerifyClientCertificateReply) ProtoReflect() protoreflect.Message
func (*VerifyClientCertificateReply) Reset ¶
func (x *VerifyClientCertificateReply) Reset()
func (*VerifyClientCertificateReply) String ¶
func (x *VerifyClientCertificateReply) String() string
type VerifyClientCertificateRequest ¶
type VerifyClientCertificateRequest struct { // Client's certificate chain. Each certificate in the chain is represented as // a DER-encoded ASN.1 structure. CertChain [][]byte `protobuf:"bytes,1,rep,name=cert_chain,json=certChain,proto3" json:"cert_chain,omitempty"` // contains filtered or unexported fields }
VerifyClientCertificateRequest is a request from a weavelet to verify the identity of a client that is attempting to connect to the weavelet.
func (*VerifyClientCertificateRequest) Descriptor
deprecated
func (*VerifyClientCertificateRequest) Descriptor() ([]byte, []int)
Deprecated: Use VerifyClientCertificateRequest.ProtoReflect.Descriptor instead.
func (*VerifyClientCertificateRequest) GetCertChain ¶
func (x *VerifyClientCertificateRequest) GetCertChain() [][]byte
func (*VerifyClientCertificateRequest) ProtoMessage ¶
func (*VerifyClientCertificateRequest) ProtoMessage()
func (*VerifyClientCertificateRequest) ProtoReflect ¶
func (x *VerifyClientCertificateRequest) ProtoReflect() protoreflect.Message
func (*VerifyClientCertificateRequest) Reset ¶
func (x *VerifyClientCertificateRequest) Reset()
func (*VerifyClientCertificateRequest) String ¶
func (x *VerifyClientCertificateRequest) String() string
type VerifyServerCertificateReply ¶
type VerifyServerCertificateReply struct {
// contains filtered or unexported fields
}
VerifyServerCertificateReply is a reply to a VerifyServerCertificateRequest.
func (*VerifyServerCertificateReply) Descriptor
deprecated
func (*VerifyServerCertificateReply) Descriptor() ([]byte, []int)
Deprecated: Use VerifyServerCertificateReply.ProtoReflect.Descriptor instead.
func (*VerifyServerCertificateReply) ProtoMessage ¶
func (*VerifyServerCertificateReply) ProtoMessage()
func (*VerifyServerCertificateReply) ProtoReflect ¶
func (x *VerifyServerCertificateReply) ProtoReflect() protoreflect.Message
func (*VerifyServerCertificateReply) Reset ¶
func (x *VerifyServerCertificateReply) Reset()
func (*VerifyServerCertificateReply) String ¶
func (x *VerifyServerCertificateReply) String() string
type VerifyServerCertificateRequest ¶
type VerifyServerCertificateRequest struct { // Server's certificate chain. Each certificate in the chain is represented as // a DER-encoded ASN.1 structure. CertChain [][]byte `protobuf:"bytes,1,rep,name=cert_chain,json=certChain,proto3" json:"cert_chain,omitempty"` // Name of the component the server is meant to be hosting. TargetComponent string `protobuf:"bytes,2,opt,name=target_component,json=targetComponent,proto3" json:"target_component,omitempty"` // contains filtered or unexported fields }
VerifyServerCertificateRequest is a request from a weavelet to verify the identity of the server it is attempting to connect to.
func (*VerifyServerCertificateRequest) Descriptor
deprecated
func (*VerifyServerCertificateRequest) Descriptor() ([]byte, []int)
Deprecated: Use VerifyServerCertificateRequest.ProtoReflect.Descriptor instead.
func (*VerifyServerCertificateRequest) GetCertChain ¶
func (x *VerifyServerCertificateRequest) GetCertChain() [][]byte
func (*VerifyServerCertificateRequest) GetTargetComponent ¶
func (x *VerifyServerCertificateRequest) GetTargetComponent() string
func (*VerifyServerCertificateRequest) ProtoMessage ¶
func (*VerifyServerCertificateRequest) ProtoMessage()
func (*VerifyServerCertificateRequest) ProtoReflect ¶
func (x *VerifyServerCertificateRequest) ProtoReflect() protoreflect.Message
func (*VerifyServerCertificateRequest) Reset ¶
func (x *VerifyServerCertificateRequest) Reset()
func (*VerifyServerCertificateRequest) String ¶
func (x *VerifyServerCertificateRequest) String() string
type WeaveletArgs ¶
type WeaveletArgs struct { App string `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"` // app name DeploymentId string `protobuf:"bytes,2,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"` // globally unique deployment id Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"` // globally unique weavelet id RunMain bool `protobuf:"varint,7,opt,name=run_main,json=runMain,proto3" json:"run_main,omitempty"` // run the main function? // Should weavelets establish mTLS connections with each other? Mtls bool `protobuf:"varint,8,opt,name=mtls,proto3" json:"mtls,omitempty"` // Address on which the weavelet's internal network listener should listen on // (e.g., "localhost:12345", ":0"). If the address is empty, it defaults to // ":0", like net.Listen. // // Note that for some deployers, the internal network listener can listen on // an arbitrary port (don't set the port number). However, for deployers where // listeners are prestarted (e.g., Kubernetes deployers), the port number // should be propagated from the deployer. InternalAddress string `protobuf:"bytes,10,opt,name=internal_address,json=internalAddress,proto3" json:"internal_address,omitempty"` // Unix domain socket path where weavelet should serve Control component // method calls. ControlSocket string `protobuf:"bytes,13,opt,name=control_socket,json=controlSocket,proto3" json:"control_socket,omitempty"` Redirects []*WeaveletArgs_Redirect `protobuf:"bytes,12,rep,name=redirects,proto3" json:"redirects,omitempty"` // contains filtered or unexported fields }
WeaveletArgs is the information provided by an envelope to a weavelet when the weavelet is created.
func (*WeaveletArgs) Descriptor
deprecated
func (*WeaveletArgs) Descriptor() ([]byte, []int)
Deprecated: Use WeaveletArgs.ProtoReflect.Descriptor instead.
func (*WeaveletArgs) GetApp ¶
func (x *WeaveletArgs) GetApp() string
func (*WeaveletArgs) GetControlSocket ¶
func (x *WeaveletArgs) GetControlSocket() string
func (*WeaveletArgs) GetDeploymentId ¶
func (x *WeaveletArgs) GetDeploymentId() string
func (*WeaveletArgs) GetId ¶
func (x *WeaveletArgs) GetId() string
func (*WeaveletArgs) GetInternalAddress ¶
func (x *WeaveletArgs) GetInternalAddress() string
func (*WeaveletArgs) GetMtls ¶
func (x *WeaveletArgs) GetMtls() bool
func (*WeaveletArgs) GetRedirects ¶
func (x *WeaveletArgs) GetRedirects() []*WeaveletArgs_Redirect
func (*WeaveletArgs) GetRunMain ¶
func (x *WeaveletArgs) GetRunMain() bool
func (*WeaveletArgs) ProtoMessage ¶
func (*WeaveletArgs) ProtoMessage()
func (*WeaveletArgs) ProtoReflect ¶
func (x *WeaveletArgs) ProtoReflect() protoreflect.Message
func (*WeaveletArgs) Reset ¶
func (x *WeaveletArgs) Reset()
func (*WeaveletArgs) String ¶
func (x *WeaveletArgs) String() string
type WeaveletArgs_Redirect ¶
type WeaveletArgs_Redirect struct { Component string `protobuf:"bytes,1,opt,name=component,proto3" json:"component,omitempty"` Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"` Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"` // contains filtered or unexported fields }
A redirect entry instructs the weavelet to direct calls made to component to be instead sent to the component named target at the specified address.
func (*WeaveletArgs_Redirect) Descriptor
deprecated
func (*WeaveletArgs_Redirect) Descriptor() ([]byte, []int)
Deprecated: Use WeaveletArgs_Redirect.ProtoReflect.Descriptor instead.
func (*WeaveletArgs_Redirect) GetAddress ¶
func (x *WeaveletArgs_Redirect) GetAddress() string
func (*WeaveletArgs_Redirect) GetComponent ¶
func (x *WeaveletArgs_Redirect) GetComponent() string
func (*WeaveletArgs_Redirect) GetTarget ¶
func (x *WeaveletArgs_Redirect) GetTarget() string
func (*WeaveletArgs_Redirect) ProtoMessage ¶
func (*WeaveletArgs_Redirect) ProtoMessage()
func (*WeaveletArgs_Redirect) ProtoReflect ¶
func (x *WeaveletArgs_Redirect) ProtoReflect() protoreflect.Message
func (*WeaveletArgs_Redirect) Reset ¶
func (x *WeaveletArgs_Redirect) Reset()
func (*WeaveletArgs_Redirect) String ¶
func (x *WeaveletArgs_Redirect) String() string