proto

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Mar 7, 2024 License: MIT Imports: 7 Imported by: 0

Documentation

Overview

Package proto is a generated protocol buffer package.

It is generated from these files: 

context_bus.proto

It has these top-level messages: 

ConditionMessage
ConditionLogic
ConditionNode
ConditionTree
PrerequisiteMessage
PrerequisiteLogic
PrerequisiteNode
PrerequisiteTree
PrerequisiteSnapshot
PrerequisiteSnapshots
FaultDelayParam
TrafficBalanceParam
TrafficRoutingParam
ReactionConfigure
Path
AttributeConfigure
TimestampConfigure
StackTraceConfigure
LoggingConfigure
TracingConfigure
MetricsConfigure
ObservationConfigure
Configure
CPUProfile
MemProfile
NetProfile
HardwareProfile
LanguageGo
LanguageJava
LanguageProfile
EnvironmentalProfile
EventWhen
AttributeValue
Attributes
CodeBaseInfo
EventWhere
EventRecorder
EventMessage
LibrariesMessage
EventWhat
EventRepresentation
ParentChildPointers
SpanMetadata
EventMetadata
EventData
Record
PrometheusOpts
PrometheusHistogramOpts
PrometheusSummaryObjective
PrometheusSummaryOpts
PrometheusConfiguration
Payload

Index

Constants

This section is empty.

Variables

View Source 
var ActionType_name = map[int32]string{
	0: "ActionType_",
	1: "ActionSend",
	2: "ActionReceive",
}
View Source 
var ActionType_value = map[string]int32{
	"ActionType_":   0,
	"ActionSend":    1,
	"ActionReceive": 2,
}
View Source 
var AttributeValueType_name = map[int32]string{
	0: "AttributeValueType_",
	1: "AttributeValueStr",
	2: "AttributeValueAttr",
}
View Source 
var AttributeValueType_value = map[string]int32{
	"AttributeValueType_": 0,
	"AttributeValueStr":   1,
	"AttributeValueAttr":  2,
}
View Source 
var ConditionNodeType_name = map[int32]string{
	0: "ConditionNodeType_",
	1: "ConditionMessage_",
	2: "ConditionLogic_",
}
View Source 
var ConditionNodeType_value = map[string]int32{
	"ConditionNodeType_": 0,
	"ConditionMessage_":  1,
	"ConditionLogic_":    2,
}
View Source 
var ConditionOperator_name = map[int32]string{
	0: "ConditionOperator_",
	1: "LT",
	2: "GT",
	3: "LE",
	4: "GE",
	5: "EQ",
	6: "NE",
}
View Source 
var ConditionOperator_value = map[string]int32{
	"ConditionOperator_": 0,
	"LT":                 1,
	"GT":                 2,
	"LE":                 3,
	"GE":                 4,
	"EQ":                 5,
	"NE":                 6,
}
View Source 
var ConditionType_name = map[int32]string{
	0: "ConditionType_",
	1: "NumOfInvok",
	2: "Latency",
}
View Source 
var ConditionType_value = map[string]int32{
	"ConditionType_": 0,
	"NumOfInvok":     1,
	"Latency":        2,
}
View Source 
var EventRecorderType_name = map[int32]string{
	0: "EventRecorderType_",
	1: "EventRecorderServiceHandler",
	2: "EventRecorderFunction",
	3: "EventRecorderThirdParty",
}
View Source 
var EventRecorderType_value = map[string]int32{
	"EventRecorderType_":          0,
	"EventRecorderServiceHandler": 1,
	"EventRecorderFunction":       2,
	"EventRecorderThirdParty":     3,
}
View Source 
var LanguageType_name = map[int32]string{
	0: "LanguageType_",
	1: "Other",
	2: "Golang",
	3: "Java",
}
View Source 
var LanguageType_value = map[string]int32{
	"LanguageType_": 0,
	"Other":         1,
	"Golang":        2,
	"Java":          3,
}
View Source 
var LogOutType_name = map[int32]string{
	0: "LogOutType_",
	1: "Stdout",
	2: "Stderr",
	3: "File",
}
View Source 
var LogOutType_value = map[string]int32{
	"LogOutType_": 0,
	"Stdout":      1,
	"Stderr":      2,
	"File":        3,
}
View Source 
var LogicType_name = map[int32]string{
	0: "LogicType_",
	1: "And_",
	2: "Or_",
}
View Source 
var LogicType_value = map[string]int32{
	"LogicType_": 0,
	"And_":       1,
	"Or_":        2,
}
View Source 
var MessageType_name = map[int32]string{
	0: "MessageType_",
	1: "Message_Request",
	2: "Message_Response",
}
View Source 
var MessageType_value = map[string]int32{
	"MessageType_":     0,
	"Message_Request":  1,
	"Message_Response": 2,
}
View Source 
var MetricType_name = map[int32]string{
	0: "MetricType_",
	1: "Counter",
	2: "Gauge",
	3: "Histogram",
	4: "Summary",
}
View Source 
var MetricType_value = map[string]int32{
	"MetricType_": 0,
	"Counter":     1,
	"Gauge":       2,
	"Histogram":   3,
	"Summary":     4,
}
View Source 
var ObservationType_name = map[int32]string{
	0: "ObservationType_",
	1: "ObservationSingle",
	2: "ObservationStart",
	3: "ObservationInter",
	4: "ObservationEnd",
}
View Source 
var ObservationType_value = map[string]int32{
	"ObservationType_":  0,
	"ObservationSingle": 1,
	"ObservationStart":  2,
	"ObservationInter":  3,
	"ObservationEnd":    4,
}
View Source 
var PathType_name = map[int32]string{
	0: "PathType_",
	1: "Application",
	2: "Library",
}
View Source 
var PathType_value = map[string]int32{
	"PathType_":   0,
	"Application": 1,
	"Library":     2,
}
View Source 
var PrerequisiteNodeType_name = map[int32]string{
	0: "PrerequisiteNodeType_",
	1: "PrerequisiteMessage_",
	2: "PrerequisiteLogic_",
}
View Source 
var PrerequisiteNodeType_value = map[string]int32{
	"PrerequisiteNodeType_": 0,
	"PrerequisiteMessage_":  1,
	"PrerequisiteLogic_":    2,
}
View Source 
var ReactionType_name = map[int32]string{
	0:   "ReactionType_",
	1:   "FaultCrash",
	2:   "FaultDelay",
	3:   "FaultDrop",
	101: "TrafficBalance",
	102: "TrafficRouting",
}
View Source 
var ReactionType_value = map[string]int32{
	"ReactionType_":  0,
	"FaultCrash":     1,
	"FaultDelay":     2,
	"FaultDrop":      3,
	"TrafficBalance": 101,
	"TrafficRouting": 102,
}
View Source 
var Test_AttributeConfigure_App_Key21 = NewAttributeConfigure("app.key21", Test_Path_App_Key21)

Test_AttributeConfigure_App_Key21 tag["app.key21"] = val(app.key2.key21)

View Source 
var Test_AttributeConfigure_App_Message = NewAttributeConfigure("app.message", Test_Path_App_Message)

Test_AttributeConfigure_App_Message tag["app.message"] = val(app.message)

View Source 
var Test_AttributeConfigure_Lib1_Key11 = NewAttributeConfigure("lib1.key11", Test_Path_Lib1_Key11)

Test_AttributeConfigure_Lib1_Key11 tag["lib1.key11"] = val(lib1.key1.key11)

View Source 
var Test_AttributeConfigure_Rest_From = NewAttributeConfigure("rest.from", Test_Path_Rest_From)

Test_AttributeConfigure_Rest_From tag["rest.from"] = val(rest.from)

View Source 
var Test_AttributeConfigure_Rest_Handler = NewAttributeConfigure("handler", Test_Path_Rest_Handler)

Test_AttributeConfigure_Rest_Handler tag["rest.handler"] = val(rest.handler)

View Source 
var Test_AttributeConfigure_Rest_Key = NewAttributeConfigure("rest.key", Test_Path_Rest_Key)

Test_AttributeConfigure_Rest_Key tag["rest.key"] = val(rest.key)

View Source 
var Test_AttributeConfigure_Rest_Key_ = NewAttributeConfigure("rest.key_", Test_Path_Rest_Key_)

Test_AttributeConfigure_Rest_Key_ tag["rest.key_"] = val(rest.key_)

View Source 
var Test_AttributeConfigure_Rest_Method = NewAttributeConfigure("method", Test_Path_Rest_Method)

Test_AttributeConfigure_Rest_Method tag["rest.method"] = val(rest.method)

View Source 
var Test_Condition_0_2_0 = NewConditionMessageNode(ConditionType_NumOfInvok, ConditionOperator_EQ, 1)

Test_Condition_0_2_0 number of invocation == 1

View Source 
var Test_Condition_1_3_0 = Test_Condition_0_2_0
View Source 
var Test_Condition_1_4_0 = NewConditionLogicNode(LogicType_And_, -1, []int64{1, 2})
View Source 
var Test_Condition_1_4_0_0 = NewConditionMessageNode(ConditionType_NumOfInvok, ConditionOperator_GT, 1)

Test_Condition_1_4_0_0 number of invocation > 1

View Source 
var Test_Condition_1_4_0_1 = NewConditionMessageNode(ConditionType_NumOfInvok, ConditionOperator_LT, 4)

Test_Condition_1_4_0_1 number of invocation > 4

View Source 
var Test_Condition_C_1_0 = NewConditionMessageNode(ConditionType_NumOfInvok, ConditionOperator_GE, 1)
View Source 
var Test_Condition_C_2_0 = NewConditionMessageNode(ConditionType_NumOfInvok, ConditionOperator_GE, 0)
View Source 
var Test_EventMessage_Rest = &EventMessage{
	Attrs: &Attributes{
		Attrs: map[string]*AttributeValue{
			"from": {
				Type: AttributeValueType_AttributeValueStr,
				Str:  "SenderA",
			},
			"method": {
				Type: AttributeValueType_AttributeValueStr,
				Str:  "POST",
			},
			"handler": {
				Type: AttributeValueType_AttributeValueStr,
				Str:  "/handler1",
			},
			"key": {
				Type: AttributeValueType_AttributeValueStr,
				Str:  "This a string attribute",
			},
			"key_": {
				Type: AttributeValueType_AttributeValueStr,
				Str:  "This another string attribute",
			},
		},
	},
}
View Source 
var Test_Path_App_Key21 = NewPath(PathType_Application, []string{"key2", "key21"})

Test_Path_App_Key21 app.key2.key21

View Source 
var Test_Path_App_Message = NewPath(PathType_Application, []string{"__message__"})

Test_Path_App_Message app.message

View Source 
var Test_Path_Lib1_Key11 = NewPath(PathType_Library, []string{"lib1", "key1", "key11"})

Test_Path_Lib1_Key11 lib1.key1.key11

View Source 
var Test_Path_Not_Found = NewPath(PathType_Library, []string{"__not__", "__found__"})

Test_Path_Not_Found not.found

View Source 
var Test_Path_Rest_From = NewPath(PathType_Library, []string{"rest", "from"})

Test_Path_Rest_From rest.from

View Source 
var Test_Path_Rest_Handler = NewPath(PathType_Library, []string{"rest", "handler"})

Test_Path_Rest_Handler rest.handler

View Source 
var Test_Path_Rest_Key = NewPath(PathType_Library, []string{"rest", "key"})

Test_Path_Rest_Key rest.key

View Source 
var Test_Path_Rest_Key_ = NewPath(PathType_Library, []string{"rest", "key_"})

Test_Path_Rest_Key_ rest.key_

View Source 
var Test_Path_Rest_Method = NewPath(PathType_Library, []string{"rest", "method"})

Test_Path_Rest_Method rest.method

View Source 
var Test_PrerequisiteTree0 = &PrerequisiteTree{
	Nodes: []*PrerequisiteNode{
		NewPrerequisiteLogicNode(0, LogicType_And_, -1, []int64{1, 2}),
		NewPrerequisiteMessageNode(1, "EventA", nil, 0, nil),
		NewPrerequisiteMessageNode(2, "EventB", NewConditionTree([]*ConditionNode{Test_Condition_0_2_0}, nil), 0, nil),
	},
}

Test_PrerequisiteTree0 (EventA) && (EventB = 1)

View Source 
var Test_PrerequisiteTree1 = &PrerequisiteTree{
	Nodes: []*PrerequisiteNode{
		NewPrerequisiteLogicNode(0, LogicType_Or_, -1, []int64{1, 4}),
		NewPrerequisiteLogicNode(1, LogicType_And_, 0, []int64{2, 3}),
		NewPrerequisiteMessageNode(2, "EventA", nil, 1, nil),
		NewPrerequisiteMessageNode(3, "EventB", NewConditionTree([]*ConditionNode{Test_Condition_1_3_0}, nil), 1, nil),
		NewPrerequisiteMessageNode(4, "EventC", NewConditionTree([]*ConditionNode{Test_Condition_1_4_0, Test_Condition_1_4_0_0, Test_Condition_1_4_0_1}, nil), 0, nil),
	},
}

Test_PrerequisiteTree1 ((EventA) && (EventB = 1)) || (1 < EventC < 4)

Functions

This section is empty.

Types

type ActionType 

type ActionType int32
const (
	ActionType_ActionType_   ActionType = 0
	ActionType_ActionSend    ActionType = 1
	ActionType_ActionReceive ActionType = 2
)

func (ActionType) EnumDescriptor 

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

func (ActionType) String 

func (x ActionType) String() string

type AttributeConfigure 

type AttributeConfigure struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Path *Path  `protobuf:"bytes,2,opt,name=path" json:"path,omitempty"`
}

func NewAttributeConfigure 

func NewAttributeConfigure(name string, path *Path) *AttributeConfigure

func (*AttributeConfigure) Descriptor 

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

func (*AttributeConfigure) GetName 

func (m *AttributeConfigure) GetName() string

func (*AttributeConfigure) GetPath 

func (m *AttributeConfigure) GetPath() *Path

func (*AttributeConfigure) ProtoMessage 

func (*AttributeConfigure) ProtoMessage()

func (*AttributeConfigure) Reset 

func (m *AttributeConfigure) Reset()

func (*AttributeConfigure) String 

func (m *AttributeConfigure) String() string

type AttributeValue 

type AttributeValue struct {
	Type   AttributeValueType `protobuf:"varint,1,opt,name=type,enum=context_bus.AttributeValueType" json:"type,omitempty"`
	Str    string             `protobuf:"bytes,2,opt,name=str" json:"str,omitempty"`
	Struct *Attributes        `protobuf:"bytes,3,opt,name=struct" json:"struct,omitempty"`
}

func (*AttributeValue) Clone 

func (m *AttributeValue) Clone() *AttributeValue

func (*AttributeValue) Descriptor 

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

func (*AttributeValue) GetStr 

func (m *AttributeValue) GetStr() string

func (*AttributeValue) GetStruct 

func (m *AttributeValue) GetStruct() *Attributes

func (*AttributeValue) GetType 

func (m *AttributeValue) GetType() AttributeValueType

func (*AttributeValue) Merge 

func (m *AttributeValue) Merge(value *AttributeValue) *AttributeValue

func (*AttributeValue) ProtoMessage 

func (*AttributeValue) ProtoMessage()

func (*AttributeValue) Reset 

func (m *AttributeValue) Reset()

func (*AttributeValue) String 

func (m *AttributeValue) String() string

type AttributeValueType 

type AttributeValueType int32
const (
	AttributeValueType_AttributeValueType_ AttributeValueType = 0
	AttributeValueType_AttributeValueStr   AttributeValueType = 1
	AttributeValueType_AttributeValueAttr  AttributeValueType = 2
)

func (AttributeValueType) EnumDescriptor 

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

func (AttributeValueType) String 

func (x AttributeValueType) String() string

type Attributes 

type Attributes struct {
	Attrs map[string]*AttributeValue `` /* 130-byte string literal not displayed */
}

func (*Attributes) Clone 

func (m *Attributes) Clone() *Attributes

func (*Attributes) Descriptor 

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

func (*Attributes) GetAttrs 

func (m *Attributes) GetAttrs() map[string]*AttributeValue

func (*Attributes) GetString 

func (m *Attributes) GetString(key string) (string, bool)

func (*Attributes) GetValue 

func (m *Attributes) GetValue(path []string) (string, error)

func (*Attributes) Merge 

func (m *Attributes) Merge(attrs *Attributes) *Attributes

func (*Attributes) ProtoMessage 

func (*Attributes) ProtoMessage()

func (*Attributes) Reset 

func (m *Attributes) Reset()

func (*Attributes) SetAttributes 

func (m *Attributes) SetAttributes(key string, value *Attributes) *Attributes

func (*Attributes) SetString 

func (m *Attributes) SetString(key string, value string) *Attributes

SetString sets a string {value} for the {key}, return {m} (self) for method chaining.

func (*Attributes) String 

func (m *Attributes) String() string

func (*Attributes) WithAttributes 

func (m *Attributes) WithAttributes(key string, attrs *Attributes) *Attributes

WithAttributes merges {attrs} for the value of given {key}, returns the merged value of {key} for method chaining.

type CPUProfile 

type CPUProfile struct {
	Percent float64 `protobuf:"fixed64,1,opt,name=percent" json:"percent,omitempty"`
}

******************* Environmental Profile *******************

func (*CPUProfile) Descriptor 

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

func (*CPUProfile) GetPercent 

func (m *CPUProfile) GetPercent() float64

func (*CPUProfile) ProtoMessage 

func (*CPUProfile) ProtoMessage()

func (*CPUProfile) Reset 

func (m *CPUProfile) Reset()

func (*CPUProfile) String 

func (m *CPUProfile) String() string

type CodeBaseInfo 

type CodeBaseInfo struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	File string `protobuf:"bytes,2,opt,name=file" json:"file,omitempty"`
	Line int64  `protobuf:"varint,3,opt,name=line" json:"line,omitempty"`
}

func (*CodeBaseInfo) Descriptor 

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

func (*CodeBaseInfo) GetFile 

func (m *CodeBaseInfo) GetFile() string

func (*CodeBaseInfo) GetLine 

func (m *CodeBaseInfo) GetLine() int64

func (*CodeBaseInfo) GetName 

func (m *CodeBaseInfo) GetName() string

func (*CodeBaseInfo) ProtoMessage 

func (*CodeBaseInfo) ProtoMessage()

func (*CodeBaseInfo) Reset 

func (m *CodeBaseInfo) Reset()

func (*CodeBaseInfo) String 

func (m *CodeBaseInfo) String() string

type ConditionLogic 

type ConditionLogic struct {
	Type   LogicType `protobuf:"varint,1,opt,name=type,enum=context_bus.LogicType" json:"type,omitempty"`
	Parent int64     `protobuf:"varint,100,opt,name=parent" json:"parent,omitempty"`
	List   []int64   `protobuf:"varint,101,rep,packed,name=list" json:"list,omitempty"`
}

func (*ConditionLogic) Descriptor 

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

func (*ConditionLogic) GetList 

func (m *ConditionLogic) GetList() []int64

func (*ConditionLogic) GetParent 

func (m *ConditionLogic) GetParent() int64

func (*ConditionLogic) GetType 

func (m *ConditionLogic) GetType() LogicType

func (*ConditionLogic) ProtoMessage 

func (*ConditionLogic) ProtoMessage()

func (*ConditionLogic) Reset 

func (m *ConditionLogic) Reset()

func (*ConditionLogic) String 

func (m *ConditionLogic) String() string

type ConditionMessage 

type ConditionMessage struct {
	Type  ConditionType     `protobuf:"varint,1,opt,name=type,enum=context_bus.ConditionType" json:"type,omitempty"`
	Op    ConditionOperator `protobuf:"varint,2,opt,name=op,enum=context_bus.ConditionOperator" json:"op,omitempty"`
	Value int64             `protobuf:"varint,3,opt,name=value" json:"value,omitempty"`
}

func (*ConditionMessage) Descriptor 

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

func (*ConditionMessage) GetOp 

func (m *ConditionMessage) GetOp() ConditionOperator

func (*ConditionMessage) GetType 

func (m *ConditionMessage) GetType() ConditionType

func (*ConditionMessage) GetValue 

func (m *ConditionMessage) GetValue() int64

func (*ConditionMessage) ProtoMessage 

func (*ConditionMessage) ProtoMessage()

func (*ConditionMessage) Reset 

func (m *ConditionMessage) Reset()

func (*ConditionMessage) String 

func (m *ConditionMessage) String() string

type ConditionNode 

type ConditionNode struct {
	Type    ConditionNodeType `protobuf:"varint,2,opt,name=type,enum=context_bus.ConditionNodeType" json:"type,omitempty"`
	Message *ConditionMessage `protobuf:"bytes,3,opt,name=message" json:"message,omitempty"`
	Logic   *ConditionLogic   `protobuf:"bytes,4,opt,name=logic" json:"logic,omitempty"`
}

func NewConditionLogicNode 

func NewConditionLogicNode(typ LogicType, parent int64, list []int64) *ConditionNode

func NewConditionMessageNode 

func NewConditionMessageNode(typ ConditionType, op ConditionOperator, val int64) *ConditionNode

func (*ConditionNode) Descriptor 

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

func (*ConditionNode) GetLogic 

func (m *ConditionNode) GetLogic() *ConditionLogic

func (*ConditionNode) GetMessage 

func (m *ConditionNode) GetMessage() *ConditionMessage

func (*ConditionNode) GetType 

func (m *ConditionNode) GetType() ConditionNodeType

func (*ConditionNode) ProtoMessage 

func (*ConditionNode) ProtoMessage()

func (*ConditionNode) Reset 

func (m *ConditionNode) Reset()

func (*ConditionNode) String 

func (m *ConditionNode) String() string

type ConditionNodeType 

type ConditionNodeType int32
const (
	ConditionNodeType_ConditionNodeType_ ConditionNodeType = 0
	ConditionNodeType_ConditionMessage_  ConditionNodeType = 1
	ConditionNodeType_ConditionLogic_    ConditionNodeType = 2
)

func (ConditionNodeType) EnumDescriptor 

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

func (ConditionNodeType) String 

func (x ConditionNodeType) String() string

type ConditionOperator 

type ConditionOperator int32
const (
	ConditionOperator_ConditionOperator_ ConditionOperator = 0
	ConditionOperator_LT                 ConditionOperator = 1
	ConditionOperator_GT                 ConditionOperator = 2
	ConditionOperator_LE                 ConditionOperator = 3
	ConditionOperator_GE                 ConditionOperator = 4
	ConditionOperator_EQ                 ConditionOperator = 5
	ConditionOperator_NE                 ConditionOperator = 6
)

func (ConditionOperator) EnumDescriptor 

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

func (ConditionOperator) String 

func (x ConditionOperator) String() string

type ConditionTree 

type ConditionTree struct {
	Nodes   []*ConditionNode `protobuf:"bytes,1,rep,name=nodes" json:"nodes,omitempty"`
	LeafIDs []int64          `protobuf:"varint,2,rep,packed,name=leafIDs" json:"leafIDs,omitempty"`
}

func NewConditionTree 

func NewConditionTree(nodes []*ConditionNode, leafIDs []int64) *ConditionTree

func (*ConditionTree) Descriptor 

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

func (*ConditionTree) GetLeafIDs 

func (m *ConditionTree) GetLeafIDs() []int64

func (*ConditionTree) GetNodes 

func (m *ConditionTree) GetNodes() []*ConditionNode

func (*ConditionTree) ProtoMessage 

func (*ConditionTree) ProtoMessage()

func (*ConditionTree) Reset 

func (m *ConditionTree) Reset()

func (*ConditionTree) String 

func (m *ConditionTree) String() string

type ConditionType 

type ConditionType int32
const (
	ConditionType_ConditionType_ ConditionType = 0
	ConditionType_NumOfInvok     ConditionType = 1
	ConditionType_Latency        ConditionType = 2
)

func (ConditionType) EnumDescriptor 

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

func (ConditionType) String 

func (x ConditionType) String() string

type Configure 

type Configure struct {
	Reactions    map[string]*ReactionConfigure    `` /* 138-byte string literal not displayed */
	Observations map[string]*ObservationConfigure `` /* 144-byte string literal not displayed */
}

func (*Configure) Descriptor 

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

func (*Configure) GetObservations 

func (m *Configure) GetObservations() map[string]*ObservationConfigure

func (*Configure) GetReactions 

func (m *Configure) GetReactions() map[string]*ReactionConfigure

func (*Configure) ProtoMessage 

func (*Configure) ProtoMessage()

func (*Configure) Reset 

func (m *Configure) Reset()

func (*Configure) String 

func (m *Configure) String() string

type EnvironmentalProfile 

type EnvironmentalProfile struct {
	Timestamp int64            `protobuf:"varint,1,opt,name=timestamp" json:"timestamp,omitempty"`
	Hardware  *HardwareProfile `protobuf:"bytes,2,opt,name=hardware" json:"hardware,omitempty"`
	Language  *LanguageProfile `protobuf:"bytes,3,opt,name=language" json:"language,omitempty"`
	Prev      int64            `protobuf:"varint,101,opt,name=prev" json:"prev,omitempty"`
	Next      int64            `protobuf:"varint,102,opt,name=next" json:"next,omitempty"`
}

func (*EnvironmentalProfile) Descriptor 

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

func (*EnvironmentalProfile) GetHardware 

func (m *EnvironmentalProfile) GetHardware() *HardwareProfile

func (*EnvironmentalProfile) GetLanguage 

func (m *EnvironmentalProfile) GetLanguage() *LanguageProfile

func (*EnvironmentalProfile) GetNext 

func (m *EnvironmentalProfile) GetNext() int64

func (*EnvironmentalProfile) GetPrev 

func (m *EnvironmentalProfile) GetPrev() int64

func (*EnvironmentalProfile) GetTimestamp 

func (m *EnvironmentalProfile) GetTimestamp() int64

func (*EnvironmentalProfile) ProtoMessage 

func (*EnvironmentalProfile) ProtoMessage()

func (*EnvironmentalProfile) Reset 

func (m *EnvironmentalProfile) Reset()

func (*EnvironmentalProfile) String 

func (m *EnvironmentalProfile) String() string

type EventData 

type EventData struct {
	Event    *EventRepresentation `protobuf:"bytes,1,opt,name=event" json:"event,omitempty"`
	Metadata *EventMetadata       `protobuf:"bytes,2,opt,name=metadata" json:"metadata,omitempty"`
	// event pairs for tracing and metrics
	PrevEventData *EventData    `protobuf:"bytes,11,opt,name=prev_event_data,json=prevEventData" json:"prev_event_data,omitempty"`
	SpanMetadata  *SpanMetadata `protobuf:"bytes,12,opt,name=span_metadata,json=spanMetadata" json:"span_metadata,omitempty"`
}

******************* Event Data

func (*EventData) Descriptor 

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

func (*EventData) GetEvent 

func (m *EventData) GetEvent() *EventRepresentation

func (*EventData) GetMetadata 

func (m *EventData) GetMetadata() *EventMetadata

func (*EventData) GetPrevEventData 

func (m *EventData) GetPrevEventData() *EventData

func (*EventData) GetPreviousEventData 

func (m *EventData) GetPreviousEventData(name string) *EventData

func (*EventData) GetSpanMetadata 

func (m *EventData) GetSpanMetadata() *SpanMetadata

func (*EventData) ProtoMessage 

func (*EventData) ProtoMessage()

func (*EventData) Reset 

func (m *EventData) Reset()

func (*EventData) String 

func (m *EventData) String() string

type EventMessage 

type EventMessage struct {
	Attrs   *Attributes `protobuf:"bytes,1,opt,name=attrs" json:"attrs,omitempty"`
	Message string      `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
	Paths   []*Path     `protobuf:"bytes,3,rep,name=paths" json:"paths,omitempty"`
}

func (*EventMessage) Descriptor 

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

func (*EventMessage) GetAttributes 

func (m *EventMessage) GetAttributes() *Attributes

func (*EventMessage) GetAttrs 

func (m *EventMessage) GetAttrs() *Attributes

func (*EventMessage) GetMessage 

func (m *EventMessage) GetMessage() string

func (*EventMessage) GetPaths 

func (m *EventMessage) GetPaths() []*Path

func (*EventMessage) GetValue 

func (m *EventMessage) GetValue(path []string) (string, error)

func (*EventMessage) Merge 

func (m *EventMessage) Merge(msg *EventMessage) *EventMessage

func (*EventMessage) ProtoMessage 

func (*EventMessage) ProtoMessage()

func (*EventMessage) Reset 

func (m *EventMessage) Reset()

func (*EventMessage) SetAttributes 

func (m *EventMessage) SetAttributes(attrs *Attributes) *EventMessage

func (*EventMessage) SetMessage 

func (m *EventMessage) SetMessage(msg string) *EventMessage

func (*EventMessage) SetPaths 

func (m *EventMessage) SetPaths(paths []*Path) *EventMessage

func (*EventMessage) SetString 

func (m *EventMessage) SetString(path []string, value string) *EventMessage

func (*EventMessage) String 

func (m *EventMessage) String() string

func (*EventMessage) WithAttributes 

func (m *EventMessage) WithAttributes(attrs *Attributes) *Attributes

todo: move to Attirbutes implementation

type EventMetadata 

type EventMetadata struct {
	Id  uint64               `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	Pcp *ParentChildPointers `protobuf:"bytes,2,opt,name=pcp" json:"pcp,omitempty"`
	Esp int64                `protobuf:"varint,3,opt,name=esp" json:"esp,omitempty"`
}

func (*EventMetadata) Descriptor 

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

func (*EventMetadata) GetEsp 

func (m *EventMetadata) GetEsp() int64

func (*EventMetadata) GetId 

func (m *EventMetadata) GetId() uint64

func (*EventMetadata) GetPcp 

func (m *EventMetadata) GetPcp() *ParentChildPointers

func (*EventMetadata) ProtoMessage 

func (*EventMetadata) ProtoMessage()

func (*EventMetadata) Reset 

func (m *EventMetadata) Reset()

func (*EventMetadata) String 

func (m *EventMetadata) String() string

type EventRecorder 

type EventRecorder struct {
	Type EventRecorderType `protobuf:"varint,1,opt,name=type,enum=context_bus.EventRecorderType" json:"type,omitempty"`
	Name string            `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
}

func (*EventRecorder) Descriptor 

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

func (*EventRecorder) GetName 

func (m *EventRecorder) GetName() string

func (*EventRecorder) GetType 

func (m *EventRecorder) GetType() EventRecorderType

func (*EventRecorder) Merge 

func (m *EventRecorder) Merge(recorder *EventRecorder) *EventRecorder

func (*EventRecorder) ProtoMessage 

func (*EventRecorder) ProtoMessage()

func (*EventRecorder) Reset 

func (m *EventRecorder) Reset()

func (*EventRecorder) String 

func (m *EventRecorder) String() string

type EventRecorderType 

type EventRecorderType int32
const (
	EventRecorderType_EventRecorderType_          EventRecorderType = 0
	EventRecorderType_EventRecorderServiceHandler EventRecorderType = 1
	EventRecorderType_EventRecorderFunction       EventRecorderType = 2
	EventRecorderType_EventRecorderThirdParty     EventRecorderType = 3
)

func (EventRecorderType) EnumDescriptor 

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

func (EventRecorderType) String 

func (x EventRecorderType) String() string

type EventRepresentation 

type EventRepresentation struct {
	When     *EventWhen     `protobuf:"bytes,1,opt,name=when" json:"when,omitempty"`
	Where    *EventWhere    `protobuf:"bytes,2,opt,name=where" json:"where,omitempty"`
	Recorder *EventRecorder `protobuf:"bytes,3,opt,name=recorder" json:"recorder,omitempty"`
	What     *EventWhat     `protobuf:"bytes,4,opt,name=what" json:"what,omitempty"`
}

func (*EventRepresentation) Descriptor 

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

func (*EventRepresentation) GetRecorder 

func (m *EventRepresentation) GetRecorder() *EventRecorder

func (*EventRepresentation) GetWhat 

func (m *EventRepresentation) GetWhat() *EventWhat

func (*EventRepresentation) GetWhen 

func (m *EventRepresentation) GetWhen() *EventWhen

func (*EventRepresentation) GetWhere 

func (m *EventRepresentation) GetWhere() *EventWhere

func (*EventRepresentation) ProtoMessage 

func (*EventRepresentation) ProtoMessage()

func (*EventRepresentation) Reset 

func (m *EventRepresentation) Reset()

func (*EventRepresentation) String 

func (m *EventRepresentation) String() string

func (*EventRepresentation) WithRecorder 

func (m *EventRepresentation) WithRecorder(recorder *EventRecorder) *EventRecorder

func (*EventRepresentation) WithWhat 

func (m *EventRepresentation) WithWhat(what *EventWhat) *EventWhat

func (*EventRepresentation) WithWhen 

func (m *EventRepresentation) WithWhen(when *EventWhen) *EventWhen

func (*EventRepresentation) WithWhere 

func (m *EventRepresentation) WithWhere(where *EventWhere) *EventWhere

type EventWhat 

type EventWhat struct {
	Application *EventMessage     `protobuf:"bytes,1,opt,name=application" json:"application,omitempty"`
	Libraries   *LibrariesMessage `protobuf:"bytes,2,opt,name=libraries" json:"libraries,omitempty"`
}

func (*EventWhat) Descriptor 

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

func (*EventWhat) GetApplication 

func (m *EventWhat) GetApplication() *EventMessage

func (*EventWhat) GetLibraries 

func (m *EventWhat) GetLibraries() *LibrariesMessage

func (*EventWhat) GetValue 

func (m *EventWhat) GetValue(path *Path) (string, error)

func (*EventWhat) Merge 

func (m *EventWhat) Merge(what *EventWhat) *EventWhat

func (*EventWhat) ProtoMessage 

func (*EventWhat) ProtoMessage()

func (*EventWhat) Reset 

func (m *EventWhat) Reset()

func (*EventWhat) String 

func (m *EventWhat) String() string

func (*EventWhat) WithApplication 

func (m *EventWhat) WithApplication(msg *EventMessage) *EventMessage

func (*EventWhat) WithLibrary 

func (m *EventWhat) WithLibrary(key string, msg *EventMessage) *EventMessage

type EventWhen 

type EventWhen struct {
	Time int64 `protobuf:"varint,1,opt,name=time" json:"time,omitempty"`
}

******************* Event Representation

func (*EventWhen) Descriptor 

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

func (*EventWhen) GetTime 

func (m *EventWhen) GetTime() int64

func (*EventWhen) Merge 

func (m *EventWhen) Merge(when *EventWhen) *EventWhen

func (*EventWhen) ProtoMessage 

func (*EventWhen) ProtoMessage()

func (*EventWhen) Reset 

func (m *EventWhen) Reset()

func (*EventWhen) String 

func (m *EventWhen) String() string

type EventWhere 

type EventWhere struct {
	Attrs      *Attributes `protobuf:"bytes,1,opt,name=attrs" json:"attrs,omitempty"`
	Stacktrace string      `protobuf:"bytes,2,opt,name=stacktrace" json:"stacktrace,omitempty"`
}

func (*EventWhere) Descriptor 

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

func (*EventWhere) GetAttrs 

func (m *EventWhere) GetAttrs() *Attributes

func (*EventWhere) GetStacktrace 

func (m *EventWhere) GetStacktrace() string

func (*EventWhere) Merge 

func (m *EventWhere) Merge(where *EventWhere) *EventWhere

func (*EventWhere) ProtoMessage 

func (*EventWhere) ProtoMessage()

func (*EventWhere) Reset 

func (m *EventWhere) Reset()

func (*EventWhere) String 

func (m *EventWhere) String() string

type FaultDelayParam 

type FaultDelayParam struct {
	Ms int64 `protobuf:"varint,1,opt,name=ms" json:"ms,omitempty"`
}

func (*FaultDelayParam) Descriptor 

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

func (*FaultDelayParam) GetMs 

func (m *FaultDelayParam) GetMs() int64

func (*FaultDelayParam) ProtoMessage 

func (*FaultDelayParam) ProtoMessage()

func (*FaultDelayParam) Reset 

func (m *FaultDelayParam) Reset()

func (*FaultDelayParam) String 

func (m *FaultDelayParam) String() string

type HardwareProfile 

type HardwareProfile struct {
	Cpu *CPUProfile `protobuf:"bytes,1,opt,name=cpu" json:"cpu,omitempty"`
	Mem *MemProfile `protobuf:"bytes,2,opt,name=mem" json:"mem,omitempty"`
	Net *NetProfile `protobuf:"bytes,3,opt,name=net" json:"net,omitempty"`
}

func (*HardwareProfile) Descriptor 

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

func (*HardwareProfile) GetCpu 

func (m *HardwareProfile) GetCpu() *CPUProfile

func (*HardwareProfile) GetMem 

func (m *HardwareProfile) GetMem() *MemProfile

func (*HardwareProfile) GetNet 

func (m *HardwareProfile) GetNet() *NetProfile

func (*HardwareProfile) ProtoMessage 

func (*HardwareProfile) ProtoMessage()

func (*HardwareProfile) Reset 

func (m *HardwareProfile) Reset()

func (*HardwareProfile) String 

func (m *HardwareProfile) String() string

type LanguageGo 

type LanguageGo struct {
	HeapSys       uint64  `protobuf:"varint,1,opt,name=HeapSys" json:"HeapSys,omitempty"`
	HeapAlloc     uint64  `protobuf:"varint,2,opt,name=HeapAlloc" json:"HeapAlloc,omitempty"`
	HeapInuse     uint64  `protobuf:"varint,3,opt,name=HeapInuse" json:"HeapInuse,omitempty"`
	StackSys      uint64  `protobuf:"varint,4,opt,name=StackSys" json:"StackSys,omitempty"`
	StackInuse    uint64  `protobuf:"varint,5,opt,name=StackInuse" json:"StackInuse,omitempty"`
	MSpanInuse    uint64  `protobuf:"varint,6,opt,name=MSpanInuse" json:"MSpanInuse,omitempty"`
	MSpanSys      uint64  `protobuf:"varint,7,opt,name=MSpanSys" json:"MSpanSys,omitempty"`
	MCacheInuse   uint64  `protobuf:"varint,8,opt,name=MCacheInuse" json:"MCacheInuse,omitempty"`
	MCacheSys     uint64  `protobuf:"varint,9,opt,name=MCacheSys" json:"MCacheSys,omitempty"`
	LastGC        uint64  `protobuf:"varint,101,opt,name=LastGC" json:"LastGC,omitempty"`
	NextGC        uint64  `protobuf:"varint,102,opt,name=NextGC" json:"NextGC,omitempty"`
	GCCPUFraction float64 `protobuf:"fixed64,103,opt,name=GCCPUFraction" json:"GCCPUFraction,omitempty"`
}

func (*LanguageGo) Descriptor 

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

func (*LanguageGo) GetGCCPUFraction 

func (m *LanguageGo) GetGCCPUFraction() float64

func (*LanguageGo) GetHeapAlloc 

func (m *LanguageGo) GetHeapAlloc() uint64

func (*LanguageGo) GetHeapInuse 

func (m *LanguageGo) GetHeapInuse() uint64

func (*LanguageGo) GetHeapSys 

func (m *LanguageGo) GetHeapSys() uint64

func (*LanguageGo) GetLastGC 

func (m *LanguageGo) GetLastGC() uint64

func (*LanguageGo) GetMCacheInuse 

func (m *LanguageGo) GetMCacheInuse() uint64

func (*LanguageGo) GetMCacheSys 

func (m *LanguageGo) GetMCacheSys() uint64

func (*LanguageGo) GetMSpanInuse 

func (m *LanguageGo) GetMSpanInuse() uint64

func (*LanguageGo) GetMSpanSys 

func (m *LanguageGo) GetMSpanSys() uint64

func (*LanguageGo) GetNextGC 

func (m *LanguageGo) GetNextGC() uint64

func (*LanguageGo) GetStackInuse 

func (m *LanguageGo) GetStackInuse() uint64

func (*LanguageGo) GetStackSys 

func (m *LanguageGo) GetStackSys() uint64

func (*LanguageGo) ProtoMessage 

func (*LanguageGo) ProtoMessage()

func (*LanguageGo) Reset 

func (m *LanguageGo) Reset()

func (*LanguageGo) String 

func (m *LanguageGo) String() string

type LanguageJava 

type LanguageJava struct {
}

func (*LanguageJava) Descriptor 

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

func (*LanguageJava) ProtoMessage 

func (*LanguageJava) ProtoMessage()

func (*LanguageJava) Reset 

func (m *LanguageJava) Reset()

func (*LanguageJava) String 

func (m *LanguageJava) String() string

type LanguageProfile 

type LanguageProfile struct {
	Type LanguageType `protobuf:"varint,1,opt,name=type,enum=context_bus.LanguageType" json:"type,omitempty"`
	// Types that are valid to be assigned to Profile:
	//	*LanguageProfile_Go
	//	*LanguageProfile_Java
	Profile isLanguageProfile_Profile `protobuf_oneof:"Profile"`
}

func (*LanguageProfile) Descriptor 

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

func (*LanguageProfile) GetGo 

func (m *LanguageProfile) GetGo() *LanguageGo

func (*LanguageProfile) GetJava 

func (m *LanguageProfile) GetJava() *LanguageJava

func (*LanguageProfile) GetProfile 

func (m *LanguageProfile) GetProfile() isLanguageProfile_Profile

func (*LanguageProfile) GetType 

func (m *LanguageProfile) GetType() LanguageType

func (*LanguageProfile) ProtoMessage 

func (*LanguageProfile) ProtoMessage()

func (*LanguageProfile) Reset 

func (m *LanguageProfile) Reset()

func (*LanguageProfile) String 

func (m *LanguageProfile) String() string

func (*LanguageProfile) XXX_OneofFuncs 

func (*LanguageProfile) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, func(msg proto1.Message, tag, wire int, b *proto1.Buffer) (bool, error), func(msg proto1.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type LanguageProfile_Go 

type LanguageProfile_Go struct {
	Go *LanguageGo `protobuf:"bytes,2002,opt,name=go,oneof"`
}

type LanguageProfile_Java 

type LanguageProfile_Java struct {
	Java *LanguageJava `protobuf:"bytes,2003,opt,name=java,oneof"`
}

type LanguageType 

type LanguageType int32
const (
	LanguageType_LanguageType_ LanguageType = 0
	LanguageType_Other         LanguageType = 1
	LanguageType_Golang        LanguageType = 2
	LanguageType_Java          LanguageType = 3
)

func (LanguageType) EnumDescriptor 

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

func (LanguageType) String 

func (x LanguageType) String() string

type LibrariesMessage 

type LibrariesMessage struct {
	Libraries map[string]*EventMessage `` /* 138-byte string literal not displayed */
}

func (*LibrariesMessage) Descriptor 

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

func (*LibrariesMessage) GetLibraries 

func (m *LibrariesMessage) GetLibraries() map[string]*EventMessage

func (*LibrariesMessage) GetValue 

func (m *LibrariesMessage) GetValue(path []string) (string, error)

func (*LibrariesMessage) Merge 

func (m *LibrariesMessage) Merge(libs *LibrariesMessage) *LibrariesMessage

func (*LibrariesMessage) ProtoMessage 

func (*LibrariesMessage) ProtoMessage()

func (*LibrariesMessage) Reset 

func (m *LibrariesMessage) Reset()

func (*LibrariesMessage) String 

func (m *LibrariesMessage) String() string

type LogOutType 

type LogOutType int32
const (
	LogOutType_LogOutType_ LogOutType = 0
	LogOutType_Stdout      LogOutType = 1
	LogOutType_Stderr      LogOutType = 2
	LogOutType_File        LogOutType = 3
)

func (LogOutType) EnumDescriptor 

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

func (LogOutType) String 

func (x LogOutType) String() string

type LoggingConfigure 

type LoggingConfigure struct {
	Timestamp  *TimestampConfigure   `protobuf:"bytes,1,opt,name=timestamp" json:"timestamp,omitempty"`
	Stacktrace *StackTraceConfigure  `protobuf:"bytes,2,opt,name=stacktrace" json:"stacktrace,omitempty"`
	Attrs      []*AttributeConfigure `protobuf:"bytes,3,rep,name=attrs" json:"attrs,omitempty"`
	Out        LogOutType            `protobuf:"varint,4,opt,name=out,enum=context_bus.LogOutType" json:"out,omitempty"`
}

func NewLoggingConfigure 

func NewLoggingConfigure(ts *TimestampConfigure, st *StackTraceConfigure, attrs []*AttributeConfigure, out LogOutType) *LoggingConfigure

func (*LoggingConfigure) Descriptor 

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

func (*LoggingConfigure) GetAttrs 

func (m *LoggingConfigure) GetAttrs() []*AttributeConfigure

func (*LoggingConfigure) GetOut 

func (m *LoggingConfigure) GetOut() LogOutType

func (*LoggingConfigure) GetStacktrace 

func (m *LoggingConfigure) GetStacktrace() *StackTraceConfigure

func (*LoggingConfigure) GetTimestamp 

func (m *LoggingConfigure) GetTimestamp() *TimestampConfigure

func (*LoggingConfigure) ProtoMessage 

func (*LoggingConfigure) ProtoMessage()

func (*LoggingConfigure) Reset 

func (m *LoggingConfigure) Reset()

func (*LoggingConfigure) String 

func (m *LoggingConfigure) String() string

type LogicType 

type LogicType int32
const (
	LogicType_LogicType_ LogicType = 0
	LogicType_And_       LogicType = 1
	LogicType_Or_        LogicType = 2
)

func (LogicType) EnumDescriptor 

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

func (LogicType) String 

func (x LogicType) String() string

type MemProfile 

type MemProfile struct {
	Total       uint64  `protobuf:"varint,1,opt,name=total" json:"total,omitempty"`
	Available   uint64  `protobuf:"varint,2,opt,name=available" json:"available,omitempty"`
	Used        uint64  `protobuf:"varint,3,opt,name=used" json:"used,omitempty"`
	UsedPercent float64 `protobuf:"fixed64,4,opt,name=usedPercent" json:"usedPercent,omitempty"`
	Free        uint64  `protobuf:"varint,5,opt,name=free" json:"free,omitempty"`
}

func (*MemProfile) Descriptor 

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

func (*MemProfile) GetAvailable 

func (m *MemProfile) GetAvailable() uint64

func (*MemProfile) GetFree 

func (m *MemProfile) GetFree() uint64

func (*MemProfile) GetTotal 

func (m *MemProfile) GetTotal() uint64

func (*MemProfile) GetUsed 

func (m *MemProfile) GetUsed() uint64

func (*MemProfile) GetUsedPercent 

func (m *MemProfile) GetUsedPercent() float64

func (*MemProfile) ProtoMessage 

func (*MemProfile) ProtoMessage()

func (*MemProfile) Reset 

func (m *MemProfile) Reset()

func (*MemProfile) String 

func (m *MemProfile) String() string

type MessageType 

type MessageType int32

******************* from 3mb WIP 

const (
	MessageType_MessageType_     MessageType = 0
	MessageType_Message_Request  MessageType = 1
	MessageType_Message_Response MessageType = 2
)

func (MessageType) EnumDescriptor 

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

func (MessageType) String 

func (x MessageType) String() string

type MetricType 

type MetricType int32
const (
	MetricType_MetricType_ MetricType = 0
	MetricType_Counter     MetricType = 1
	MetricType_Gauge       MetricType = 2
	MetricType_Histogram   MetricType = 3
	MetricType_Summary     MetricType = 4
)

func (MetricType) EnumDescriptor 

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

func (MetricType) String 

func (x MetricType) String() string

type MetricsConfigure 

type MetricsConfigure struct {
	Type     MetricType            `protobuf:"varint,1,opt,name=type,enum=context_bus.MetricType" json:"type,omitempty"`
	OptsId   int64                 `protobuf:"varint,2,opt,name=opts_id,json=optsId" json:"opts_id,omitempty"`
	Name     string                `protobuf:"bytes,3,opt,name=name" json:"name,omitempty"`
	PrevName string                `protobuf:"bytes,4,opt,name=prev_name,json=prevName" json:"prev_name,omitempty"`
	Attrs    []*AttributeConfigure `protobuf:"bytes,5,rep,name=attrs" json:"attrs,omitempty"`
}

func (*MetricsConfigure) Descriptor 

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

func (*MetricsConfigure) GetAttrs 

func (m *MetricsConfigure) GetAttrs() []*AttributeConfigure

func (*MetricsConfigure) GetName 

func (m *MetricsConfigure) GetName() string

func (*MetricsConfigure) GetOptsId 

func (m *MetricsConfigure) GetOptsId() int64

func (*MetricsConfigure) GetPrevName 

func (m *MetricsConfigure) GetPrevName() string

func (*MetricsConfigure) GetType 

func (m *MetricsConfigure) GetType() MetricType

func (*MetricsConfigure) ProtoMessage 

func (*MetricsConfigure) ProtoMessage()

func (*MetricsConfigure) Reset 

func (m *MetricsConfigure) Reset()

func (*MetricsConfigure) String 

func (m *MetricsConfigure) String() string

type NetProfile 

type NetProfile struct {
	BytesSent   uint64 `protobuf:"varint,1,opt,name=bytesSent" json:"bytesSent,omitempty"`
	BytesRecv   uint64 `protobuf:"varint,2,opt,name=bytesRecv" json:"bytesRecv,omitempty"`
	PacketsSent uint64 `protobuf:"varint,3,opt,name=packetsSent" json:"packetsSent,omitempty"`
	PacketsRecv uint64 `protobuf:"varint,4,opt,name=packetsRecv" json:"packetsRecv,omitempty"`
	Errin       uint64 `protobuf:"varint,5,opt,name=errin" json:"errin,omitempty"`
	Errout      uint64 `protobuf:"varint,6,opt,name=errout" json:"errout,omitempty"`
	Dropin      uint64 `protobuf:"varint,7,opt,name=dropin" json:"dropin,omitempty"`
	Dropout     uint64 `protobuf:"varint,8,opt,name=dropout" json:"dropout,omitempty"`
}

func (*NetProfile) Descriptor 

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

func (*NetProfile) GetBytesRecv 

func (m *NetProfile) GetBytesRecv() uint64

func (*NetProfile) GetBytesSent 

func (m *NetProfile) GetBytesSent() uint64

func (*NetProfile) GetDropin 

func (m *NetProfile) GetDropin() uint64

func (*NetProfile) GetDropout 

func (m *NetProfile) GetDropout() uint64

func (*NetProfile) GetErrin 

func (m *NetProfile) GetErrin() uint64

func (*NetProfile) GetErrout 

func (m *NetProfile) GetErrout() uint64

func (*NetProfile) GetPacketsRecv 

func (m *NetProfile) GetPacketsRecv() uint64

func (*NetProfile) GetPacketsSent 

func (m *NetProfile) GetPacketsSent() uint64

func (*NetProfile) ProtoMessage 

func (*NetProfile) ProtoMessage()

func (*NetProfile) Reset 

func (m *NetProfile) Reset()

func (*NetProfile) String 

func (m *NetProfile) String() string

type ObservationConfigure 

type ObservationConfigure struct {
	Type    ObservationType     `protobuf:"varint,1,opt,name=type,enum=context_bus.ObservationType" json:"type,omitempty"`
	Logging *LoggingConfigure   `protobuf:"bytes,2,opt,name=logging" json:"logging,omitempty"`
	Tracing *TracingConfigure   `protobuf:"bytes,3,opt,name=tracing" json:"tracing,omitempty"`
	Metrics []*MetricsConfigure `protobuf:"bytes,4,rep,name=metrics" json:"metrics,omitempty"`
}

func (*ObservationConfigure) Descriptor 

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

func (*ObservationConfigure) GetLogging 

func (m *ObservationConfigure) GetLogging() *LoggingConfigure

func (*ObservationConfigure) GetMetrics 

func (m *ObservationConfigure) GetMetrics() []*MetricsConfigure

func (*ObservationConfigure) GetTracing 

func (m *ObservationConfigure) GetTracing() *TracingConfigure

func (*ObservationConfigure) GetType 

func (m *ObservationConfigure) GetType() ObservationType

func (*ObservationConfigure) ProtoMessage 

func (*ObservationConfigure) ProtoMessage()

func (*ObservationConfigure) Reset 

func (m *ObservationConfigure) Reset()

func (*ObservationConfigure) String 

func (m *ObservationConfigure) String() string

type ObservationType 

type ObservationType int32
const (
	ObservationType_ObservationType_  ObservationType = 0
	ObservationType_ObservationSingle ObservationType = 1
	ObservationType_ObservationStart  ObservationType = 2
	ObservationType_ObservationInter  ObservationType = 3
	ObservationType_ObservationEnd    ObservationType = 4
)

func (ObservationType) EnumDescriptor 

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

func (ObservationType) String 

func (x ObservationType) String() string

type ParentChildPointers 

type ParentChildPointers struct {
	Parent   uint64   `protobuf:"varint,1,opt,name=parent" json:"parent,omitempty"`
	Children []uint64 `protobuf:"varint,2,rep,packed,name=children" json:"children,omitempty"`
}

******************* Event Metadata

func (*ParentChildPointers) Descriptor 

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

func (*ParentChildPointers) GetChildren 

func (m *ParentChildPointers) GetChildren() []uint64

func (*ParentChildPointers) GetParent 

func (m *ParentChildPointers) GetParent() uint64

func (*ParentChildPointers) ProtoMessage 

func (*ParentChildPointers) ProtoMessage()

func (*ParentChildPointers) Reset 

func (m *ParentChildPointers) Reset()

func (*ParentChildPointers) String 

func (m *ParentChildPointers) String() string

type Path 

type Path struct {
	Type PathType `protobuf:"varint,1,opt,name=type,enum=context_bus.PathType" json:"type,omitempty"`
	Path []string `protobuf:"bytes,2,rep,name=path" json:"path,omitempty"`
}

func NewPath 

func NewPath(typ PathType, path []string) *Path

func (*Path) Descriptor 

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

func (*Path) GetPath 

func (m *Path) GetPath() []string

func (*Path) GetType 

func (m *Path) GetType() PathType

func (*Path) ProtoMessage 

func (*Path) ProtoMessage()

func (*Path) Reset 

func (m *Path) Reset()

func (*Path) String 

func (m *Path) String() string

type PathType 

type PathType int32
const (
	PathType_PathType_   PathType = 0
	PathType_Application PathType = 1
	PathType_Library     PathType = 2
)

func (PathType) EnumDescriptor 

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

func (PathType) String 

func (x PathType) String() string

type Payload 

type Payload struct {
	// workflow-level
	RequestId int64                  `protobuf:"varint,1,opt,name=request_id,json=requestId" json:"request_id,omitempty"`
	ConfigId  int64                  `protobuf:"varint,2,opt,name=config_id,json=configId" json:"config_id,omitempty"`
	Snapshots *PrerequisiteSnapshots `protobuf:"bytes,3,opt,name=snapshots" json:"snapshots,omitempty"`
	Addition  *PrerequisiteSnapshots `protobuf:"bytes,4,opt,name=addition" json:"addition,omitempty"`
	// message-level
	Parent *SpanMetadata `protobuf:"bytes,11,opt,name=parent" json:"parent,omitempty"`
	MType  MessageType   `protobuf:"varint,12,opt,name=m_type,json=mType,enum=context_bus.MessageType" json:"m_type,omitempty"`
	Uuid   string        `protobuf:"bytes,13,opt,name=uuid" json:"uuid,omitempty"`
}

******************* Integration *******************

func (*Payload) Descriptor 

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

func (*Payload) GetAddition 

func (m *Payload) GetAddition() *PrerequisiteSnapshots

func (*Payload) GetConfigId 

func (m *Payload) GetConfigId() int64

func (*Payload) GetMType 

func (m *Payload) GetMType() MessageType

func (*Payload) GetParent 

func (m *Payload) GetParent() *SpanMetadata

func (*Payload) GetRequestId 

func (m *Payload) GetRequestId() int64

func (*Payload) GetSnapshots 

func (m *Payload) GetSnapshots() *PrerequisiteSnapshots

func (*Payload) GetUuid 

func (m *Payload) GetUuid() string

func (*Payload) ProtoMessage 

func (*Payload) ProtoMessage()

func (*Payload) Reset 

func (m *Payload) Reset()

func (*Payload) String 

func (m *Payload) String() string

type PrerequisiteLogic 

type PrerequisiteLogic struct {
	Type   LogicType `protobuf:"varint,1,opt,name=type,enum=context_bus.LogicType" json:"type,omitempty"`
	Parent int64     `protobuf:"varint,100,opt,name=parent" json:"parent,omitempty"`
	List   []int64   `protobuf:"varint,101,rep,packed,name=list" json:"list,omitempty"`
}

func NewPrerequisiteLogic 

func NewPrerequisiteLogic(typ LogicType, parent int64, list []int64) *PrerequisiteLogic

func (*PrerequisiteLogic) Descriptor 

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

func (*PrerequisiteLogic) GetList 

func (m *PrerequisiteLogic) GetList() []int64

func (*PrerequisiteLogic) GetParent 

func (m *PrerequisiteLogic) GetParent() int64

func (*PrerequisiteLogic) GetType 

func (m *PrerequisiteLogic) GetType() LogicType

func (*PrerequisiteLogic) ProtoMessage 

func (*PrerequisiteLogic) ProtoMessage()

func (*PrerequisiteLogic) Reset 

func (m *PrerequisiteLogic) Reset()

func (*PrerequisiteLogic) String 

func (m *PrerequisiteLogic) String() string

type PrerequisiteMessage 

type PrerequisiteMessage struct {
	Name     string         `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	CondTree *ConditionTree `protobuf:"bytes,2,opt,name=cond_tree,json=condTree" json:"cond_tree,omitempty"`
	Parent   int64          `protobuf:"varint,100,opt,name=parent" json:"parent,omitempty"`
}

func NewPrerequisiteMessage 

func NewPrerequisiteMessage(name string, condTree *ConditionTree, parent int64, list []int64) *PrerequisiteMessage

func (*PrerequisiteMessage) Descriptor 

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

func (*PrerequisiteMessage) GetCondTree 

func (m *PrerequisiteMessage) GetCondTree() *ConditionTree

func (*PrerequisiteMessage) GetName 

func (m *PrerequisiteMessage) GetName() string

func (*PrerequisiteMessage) GetParent 

func (m *PrerequisiteMessage) GetParent() int64

func (*PrerequisiteMessage) ProtoMessage 

func (*PrerequisiteMessage) ProtoMessage()

func (*PrerequisiteMessage) Reset 

func (m *PrerequisiteMessage) Reset()

func (*PrerequisiteMessage) String 

func (m *PrerequisiteMessage) String() string

type PrerequisiteNode 

type PrerequisiteNode struct {
	Id      int64                `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	Type    PrerequisiteNodeType `protobuf:"varint,2,opt,name=type,enum=context_bus.PrerequisiteNodeType" json:"type,omitempty"`
	Message *PrerequisiteMessage `protobuf:"bytes,3,opt,name=message" json:"message,omitempty"`
	Logic   *PrerequisiteLogic   `protobuf:"bytes,4,opt,name=logic" json:"logic,omitempty"`
}

func NewPrerequisiteLogicNode 

func NewPrerequisiteLogicNode(id int64, typ LogicType, parent int64, list []int64) *PrerequisiteNode

func NewPrerequisiteMessageNode 

func NewPrerequisiteMessageNode(id int64, name string, condTree *ConditionTree, parent int64, list []int64) *PrerequisiteNode

func (*PrerequisiteNode) Descriptor 

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

func (*PrerequisiteNode) GetId 

func (m *PrerequisiteNode) GetId() int64

func (*PrerequisiteNode) GetLogic 

func (m *PrerequisiteNode) GetLogic() *PrerequisiteLogic

func (*PrerequisiteNode) GetMessage 

func (m *PrerequisiteNode) GetMessage() *PrerequisiteMessage

func (*PrerequisiteNode) GetType 

func (m *PrerequisiteNode) GetType() PrerequisiteNodeType

func (*PrerequisiteNode) ProtoMessage 

func (*PrerequisiteNode) ProtoMessage()

func (*PrerequisiteNode) Reset 

func (m *PrerequisiteNode) Reset()

func (*PrerequisiteNode) String 

func (m *PrerequisiteNode) String() string

type PrerequisiteNodeType 

type PrerequisiteNodeType int32
const (
	PrerequisiteNodeType_PrerequisiteNodeType_ PrerequisiteNodeType = 0
	PrerequisiteNodeType_PrerequisiteMessage_  PrerequisiteNodeType = 1
	PrerequisiteNodeType_PrerequisiteLogic_    PrerequisiteNodeType = 2
)

func (PrerequisiteNodeType) EnumDescriptor 

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

func (PrerequisiteNodeType) String 

func (x PrerequisiteNodeType) String() string

type PrerequisiteSnapshot 

type PrerequisiteSnapshot struct {
	Value []int64 `protobuf:"varint,1,rep,packed,name=value" json:"value,omitempty"`
	Acc   bool    `protobuf:"varint,2,opt,name=acc" json:"acc,omitempty"`
}

func (*PrerequisiteSnapshot) Clone 

func (m *PrerequisiteSnapshot) Clone() *PrerequisiteSnapshot

func (*PrerequisiteSnapshot) Descriptor 

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

func (*PrerequisiteSnapshot) GetAcc 

func (m *PrerequisiteSnapshot) GetAcc() bool

func (*PrerequisiteSnapshot) GetValue 

func (m *PrerequisiteSnapshot) GetValue() []int64

func (*PrerequisiteSnapshot) MergeOffset 

func (m *PrerequisiteSnapshot) MergeOffset(src *PrerequisiteSnapshot)

func (*PrerequisiteSnapshot) ProtoMessage 

func (*PrerequisiteSnapshot) ProtoMessage()

func (*PrerequisiteSnapshot) Reset 

func (m *PrerequisiteSnapshot) Reset()

func (*PrerequisiteSnapshot) String 

func (m *PrerequisiteSnapshot) String() string

type PrerequisiteSnapshots 

type PrerequisiteSnapshots struct {
	Snapshots map[string]*PrerequisiteSnapshot `` /* 138-byte string literal not displayed */
}

func (*PrerequisiteSnapshots) Clone 

func (m *PrerequisiteSnapshots) Clone() *PrerequisiteSnapshots

func (*PrerequisiteSnapshots) Descriptor 

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

func (*PrerequisiteSnapshots) GetPrerequisiteSnapshot 

func (m *PrerequisiteSnapshots) GetPrerequisiteSnapshot(name string) *PrerequisiteSnapshot

func (*PrerequisiteSnapshots) GetSnapshots 

func (m *PrerequisiteSnapshots) GetSnapshots() map[string]*PrerequisiteSnapshot

func (*PrerequisiteSnapshots) MergeOffset 

func (m *PrerequisiteSnapshots) MergeOffset(src *PrerequisiteSnapshots)

func (*PrerequisiteSnapshots) ProtoMessage 

func (*PrerequisiteSnapshots) ProtoMessage()

func (*PrerequisiteSnapshots) Reset 

func (m *PrerequisiteSnapshots) Reset()

func (*PrerequisiteSnapshots) String 

func (m *PrerequisiteSnapshots) String() string

type PrerequisiteTree 

type PrerequisiteTree struct {
	Nodes   []*PrerequisiteNode `protobuf:"bytes,1,rep,name=nodes" json:"nodes,omitempty"`
	LeafIDs []int64             `protobuf:"varint,2,rep,packed,name=leafIDs" json:"leafIDs,omitempty"`
}

prerequisite tree

func (*PrerequisiteTree) Descriptor 

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

func (*PrerequisiteTree) GetLeafIDs 

func (m *PrerequisiteTree) GetLeafIDs() []int64

func (*PrerequisiteTree) GetNodes 

func (m *PrerequisiteTree) GetNodes() []*PrerequisiteNode

func (*PrerequisiteTree) ProtoMessage 

func (*PrerequisiteTree) ProtoMessage()

func (*PrerequisiteTree) Reset 

func (m *PrerequisiteTree) Reset()

func (*PrerequisiteTree) String 

func (m *PrerequisiteTree) String() string

type PrometheusConfiguration 

type PrometheusConfiguration struct {
	Counters   []*PrometheusOpts          `protobuf:"bytes,1,rep,name=counters" json:"counters,omitempty"`
	Gauges     []*PrometheusOpts          `protobuf:"bytes,2,rep,name=gauges" json:"gauges,omitempty"`
	Histograms []*PrometheusHistogramOpts `protobuf:"bytes,3,rep,name=histograms" json:"histograms,omitempty"`
	Summaries  []*PrometheusSummaryOpts   `protobuf:"bytes,4,rep,name=summaries" json:"summaries,omitempty"`
}

func (*PrometheusConfiguration) Descriptor 

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

func (*PrometheusConfiguration) GetCounters 

func (m *PrometheusConfiguration) GetCounters() []*PrometheusOpts

func (*PrometheusConfiguration) GetGauges 

func (m *PrometheusConfiguration) GetGauges() []*PrometheusOpts

func (*PrometheusConfiguration) GetHistograms 

func (m *PrometheusConfiguration) GetHistograms() []*PrometheusHistogramOpts

func (*PrometheusConfiguration) GetSummaries 

func (m *PrometheusConfiguration) GetSummaries() []*PrometheusSummaryOpts

func (*PrometheusConfiguration) ProtoMessage 

func (*PrometheusConfiguration) ProtoMessage()

func (*PrometheusConfiguration) Reset 

func (m *PrometheusConfiguration) Reset()

func (*PrometheusConfiguration) String 

func (m *PrometheusConfiguration) String() string

type PrometheusHistogramOpts 

type PrometheusHistogramOpts struct {
	Id          int64             `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	Namespace   string            `protobuf:"bytes,2,opt,name=namespace" json:"namespace,omitempty"`
	Subsystem   string            `protobuf:"bytes,3,opt,name=subsystem" json:"subsystem,omitempty"`
	Name        string            `protobuf:"bytes,4,opt,name=name" json:"name,omitempty"`
	Help        string            `protobuf:"bytes,5,opt,name=help" json:"help,omitempty"`
	ConstLabels map[string]string `` /* 161-byte string literal not displayed */
	Buckets     []float64         `protobuf:"fixed64,7,rep,packed,name=buckets" json:"buckets,omitempty"`
	LabelNames  []string          `protobuf:"bytes,8,rep,name=label_names,json=labelNames" json:"label_names,omitempty"`
}

func (*PrometheusHistogramOpts) Descriptor 

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

func (*PrometheusHistogramOpts) GetBuckets 

func (m *PrometheusHistogramOpts) GetBuckets() []float64

func (*PrometheusHistogramOpts) GetConstLabels 

func (m *PrometheusHistogramOpts) GetConstLabels() map[string]string

func (*PrometheusHistogramOpts) GetHelp 

func (m *PrometheusHistogramOpts) GetHelp() string

func (*PrometheusHistogramOpts) GetId 

func (m *PrometheusHistogramOpts) GetId() int64

func (*PrometheusHistogramOpts) GetLabelNames 

func (m *PrometheusHistogramOpts) GetLabelNames() []string

func (*PrometheusHistogramOpts) GetName 

func (m *PrometheusHistogramOpts) GetName() string

func (*PrometheusHistogramOpts) GetNamespace 

func (m *PrometheusHistogramOpts) GetNamespace() string

func (*PrometheusHistogramOpts) GetSubsystem 

func (m *PrometheusHistogramOpts) GetSubsystem() string

func (*PrometheusHistogramOpts) ProtoMessage 

func (*PrometheusHistogramOpts) ProtoMessage()

func (*PrometheusHistogramOpts) Reset 

func (m *PrometheusHistogramOpts) Reset()

func (*PrometheusHistogramOpts) String 

func (m *PrometheusHistogramOpts) String() string

func (*PrometheusHistogramOpts) ToPrometheus 

func (m *PrometheusHistogramOpts) ToPrometheus() (prometheus.HistogramOpts, []string)

type PrometheusOpts 

type PrometheusOpts struct {
	Id          int64             `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	Namespace   string            `protobuf:"bytes,2,opt,name=namespace" json:"namespace,omitempty"`
	Subsystem   string            `protobuf:"bytes,3,opt,name=subsystem" json:"subsystem,omitempty"`
	Name        string            `protobuf:"bytes,4,opt,name=name" json:"name,omitempty"`
	Help        string            `protobuf:"bytes,5,opt,name=help" json:"help,omitempty"`
	ConstLabels map[string]string `` /* 161-byte string literal not displayed */
	LabelNames  []string          `protobuf:"bytes,7,rep,name=label_names,json=labelNames" json:"label_names,omitempty"`
}

******************* Prometheus *******************

func (*PrometheusOpts) Descriptor 

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

func (*PrometheusOpts) GetConstLabels 

func (m *PrometheusOpts) GetConstLabels() map[string]string

func (*PrometheusOpts) GetHelp 

func (m *PrometheusOpts) GetHelp() string

func (*PrometheusOpts) GetId 

func (m *PrometheusOpts) GetId() int64

func (*PrometheusOpts) GetLabelNames 

func (m *PrometheusOpts) GetLabelNames() []string

func (*PrometheusOpts) GetName 

func (m *PrometheusOpts) GetName() string

func (*PrometheusOpts) GetNamespace 

func (m *PrometheusOpts) GetNamespace() string

func (*PrometheusOpts) GetSubsystem 

func (m *PrometheusOpts) GetSubsystem() string

func (*PrometheusOpts) ProtoMessage 

func (*PrometheusOpts) ProtoMessage()

func (*PrometheusOpts) Reset 

func (m *PrometheusOpts) Reset()

func (*PrometheusOpts) String 

func (m *PrometheusOpts) String() string

func (*PrometheusOpts) ToPrometheusCounterOpts 

func (m *PrometheusOpts) ToPrometheusCounterOpts() (prometheus.CounterOpts, []string)

func (*PrometheusOpts) ToPrometheusGaugeOpts 

func (m *PrometheusOpts) ToPrometheusGaugeOpts() (prometheus.GaugeOpts, []string)

type PrometheusSummaryObjective 

type PrometheusSummaryObjective struct {
	Id    int64   `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	Key   float64 `protobuf:"fixed64,2,opt,name=key" json:"key,omitempty"`
	Value float64 `protobuf:"fixed64,3,opt,name=value" json:"value,omitempty"`
}

func (*PrometheusSummaryObjective) Descriptor 

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

func (*PrometheusSummaryObjective) GetId 

func (m *PrometheusSummaryObjective) GetId() int64

func (*PrometheusSummaryObjective) GetKey 

func (m *PrometheusSummaryObjective) GetKey() float64

func (*PrometheusSummaryObjective) GetValue 

func (m *PrometheusSummaryObjective) GetValue() float64

func (*PrometheusSummaryObjective) ProtoMessage 

func (*PrometheusSummaryObjective) ProtoMessage()

func (*PrometheusSummaryObjective) Reset 

func (m *PrometheusSummaryObjective) Reset()

func (*PrometheusSummaryObjective) String 

func (m *PrometheusSummaryObjective) String() string

type PrometheusSummaryOpts 

type PrometheusSummaryOpts struct {
	Id          int64                         `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	Namespace   string                        `protobuf:"bytes,2,opt,name=namespace" json:"namespace,omitempty"`
	Subsystem   string                        `protobuf:"bytes,3,opt,name=subsystem" json:"subsystem,omitempty"`
	Name        string                        `protobuf:"bytes,4,opt,name=name" json:"name,omitempty"`
	Help        string                        `protobuf:"bytes,5,opt,name=help" json:"help,omitempty"`
	ConstLabels map[string]string             `` /* 161-byte string literal not displayed */
	Objectives  []*PrometheusSummaryObjective `protobuf:"bytes,7,rep,name=objectives" json:"objectives,omitempty"`
	MaxAge      int64                         `protobuf:"varint,8,opt,name=max_age,json=maxAge" json:"max_age,omitempty"`
	AgeBuckets  uint32                        `protobuf:"varint,9,opt,name=age_buckets,json=ageBuckets" json:"age_buckets,omitempty"`
	BufCap      uint32                        `protobuf:"varint,10,opt,name=buf_cap,json=bufCap" json:"buf_cap,omitempty"`
	LabelNames  []string                      `protobuf:"bytes,11,rep,name=label_names,json=labelNames" json:"label_names,omitempty"`
}

func (*PrometheusSummaryOpts) Descriptor 

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

func (*PrometheusSummaryOpts) GetAgeBuckets 

func (m *PrometheusSummaryOpts) GetAgeBuckets() uint32

func (*PrometheusSummaryOpts) GetBufCap 

func (m *PrometheusSummaryOpts) GetBufCap() uint32

func (*PrometheusSummaryOpts) GetConstLabels 

func (m *PrometheusSummaryOpts) GetConstLabels() map[string]string

func (*PrometheusSummaryOpts) GetHelp 

func (m *PrometheusSummaryOpts) GetHelp() string

func (*PrometheusSummaryOpts) GetId 

func (m *PrometheusSummaryOpts) GetId() int64

func (*PrometheusSummaryOpts) GetLabelNames 

func (m *PrometheusSummaryOpts) GetLabelNames() []string

func (*PrometheusSummaryOpts) GetMaxAge 

func (m *PrometheusSummaryOpts) GetMaxAge() int64

func (*PrometheusSummaryOpts) GetName 

func (m *PrometheusSummaryOpts) GetName() string

func (*PrometheusSummaryOpts) GetNamespace 

func (m *PrometheusSummaryOpts) GetNamespace() string

func (*PrometheusSummaryOpts) GetObjectives 

func (m *PrometheusSummaryOpts) GetObjectives() []*PrometheusSummaryObjective

func (*PrometheusSummaryOpts) GetSubsystem 

func (m *PrometheusSummaryOpts) GetSubsystem() string

func (*PrometheusSummaryOpts) ProtoMessage 

func (*PrometheusSummaryOpts) ProtoMessage()

func (*PrometheusSummaryOpts) Reset 

func (m *PrometheusSummaryOpts) Reset()

func (*PrometheusSummaryOpts) String 

func (m *PrometheusSummaryOpts) String() string

func (*PrometheusSummaryOpts) ToPrometheus 

func (m *PrometheusSummaryOpts) ToPrometheus() (prometheus.SummaryOpts, []string)

type ReactionConfigure 

type ReactionConfigure struct {
	Type ReactionType `protobuf:"varint,1,opt,name=type,enum=context_bus.ReactionType" json:"type,omitempty"`
	// Types that are valid to be assigned to Params:
	//	*ReactionConfigure_FaultDelay
	//	*ReactionConfigure_TrafficBalance
	//	*ReactionConfigure_TrafficRouting
	Params  isReactionConfigure_Params `protobuf_oneof:"params"`
	PreTree *PrerequisiteTree          `protobuf:"bytes,3,opt,name=pre_tree,json=preTree" json:"pre_tree,omitempty"`
}

func (*ReactionConfigure) Descriptor 

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

func (*ReactionConfigure) GetFaultDelay 

func (m *ReactionConfigure) GetFaultDelay() *FaultDelayParam

func (*ReactionConfigure) GetParams 

func (m *ReactionConfigure) GetParams() isReactionConfigure_Params

func (*ReactionConfigure) GetPreTree 

func (m *ReactionConfigure) GetPreTree() *PrerequisiteTree

func (*ReactionConfigure) GetTrafficBalance 

func (m *ReactionConfigure) GetTrafficBalance() *TrafficBalanceParam

func (*ReactionConfigure) GetTrafficRouting 

func (m *ReactionConfigure) GetTrafficRouting() *TrafficRoutingParam

func (*ReactionConfigure) GetType 

func (m *ReactionConfigure) GetType() ReactionType

func (*ReactionConfigure) ProtoMessage 

func (*ReactionConfigure) ProtoMessage()

func (*ReactionConfigure) Reset 

func (m *ReactionConfigure) Reset()

func (*ReactionConfigure) String 

func (m *ReactionConfigure) String() string

func (*ReactionConfigure) XXX_OneofFuncs 

func (*ReactionConfigure) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, func(msg proto1.Message, tag, wire int, b *proto1.Buffer) (bool, error), func(msg proto1.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type ReactionConfigure_FaultDelay 

type ReactionConfigure_FaultDelay struct {
	FaultDelay *FaultDelayParam `protobuf:"bytes,2002,opt,name=FaultDelay,oneof"`
}

type ReactionConfigure_TrafficBalance 

type ReactionConfigure_TrafficBalance struct {
	TrafficBalance *TrafficBalanceParam `protobuf:"bytes,2101,opt,name=TrafficBalance,oneof"`
}

type ReactionConfigure_TrafficRouting 

type ReactionConfigure_TrafficRouting struct {
	TrafficRouting *TrafficRoutingParam `protobuf:"bytes,2102,opt,name=TrafficRouting,oneof"`
}

type ReactionType 

type ReactionType int32
const (
	ReactionType_ReactionType_ ReactionType = 0
	// fault injection
	ReactionType_FaultCrash ReactionType = 1
	ReactionType_FaultDelay ReactionType = 2
	ReactionType_FaultDrop  ReactionType = 3
	// traffic (e.g., load-balancing, traffic shaping)
	ReactionType_TrafficBalance ReactionType = 101
	ReactionType_TrafficRouting ReactionType = 102
)

func (ReactionType) EnumDescriptor 

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

func (ReactionType) String 

func (x ReactionType) String() string

type Record 

type Record struct {
	Type        ActionType `protobuf:"varint,1,opt,name=type,enum=context_bus.ActionType" json:"type,omitempty"`
	Timestamp   int64      `protobuf:"varint,2,opt,name=timestamp" json:"timestamp,omitempty"`
	MessageName string     `protobuf:"bytes,3,opt,name=message_name,json=messageName" json:"message_name,omitempty"`
	Uuid        string     `protobuf:"bytes,4,opt,name=uuid" json:"uuid,omitempty"`
	Service     string     `protobuf:"bytes,5,opt,name=service" json:"service,omitempty"`
}

Trace span, deprecated

func (*Record) Descriptor 

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

func (*Record) GetMessageName 

func (m *Record) GetMessageName() string

func (*Record) GetService 

func (m *Record) GetService() string

func (*Record) GetTimestamp 

func (m *Record) GetTimestamp() int64

func (*Record) GetType 

func (m *Record) GetType() ActionType

func (*Record) GetUuid 

func (m *Record) GetUuid() string

func (*Record) ProtoMessage 

func (*Record) ProtoMessage()

func (*Record) Reset 

func (m *Record) Reset()

func (*Record) String 

func (m *Record) String() string

type SpanMetadata 

type SpanMetadata struct {
	Sampled     bool              `protobuf:"varint,1,opt,name=sampled" json:"sampled,omitempty"`
	TraceIdHigh uint64            `protobuf:"varint,2,opt,name=trace_id_high,json=traceIdHigh" json:"trace_id_high,omitempty"`
	TraceIdLow  uint64            `protobuf:"varint,3,opt,name=trace_id_low,json=traceIdLow" json:"trace_id_low,omitempty"`
	SpanId      uint64            `protobuf:"varint,4,opt,name=span_id,json=spanId" json:"span_id,omitempty"`
	ParentId    uint64            `protobuf:"varint,5,opt,name=parent_id,json=parentId" json:"parent_id,omitempty"`
	Baggage     map[string]string `` /* 134-byte string literal not displayed */
}

func (*SpanMetadata) Descriptor 

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

func (*SpanMetadata) GetBaggage 

func (m *SpanMetadata) GetBaggage() map[string]string

func (*SpanMetadata) GetParentId 

func (m *SpanMetadata) GetParentId() uint64

func (*SpanMetadata) GetSampled 

func (m *SpanMetadata) GetSampled() bool

func (*SpanMetadata) GetSpanId 

func (m *SpanMetadata) GetSpanId() uint64

func (*SpanMetadata) GetTraceIdHigh 

func (m *SpanMetadata) GetTraceIdHigh() uint64

func (*SpanMetadata) GetTraceIdLow 

func (m *SpanMetadata) GetTraceIdLow() uint64

func (*SpanMetadata) ParentSpanContext 

func (m *SpanMetadata) ParentSpanContext() jaeger.SpanContext

func (*SpanMetadata) ProtoMessage 

func (*SpanMetadata) ProtoMessage()

func (*SpanMetadata) Reset 

func (m *SpanMetadata) Reset()

func (*SpanMetadata) String 

func (m *SpanMetadata) String() string

type StackTraceConfigure 

type StackTraceConfigure struct {
}

func (*StackTraceConfigure) Descriptor 

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

func (*StackTraceConfigure) ProtoMessage 

func (*StackTraceConfigure) ProtoMessage()

func (*StackTraceConfigure) Reset 

func (m *StackTraceConfigure) Reset()

func (*StackTraceConfigure) String 

func (m *StackTraceConfigure) String() string

type TimestampConfigure 

type TimestampConfigure struct {
	Format string `protobuf:"bytes,1,opt,name=format" json:"format,omitempty"`
}

func (*TimestampConfigure) Descriptor 

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

func (*TimestampConfigure) GetFormat 

func (m *TimestampConfigure) GetFormat() string

func (*TimestampConfigure) ProtoMessage 

func (*TimestampConfigure) ProtoMessage()

func (*TimestampConfigure) Reset 

func (m *TimestampConfigure) Reset()

func (*TimestampConfigure) String 

func (m *TimestampConfigure) String() string

type TracingConfigure 

type TracingConfigure struct {
	Name       string                `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	PrevName   string                `protobuf:"bytes,2,opt,name=prev_name,json=prevName" json:"prev_name,omitempty"`
	Attrs      []*AttributeConfigure `protobuf:"bytes,3,rep,name=attrs" json:"attrs,omitempty"`
	ParentName string                `protobuf:"bytes,11,opt,name=parent_name,json=parentName" json:"parent_name,omitempty"`
}

func (*TracingConfigure) Descriptor 

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

func (*TracingConfigure) GetAttrs 

func (m *TracingConfigure) GetAttrs() []*AttributeConfigure

func (*TracingConfigure) GetName 

func (m *TracingConfigure) GetName() string

func (*TracingConfigure) GetParentName 

func (m *TracingConfigure) GetParentName() string

func (*TracingConfigure) GetPrevName 

func (m *TracingConfigure) GetPrevName() string

func (*TracingConfigure) ProtoMessage 

func (*TracingConfigure) ProtoMessage()

func (*TracingConfigure) Reset 

func (m *TracingConfigure) Reset()

func (*TracingConfigure) String 

func (m *TracingConfigure) String() string

type TrafficBalanceParam 

type TrafficBalanceParam struct {
}

func (*TrafficBalanceParam) Descriptor 

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

func (*TrafficBalanceParam) ProtoMessage 

func (*TrafficBalanceParam) ProtoMessage()

func (*TrafficBalanceParam) Reset 

func (m *TrafficBalanceParam) Reset()

func (*TrafficBalanceParam) String 

func (m *TrafficBalanceParam) String() string

type TrafficRoutingParam 

type TrafficRoutingParam struct {
}

func (*TrafficRoutingParam) Descriptor 

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

func (*TrafficRoutingParam) ProtoMessage 

func (*TrafficRoutingParam) ProtoMessage()

func (*TrafficRoutingParam) Reset 

func (m *TrafficRoutingParam) Reset()

func (*TrafficRoutingParam) String 

func (m *TrafficRoutingParam) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.