telemetry_edge

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Aug 11, 2020 License: Apache-2.0 Imports: 9 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	AgentType_name = map[int32]string{
		0: "TELEGRAF",
		1: "FILEBEAT",
		2: "ORACLE",
		3: "PACKAGES",
	}
	AgentType_value = map[string]int32{
		"TELEGRAF": 0,
		"FILEBEAT": 1,
		"ORACLE":   2,
		"PACKAGES": 3,
	}
)

Enum value maps for AgentType.

View Source 
var (
	Checksum_Type_name = map[int32]string{
		0: "SHA256",
		1: "SHA512",
	}
	Checksum_Type_value = map[string]int32{
		"SHA256": 0,
		"SHA512": 1,
	}
)

Enum value maps for Checksum_Type.

View Source 
var (
	ConfigurationOp_Type_name = map[int32]string{
		0: "CREATE",
		1: "MODIFY",
		2: "REMOVE",
	}
	ConfigurationOp_Type_value = map[string]int32{
		"CREATE": 0,
		"MODIFY": 1,
		"REMOVE": 2,
	}
)

Enum value maps for ConfigurationOp_Type.

View Source 
var File_telemetry_edge_proto protoreflect.FileDescriptor

Functions

func RegisterTelemetryAmbassadorServer 

func RegisterTelemetryAmbassadorServer(s *grpc.Server, srv TelemetryAmbassadorServer)

Types

type Agent 

type Agent struct {
	Type    AgentType `protobuf:"varint,1,opt,name=type,proto3,enum=AgentType" json:"type,omitempty"`
	Version string    `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*Agent) Descriptor deprecated 

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

Deprecated: Use Agent.ProtoReflect.Descriptor instead.

func (*Agent) GetType 

func (x *Agent) GetType() AgentType

func (*Agent) GetVersion 

func (x *Agent) GetVersion() string

func (*Agent) ProtoMessage 

func (*Agent) ProtoMessage()

func (*Agent) ProtoReflect added in v0.6.0 

func (x *Agent) ProtoReflect() protoreflect.Message

func (*Agent) Reset 

func (x *Agent) Reset()

func (*Agent) String 

func (x *Agent) String() string

type AgentType 

type AgentType int32
const (
	AgentType_TELEGRAF AgentType = 0
	AgentType_FILEBEAT AgentType = 1
	AgentType_ORACLE   AgentType = 2
	AgentType_PACKAGES AgentType = 3
)

func (AgentType) Descriptor added in v0.6.0 

func (AgentType) Descriptor() protoreflect.EnumDescriptor

func (AgentType) Enum added in v0.6.0 

func (x AgentType) Enum() *AgentType

func (AgentType) EnumDescriptor deprecated 

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

Deprecated: Use AgentType.Descriptor instead.

func (AgentType) Number added in v0.6.0 

func (x AgentType) Number() protoreflect.EnumNumber

func (AgentType) String 

func (x AgentType) String() string

func (AgentType) Type added in v0.6.0 

func (AgentType) Type() protoreflect.EnumType

type Checksum 

type Checksum struct {
	Value string        `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Type  Checksum_Type `protobuf:"varint,2,opt,name=type,proto3,enum=Checksum_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*Checksum) Descriptor deprecated 

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

Deprecated: Use Checksum.ProtoReflect.Descriptor instead.

func (*Checksum) GetType 

func (x *Checksum) GetType() Checksum_Type

func (*Checksum) GetValue 

func (x *Checksum) GetValue() string

func (*Checksum) ProtoMessage 

func (*Checksum) ProtoMessage()

func (*Checksum) ProtoReflect added in v0.6.0 

func (x *Checksum) ProtoReflect() protoreflect.Message

func (*Checksum) Reset 

func (x *Checksum) Reset()

func (*Checksum) String 

func (x *Checksum) String() string

type Checksum_Type 

type Checksum_Type int32
const (
	Checksum_SHA256 Checksum_Type = 0
	Checksum_SHA512 Checksum_Type = 1
)

func (Checksum_Type) Descriptor added in v0.6.0 

func (Checksum_Type) Descriptor() protoreflect.EnumDescriptor

func (Checksum_Type) Enum added in v0.6.0 

func (x Checksum_Type) Enum() *Checksum_Type

func (Checksum_Type) EnumDescriptor deprecated 

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

Deprecated: Use Checksum_Type.Descriptor instead.

func (Checksum_Type) Number added in v0.6.0 

func (x Checksum_Type) Number() protoreflect.EnumNumber

func (Checksum_Type) String 

func (x Checksum_Type) String() string

func (Checksum_Type) Type added in v0.6.0 

func (Checksum_Type) Type() protoreflect.EnumType

type ConfigurationOp 

type ConfigurationOp struct {
	Id       string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Revision string               `protobuf:"bytes,2,opt,name=revision,proto3" json:"revision,omitempty"`
	Type     ConfigurationOp_Type `protobuf:"varint,3,opt,name=type,proto3,enum=ConfigurationOp_Type" json:"type,omitempty"`
	Content  string               `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"`
	// conveys extra labels/tags that should be associated with the generated measurements
	ExtraLabels map[string]string `` /* 163-byte string literal not displayed */
	// monitoring interval, in seconds, value of 0 means use default
	Interval int64 `protobuf:"varint,6,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigurationOp) Descriptor deprecated 

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

Deprecated: Use ConfigurationOp.ProtoReflect.Descriptor instead.

func (*ConfigurationOp) GetContent 

func (x *ConfigurationOp) GetContent() string

func (*ConfigurationOp) GetExtraLabels 

func (x *ConfigurationOp) GetExtraLabels() map[string]string

func (*ConfigurationOp) GetId 

func (x *ConfigurationOp) GetId() string

func (*ConfigurationOp) GetInterval 

func (x *ConfigurationOp) GetInterval() int64

func (*ConfigurationOp) GetRevision 

func (x *ConfigurationOp) GetRevision() string

func (*ConfigurationOp) GetType 

func (x *ConfigurationOp) GetType() ConfigurationOp_Type

func (*ConfigurationOp) ProtoMessage 

func (*ConfigurationOp) ProtoMessage()

func (*ConfigurationOp) ProtoReflect added in v0.6.0 

func (x *ConfigurationOp) ProtoReflect() protoreflect.Message

func (*ConfigurationOp) Reset 

func (x *ConfigurationOp) Reset()

func (*ConfigurationOp) String 

func (x *ConfigurationOp) String() string

type ConfigurationOp_Type 

type ConfigurationOp_Type int32
const (
	ConfigurationOp_CREATE ConfigurationOp_Type = 0
	ConfigurationOp_MODIFY ConfigurationOp_Type = 1
	ConfigurationOp_REMOVE ConfigurationOp_Type = 2
)

func (ConfigurationOp_Type) Descriptor added in v0.6.0 

func (ConfigurationOp_Type) Descriptor() protoreflect.EnumDescriptor

func (ConfigurationOp_Type) Enum added in v0.6.0 

func (x ConfigurationOp_Type) Enum() *ConfigurationOp_Type

func (ConfigurationOp_Type) EnumDescriptor deprecated 

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

Deprecated: Use ConfigurationOp_Type.Descriptor instead.

func (ConfigurationOp_Type) Number added in v0.6.0 

func (x ConfigurationOp_Type) Number() protoreflect.EnumNumber

func (ConfigurationOp_Type) String 

func (x ConfigurationOp_Type) String() string

func (ConfigurationOp_Type) Type added in v0.6.0 

func (ConfigurationOp_Type) Type() protoreflect.EnumType

type DetachedInstructions 

type DetachedInstructions struct {
	Instructions []*EnvoyInstruction `protobuf:"bytes,1,rep,name=instructions,proto3" json:"instructions,omitempty"`
	// contains filtered or unexported fields
}

DetachedInstructions is used for offline, detached loading of instructions from a file.

func (*DetachedInstructions) Descriptor deprecated 

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

Deprecated: Use DetachedInstructions.ProtoReflect.Descriptor instead.

func (*DetachedInstructions) GetInstructions 

func (x *DetachedInstructions) GetInstructions() []*EnvoyInstruction

func (*DetachedInstructions) ProtoMessage 

func (*DetachedInstructions) ProtoMessage()

func (*DetachedInstructions) ProtoReflect added in v0.6.0 

func (x *DetachedInstructions) ProtoReflect() protoreflect.Message

func (*DetachedInstructions) Reset 

func (x *DetachedInstructions) Reset()

func (*DetachedInstructions) String 

func (x *DetachedInstructions) String() string

type EnvoyInstruction 

type EnvoyInstruction struct {

	// Types that are assignable to Details:
	//	*EnvoyInstruction_Install
	//	*EnvoyInstruction_Configure
	//	*EnvoyInstruction_Refresh
	//	*EnvoyInstruction_TestMonitor
	//	*EnvoyInstruction_Ready
	Details isEnvoyInstruction_Details `protobuf_oneof:"details"`
	// contains filtered or unexported fields
}

func (*EnvoyInstruction) Descriptor deprecated 

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

Deprecated: Use EnvoyInstruction.ProtoReflect.Descriptor instead.

func (*EnvoyInstruction) GetConfigure 

func (x *EnvoyInstruction) GetConfigure() *EnvoyInstructionConfigure

func (*EnvoyInstruction) GetDetails 

func (m *EnvoyInstruction) GetDetails() isEnvoyInstruction_Details

func (*EnvoyInstruction) GetInstall 

func (x *EnvoyInstruction) GetInstall() *EnvoyInstructionInstall

func (*EnvoyInstruction) GetReady added in v0.5.0 

func (x *EnvoyInstruction) GetReady() *EnvoyInstructionReady

func (*EnvoyInstruction) GetRefresh 

func (x *EnvoyInstruction) GetRefresh() *EnvoyInstructionRefresh

func (*EnvoyInstruction) GetTestMonitor 

func (x *EnvoyInstruction) GetTestMonitor() *EnvoyInstructionTestMonitor

func (*EnvoyInstruction) ProtoMessage 

func (*EnvoyInstruction) ProtoMessage()

func (*EnvoyInstruction) ProtoReflect added in v0.6.0 

func (x *EnvoyInstruction) ProtoReflect() protoreflect.Message

func (*EnvoyInstruction) Reset 

func (x *EnvoyInstruction) Reset()

func (*EnvoyInstruction) String 

func (x *EnvoyInstruction) String() string

type EnvoyInstructionConfigure 

type EnvoyInstructionConfigure struct {
	AgentType  AgentType          `protobuf:"varint,1,opt,name=agentType,proto3,enum=AgentType" json:"agentType,omitempty"`
	Operations []*ConfigurationOp `protobuf:"bytes,2,rep,name=operations,proto3" json:"operations,omitempty"`
	// contains filtered or unexported fields
}

func (*EnvoyInstructionConfigure) Descriptor deprecated 

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

Deprecated: Use EnvoyInstructionConfigure.ProtoReflect.Descriptor instead.

func (*EnvoyInstructionConfigure) GetAgentType 

func (x *EnvoyInstructionConfigure) GetAgentType() AgentType

func (*EnvoyInstructionConfigure) GetOperations 

func (x *EnvoyInstructionConfigure) GetOperations() []*ConfigurationOp

func (*EnvoyInstructionConfigure) ProtoMessage 

func (*EnvoyInstructionConfigure) ProtoMessage()

func (*EnvoyInstructionConfigure) ProtoReflect added in v0.6.0 

func (x *EnvoyInstructionConfigure) ProtoReflect() protoreflect.Message

func (*EnvoyInstructionConfigure) Reset 

func (x *EnvoyInstructionConfigure) Reset()

func (*EnvoyInstructionConfigure) String 

func (x *EnvoyInstructionConfigure) String() string

type EnvoyInstructionInstall 

type EnvoyInstructionInstall struct {
	Agent    *Agent    `protobuf:"bytes,1,opt,name=agent,proto3" json:"agent,omitempty"`
	Url      string    `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Checksum *Checksum `protobuf:"bytes,3,opt,name=checksum,proto3" json:"checksum,omitempty"`
	// path to the agent's executable within the package
	Exe string `protobuf:"bytes,4,opt,name=exe,proto3" json:"exe,omitempty"`
	// contains filtered or unexported fields
}

func (*EnvoyInstructionInstall) Descriptor deprecated 

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

Deprecated: Use EnvoyInstructionInstall.ProtoReflect.Descriptor instead.

func (*EnvoyInstructionInstall) GetAgent 

func (x *EnvoyInstructionInstall) GetAgent() *Agent

func (*EnvoyInstructionInstall) GetChecksum 

func (x *EnvoyInstructionInstall) GetChecksum() *Checksum

func (*EnvoyInstructionInstall) GetExe 

func (x *EnvoyInstructionInstall) GetExe() string

func (*EnvoyInstructionInstall) GetUrl 

func (x *EnvoyInstructionInstall) GetUrl() string

func (*EnvoyInstructionInstall) ProtoMessage 

func (*EnvoyInstructionInstall) ProtoMessage()

func (*EnvoyInstructionInstall) ProtoReflect added in v0.6.0 

func (x *EnvoyInstructionInstall) ProtoReflect() protoreflect.Message

func (*EnvoyInstructionInstall) Reset 

func (x *EnvoyInstructionInstall) Reset()

func (*EnvoyInstructionInstall) String 

func (x *EnvoyInstructionInstall) String() string

type EnvoyInstructionReady added in v0.5.0 

type EnvoyInstructionReady struct {
	// contains filtered or unexported fields
}

func (*EnvoyInstructionReady) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use EnvoyInstructionReady.ProtoReflect.Descriptor instead.

func (*EnvoyInstructionReady) ProtoMessage added in v0.5.0 

func (*EnvoyInstructionReady) ProtoMessage()

func (*EnvoyInstructionReady) ProtoReflect added in v0.6.0 

func (x *EnvoyInstructionReady) ProtoReflect() protoreflect.Message

func (*EnvoyInstructionReady) Reset added in v0.5.0 

func (x *EnvoyInstructionReady) Reset()

func (*EnvoyInstructionReady) String added in v0.5.0 

func (x *EnvoyInstructionReady) String() string

type EnvoyInstructionRefresh 

type EnvoyInstructionRefresh struct {
	// contains filtered or unexported fields
}

mainly used to test the ambassador->envoy liveness of the channel, but could eventually contain the full set of instructions of ensure consistency

func (*EnvoyInstructionRefresh) Descriptor deprecated 

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

Deprecated: Use EnvoyInstructionRefresh.ProtoReflect.Descriptor instead.

func (*EnvoyInstructionRefresh) ProtoMessage 

func (*EnvoyInstructionRefresh) ProtoMessage()

func (*EnvoyInstructionRefresh) ProtoReflect added in v0.6.0 

func (x *EnvoyInstructionRefresh) ProtoReflect() protoreflect.Message

func (*EnvoyInstructionRefresh) Reset 

func (x *EnvoyInstructionRefresh) Reset()

func (*EnvoyInstructionRefresh) String 

func (x *EnvoyInstructionRefresh) String() string

type EnvoyInstructionTestMonitor 

type EnvoyInstructionTestMonitor struct {
	CorrelationId string    `protobuf:"bytes,1,opt,name=correlationId,proto3" json:"correlationId,omitempty"`
	AgentType     AgentType `protobuf:"varint,2,opt,name=agentType,proto3,enum=AgentType" json:"agentType,omitempty"`
	Content       string    `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	// declares the maximum amount of time in seconds the test operation can run
	Timeout int64 `protobuf:"varint,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*EnvoyInstructionTestMonitor) Descriptor deprecated 

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

Deprecated: Use EnvoyInstructionTestMonitor.ProtoReflect.Descriptor instead.

func (*EnvoyInstructionTestMonitor) GetAgentType 

func (x *EnvoyInstructionTestMonitor) GetAgentType() AgentType

func (*EnvoyInstructionTestMonitor) GetContent 

func (x *EnvoyInstructionTestMonitor) GetContent() string

func (*EnvoyInstructionTestMonitor) GetCorrelationId 

func (x *EnvoyInstructionTestMonitor) GetCorrelationId() string

func (*EnvoyInstructionTestMonitor) GetTimeout 

func (x *EnvoyInstructionTestMonitor) GetTimeout() int64

func (*EnvoyInstructionTestMonitor) ProtoMessage 

func (*EnvoyInstructionTestMonitor) ProtoMessage()

func (*EnvoyInstructionTestMonitor) ProtoReflect added in v0.6.0 

func (x *EnvoyInstructionTestMonitor) ProtoReflect() protoreflect.Message

func (*EnvoyInstructionTestMonitor) Reset 

func (x *EnvoyInstructionTestMonitor) Reset()

func (*EnvoyInstructionTestMonitor) String 

func (x *EnvoyInstructionTestMonitor) String() string

type EnvoyInstruction_Configure 

type EnvoyInstruction_Configure struct {
	Configure *EnvoyInstructionConfigure `protobuf:"bytes,2,opt,name=configure,proto3,oneof"`
}

type EnvoyInstruction_Install 

type EnvoyInstruction_Install struct {
	Install *EnvoyInstructionInstall `protobuf:"bytes,1,opt,name=install,proto3,oneof"`
}

type EnvoyInstruction_Ready added in v0.5.0 

type EnvoyInstruction_Ready struct {
	// ready is sent by the Ambassador when it is ready to process keepalives and metrics
	Ready *EnvoyInstructionReady `protobuf:"bytes,5,opt,name=ready,proto3,oneof"`
}

type EnvoyInstruction_Refresh 

type EnvoyInstruction_Refresh struct {
	Refresh *EnvoyInstructionRefresh `protobuf:"bytes,3,opt,name=refresh,proto3,oneof"`
}

type EnvoyInstruction_TestMonitor 

type EnvoyInstruction_TestMonitor struct {
	TestMonitor *EnvoyInstructionTestMonitor `protobuf:"bytes,4,opt,name=testMonitor,proto3,oneof"`
}

type EnvoySummary 

type EnvoySummary struct {
	Version         string            `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	SupportedAgents []AgentType       `protobuf:"varint,2,rep,packed,name=supportedAgents,proto3,enum=AgentType" json:"supportedAgents,omitempty"`
	Labels          map[string]string `` /* 153-byte string literal not displayed */
	ResourceId      string            `protobuf:"bytes,4,opt,name=resourceId,proto3" json:"resourceId,omitempty"`
	Zone            string            `protobuf:"bytes,5,opt,name=zone,proto3" json:"zone,omitempty"`
	// contains filtered or unexported fields
}

func (*EnvoySummary) Descriptor deprecated 

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

Deprecated: Use EnvoySummary.ProtoReflect.Descriptor instead.

func (*EnvoySummary) GetLabels 

func (x *EnvoySummary) GetLabels() map[string]string

func (*EnvoySummary) GetResourceId 

func (x *EnvoySummary) GetResourceId() string

func (*EnvoySummary) GetSupportedAgents 

func (x *EnvoySummary) GetSupportedAgents() []AgentType

func (*EnvoySummary) GetVersion 

func (x *EnvoySummary) GetVersion() string

func (*EnvoySummary) GetZone 

func (x *EnvoySummary) GetZone() string

func (*EnvoySummary) ProtoMessage 

func (*EnvoySummary) ProtoMessage()

func (*EnvoySummary) ProtoReflect added in v0.6.0 

func (x *EnvoySummary) ProtoReflect() protoreflect.Message

func (*EnvoySummary) Reset 

func (x *EnvoySummary) Reset()

func (*EnvoySummary) String 

func (x *EnvoySummary) String() string

type KeepAliveRequest 

type KeepAliveRequest struct {
	// contains filtered or unexported fields
}

func (*KeepAliveRequest) Descriptor deprecated 

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

Deprecated: Use KeepAliveRequest.ProtoReflect.Descriptor instead.

func (*KeepAliveRequest) ProtoMessage 

func (*KeepAliveRequest) ProtoMessage()

func (*KeepAliveRequest) ProtoReflect added in v0.6.0 

func (x *KeepAliveRequest) ProtoReflect() protoreflect.Message

func (*KeepAliveRequest) Reset 

func (x *KeepAliveRequest) Reset()

func (*KeepAliveRequest) String 

func (x *KeepAliveRequest) String() string

type KeepAliveResponse 

type KeepAliveResponse struct {
	// contains filtered or unexported fields
}

func (*KeepAliveResponse) Descriptor deprecated 

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

Deprecated: Use KeepAliveResponse.ProtoReflect.Descriptor instead.

func (*KeepAliveResponse) ProtoMessage 

func (*KeepAliveResponse) ProtoMessage()

func (*KeepAliveResponse) ProtoReflect added in v0.6.0 

func (x *KeepAliveResponse) ProtoReflect() protoreflect.Message

func (*KeepAliveResponse) Reset 

func (x *KeepAliveResponse) Reset()

func (*KeepAliveResponse) String 

func (x *KeepAliveResponse) String() string

type LogEvent 

type LogEvent struct {
	AgentType   AgentType `protobuf:"varint,1,opt,name=agentType,proto3,enum=AgentType" json:"agentType,omitempty"`
	JsonContent string    `protobuf:"bytes,2,opt,name=jsonContent,proto3" json:"jsonContent,omitempty"`
	// contains filtered or unexported fields
}

func (*LogEvent) Descriptor deprecated 

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

Deprecated: Use LogEvent.ProtoReflect.Descriptor instead.

func (*LogEvent) GetAgentType 

func (x *LogEvent) GetAgentType() AgentType

func (*LogEvent) GetJsonContent 

func (x *LogEvent) GetJsonContent() string

func (*LogEvent) ProtoMessage 

func (*LogEvent) ProtoMessage()

func (*LogEvent) ProtoReflect added in v0.6.0 

func (x *LogEvent) ProtoReflect() protoreflect.Message

func (*LogEvent) Reset 

func (x *LogEvent) Reset()

func (*LogEvent) String 

func (x *LogEvent) String() string

type Metric 

type Metric struct {

	// Types that are assignable to Variant:
	//	*Metric_NameTagValue
	Variant isMetric_Variant `protobuf_oneof:"variant"`
	// contains filtered or unexported fields
}

func (*Metric) Descriptor deprecated 

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

Deprecated: Use Metric.ProtoReflect.Descriptor instead.

func (*Metric) GetNameTagValue 

func (x *Metric) GetNameTagValue() *NameTagValueMetric

func (*Metric) GetVariant 

func (m *Metric) GetVariant() isMetric_Variant

func (*Metric) ProtoMessage 

func (*Metric) ProtoMessage()

func (*Metric) ProtoReflect added in v0.6.0 

func (x *Metric) ProtoReflect() protoreflect.Message

func (*Metric) Reset 

func (x *Metric) Reset()

func (*Metric) String 

func (x *Metric) String() string

type Metric_NameTagValue 

type Metric_NameTagValue struct {
	NameTagValue *NameTagValueMetric `protobuf:"bytes,1,opt,name=nameTagValue,proto3,oneof"`
}

type NameTagValueMetric 

type NameTagValueMetric struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// in milliseconds
	Timestamp int64              `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Tags      map[string]string  `` /* 149-byte string literal not displayed */
	Fvalues   map[string]float64 `` /* 157-byte string literal not displayed */
	Svalues   map[string]string  `` /* 155-byte string literal not displayed */
	Ivalues   map[string]int64   `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NameTagValueMetric) Descriptor deprecated 

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

Deprecated: Use NameTagValueMetric.ProtoReflect.Descriptor instead.

func (*NameTagValueMetric) GetFvalues 

func (x *NameTagValueMetric) GetFvalues() map[string]float64

func (*NameTagValueMetric) GetIvalues 

func (x *NameTagValueMetric) GetIvalues() map[string]int64

func (*NameTagValueMetric) GetName 

func (x *NameTagValueMetric) GetName() string

func (*NameTagValueMetric) GetSvalues 

func (x *NameTagValueMetric) GetSvalues() map[string]string

func (*NameTagValueMetric) GetTags 

func (x *NameTagValueMetric) GetTags() map[string]string

func (*NameTagValueMetric) GetTimestamp 

func (x *NameTagValueMetric) GetTimestamp() int64

func (*NameTagValueMetric) ProtoMessage 

func (*NameTagValueMetric) ProtoMessage()

func (*NameTagValueMetric) ProtoReflect added in v0.6.0 

func (x *NameTagValueMetric) ProtoReflect() protoreflect.Message

func (*NameTagValueMetric) Reset 

func (x *NameTagValueMetric) Reset()

func (*NameTagValueMetric) String 

func (x *NameTagValueMetric) String() string

type PostLogEventResponse 

type PostLogEventResponse struct {
	// contains filtered or unexported fields
}

func (*PostLogEventResponse) Descriptor deprecated 

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

Deprecated: Use PostLogEventResponse.ProtoReflect.Descriptor instead.

func (*PostLogEventResponse) ProtoMessage 

func (*PostLogEventResponse) ProtoMessage()

func (*PostLogEventResponse) ProtoReflect added in v0.6.0 

func (x *PostLogEventResponse) ProtoReflect() protoreflect.Message

func (*PostLogEventResponse) Reset 

func (x *PostLogEventResponse) Reset()

func (*PostLogEventResponse) String 

func (x *PostLogEventResponse) String() string

type PostMetricResponse 

type PostMetricResponse struct {
	// contains filtered or unexported fields
}

func (*PostMetricResponse) Descriptor deprecated 

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

Deprecated: Use PostMetricResponse.ProtoReflect.Descriptor instead.

func (*PostMetricResponse) ProtoMessage 

func (*PostMetricResponse) ProtoMessage()

func (*PostMetricResponse) ProtoReflect added in v0.6.0 

func (x *PostMetricResponse) ProtoReflect() protoreflect.Message

func (*PostMetricResponse) Reset 

func (x *PostMetricResponse) Reset()

func (*PostMetricResponse) String 

func (x *PostMetricResponse) String() string

type PostTestMonitorResultsResponse 

type PostTestMonitorResultsResponse struct {
	// contains filtered or unexported fields
}

func (*PostTestMonitorResultsResponse) Descriptor deprecated 

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

Deprecated: Use PostTestMonitorResultsResponse.ProtoReflect.Descriptor instead.

func (*PostTestMonitorResultsResponse) ProtoMessage 

func (*PostTestMonitorResultsResponse) ProtoMessage()

func (*PostTestMonitorResultsResponse) ProtoReflect added in v0.6.0 

func (x *PostTestMonitorResultsResponse) ProtoReflect() protoreflect.Message

func (*PostTestMonitorResultsResponse) Reset 

func (x *PostTestMonitorResultsResponse) Reset()

func (*PostTestMonitorResultsResponse) String 

func (x *PostTestMonitorResultsResponse) String() string

type PostedMetric 

type PostedMetric struct {
	Metric *Metric `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	// contains filtered or unexported fields
}

func (*PostedMetric) Descriptor deprecated 

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

Deprecated: Use PostedMetric.ProtoReflect.Descriptor instead.

func (*PostedMetric) GetMetric 

func (x *PostedMetric) GetMetric() *Metric

func (*PostedMetric) ProtoMessage 

func (*PostedMetric) ProtoMessage()

func (*PostedMetric) ProtoReflect added in v0.6.0 

func (x *PostedMetric) ProtoReflect() protoreflect.Message

func (*PostedMetric) Reset 

func (x *PostedMetric) Reset()

func (*PostedMetric) String 

func (x *PostedMetric) String() string

type TelemetryAmbassadorClient 

type TelemetryAmbassadorClient interface {
	AttachEnvoy(ctx context.Context, in *EnvoySummary, opts ...grpc.CallOption) (TelemetryAmbassador_AttachEnvoyClient, error)
	KeepAlive(ctx context.Context, in *KeepAliveRequest, opts ...grpc.CallOption) (*KeepAliveResponse, error)
	PostLogEvent(ctx context.Context, in *LogEvent, opts ...grpc.CallOption) (*PostLogEventResponse, error)
	PostMetric(ctx context.Context, in *PostedMetric, opts ...grpc.CallOption) (*PostMetricResponse, error)
	PostTestMonitorResults(ctx context.Context, in *TestMonitorResults, opts ...grpc.CallOption) (*PostTestMonitorResultsResponse, error)
}

TelemetryAmbassadorClient is the client API for TelemetryAmbassador service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTelemetryAmbassadorClient 

func NewTelemetryAmbassadorClient(cc grpc.ClientConnInterface) TelemetryAmbassadorClient

type TelemetryAmbassadorServer 

type TelemetryAmbassadorServer interface {
	AttachEnvoy(*EnvoySummary, TelemetryAmbassador_AttachEnvoyServer) error
	KeepAlive(context.Context, *KeepAliveRequest) (*KeepAliveResponse, error)
	PostLogEvent(context.Context, *LogEvent) (*PostLogEventResponse, error)
	PostMetric(context.Context, *PostedMetric) (*PostMetricResponse, error)
	PostTestMonitorResults(context.Context, *TestMonitorResults) (*PostTestMonitorResultsResponse, error)
}

TelemetryAmbassadorServer is the server API for TelemetryAmbassador service.

type TelemetryAmbassador_AttachEnvoyClient 

type TelemetryAmbassador_AttachEnvoyClient interface {
	Recv() (*EnvoyInstruction, error)
	grpc.ClientStream
}

type TelemetryAmbassador_AttachEnvoyServer 

type TelemetryAmbassador_AttachEnvoyServer interface {
	Send(*EnvoyInstruction) error
	grpc.ServerStream
}

type TestMonitorResults 

type TestMonitorResults struct {
	CorrelationId string    `protobuf:"bytes,1,opt,name=correlationId,proto3" json:"correlationId,omitempty"`
	Errors        []string  `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"`
	Metrics       []*Metric `protobuf:"bytes,3,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*TestMonitorResults) Descriptor deprecated 

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

Deprecated: Use TestMonitorResults.ProtoReflect.Descriptor instead.

func (*TestMonitorResults) GetCorrelationId 

func (x *TestMonitorResults) GetCorrelationId() string

func (*TestMonitorResults) GetErrors 

func (x *TestMonitorResults) GetErrors() []string

func (*TestMonitorResults) GetMetrics 

func (x *TestMonitorResults) GetMetrics() []*Metric

func (*TestMonitorResults) ProtoMessage 

func (*TestMonitorResults) ProtoMessage()

func (*TestMonitorResults) ProtoReflect added in v0.6.0 

func (x *TestMonitorResults) ProtoReflect() protoreflect.Message

func (*TestMonitorResults) Reset 

func (x *TestMonitorResults) Reset()

func (*TestMonitorResults) String 

func (x *TestMonitorResults) String() string

type UnimplementedTelemetryAmbassadorServer 

type UnimplementedTelemetryAmbassadorServer struct {
}

UnimplementedTelemetryAmbassadorServer can be embedded to have forward compatible implementations.

func (*UnimplementedTelemetryAmbassadorServer) AttachEnvoy 

func (*UnimplementedTelemetryAmbassadorServer) AttachEnvoy(*EnvoySummary, TelemetryAmbassador_AttachEnvoyServer) error

func (*UnimplementedTelemetryAmbassadorServer) KeepAlive 

func (*UnimplementedTelemetryAmbassadorServer) KeepAlive(context.Context, *KeepAliveRequest) (*KeepAliveResponse, error)

func (*UnimplementedTelemetryAmbassadorServer) PostLogEvent 

func (*UnimplementedTelemetryAmbassadorServer) PostLogEvent(context.Context, *LogEvent) (*PostLogEventResponse, error)

func (*UnimplementedTelemetryAmbassadorServer) PostMetric 

func (*UnimplementedTelemetryAmbassadorServer) PostMetric(context.Context, *PostedMetric) (*PostMetricResponse, error)

func (*UnimplementedTelemetryAmbassadorServer) PostTestMonitorResults 

func (*UnimplementedTelemetryAmbassadorServer) PostTestMonitorResults(context.Context, *TestMonitorResults) (*PostTestMonitorResultsResponse, error)

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.