definitions

Documentation

Overview

Package definitions is a generated protocol buffer package.

It is generated from these files:

events.proto
server.proto

It has these top-level messages:

Event
Heartbeat
Alert
EgressRequest

Index

• func RegisterEgressServer(s *grpc.Server, srv EgressServer)
• type Alert
  • func (*Alert) Descriptor() ([]byte, []int)
  • func (m *Alert) GetCategory() string
  • func (m *Alert) GetSeverity() int32
  • func (m *Alert) GetSource() string
  • func (m *Alert) GetSummary() string
  • func (m *Alert) GetTitle() string
  • func (*Alert) ProtoMessage()
  • func (m *Alert) Reset()
  • func (m *Alert) String() string
• type EgressClient
  • func NewEgressClient(cc *grpc.ClientConn) EgressClient
• type EgressRequest
  • func (*EgressRequest) Descriptor() ([]byte, []int)
  • func (m *EgressRequest) GetSubscriptionId() string
  • func (*EgressRequest) ProtoMessage()
  • func (m *EgressRequest) Reset()
  • func (m *EgressRequest) String() string
• type EgressServer
• type Egress_BoshMetricsClient
• type Egress_BoshMetricsServer
• type Event
  • func (*Event) Descriptor() ([]byte, []int)
  • func (m *Event) GetAlert() *Alert
  • func (m *Event) GetDeployment() string
  • func (m *Event) GetHeartbeat() *Heartbeat
  • func (m *Event) GetId() string
  • func (m *Event) GetMessage() isEvent_Message
  • func (m *Event) GetTimestamp() int64
  • func (*Event) ProtoMessage()
  • func (m *Event) Reset()
  • func (m *Event) String() string
  • func (*Event) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
• type Event_Alert
• type Event_Heartbeat
• type Heartbeat
  • func (*Heartbeat) Descriptor() ([]byte, []int)
  • func (m *Heartbeat) GetAgentId() string
  • func (m *Heartbeat) GetIndex() int32
  • func (m *Heartbeat) GetInstanceId() string
  • func (m *Heartbeat) GetJob() string
  • func (m *Heartbeat) GetJobState() string
  • func (m *Heartbeat) GetMetrics() []*Heartbeat_Metric
  • func (*Heartbeat) ProtoMessage()
  • func (m *Heartbeat) Reset()
  • func (m *Heartbeat) String() string
• type Heartbeat_Metric
  • func (*Heartbeat_Metric) Descriptor() ([]byte, []int)
  • func (m *Heartbeat_Metric) GetName() string
  • func (m *Heartbeat_Metric) GetTags() map[string]string
  • func (m *Heartbeat_Metric) GetTimestamp() int64
  • func (m *Heartbeat_Metric) GetValue() float64
  • func (*Heartbeat_Metric) ProtoMessage()
  • func (m *Heartbeat_Metric) Reset()
  • func (m *Heartbeat_Metric) String() string

Functions

func RegisterEgressServer

func RegisterEgressServer(s *grpc.Server, srv EgressServer)

Types

type Alert

type Alert struct {
	Severity int32  `protobuf:"varint,1,opt,name=severity" json:"severity,omitempty"`
	Category string `protobuf:"bytes,2,opt,name=category" json:"category,omitempty"`
	Title    string `protobuf:"bytes,3,opt,name=title" json:"title,omitempty"`
	Summary  string `protobuf:"bytes,4,opt,name=summary" json:"summary,omitempty"`
	Source   string `protobuf:"bytes,5,opt,name=source" json:"source,omitempty"`
}

func (*Alert) Descriptor

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

func (*Alert) GetCategory

func (m *Alert) GetCategory() string

func (*Alert) GetSeverity

func (m *Alert) GetSeverity() int32

func (*Alert) GetSource

func (m *Alert) GetSource() string

func (*Alert) GetSummary

func (m *Alert) GetSummary() string

func (*Alert) GetTitle

func (m *Alert) GetTitle() string

func (*Alert) ProtoMessage

func (*Alert) ProtoMessage()

func (*Alert) Reset

func (m *Alert) Reset()

func (*Alert) String

func (m *Alert) String() string

type EgressClient

type EgressClient interface {
	BoshMetrics(ctx context.Context, in *EgressRequest, opts ...grpc.CallOption) (Egress_BoshMetricsClient, error)
}

func NewEgressClient

func NewEgressClient(cc *grpc.ClientConn) EgressClient

type EgressRequest

type EgressRequest struct {
	SubscriptionId string `protobuf:"bytes,1,opt,name=subscription_id,json=subscriptionId" json:"subscription_id,omitempty"`
}

func (*EgressRequest) Descriptor

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

func (*EgressRequest) GetSubscriptionId

func (m *EgressRequest) GetSubscriptionId() string

func (*EgressRequest) ProtoMessage

func (*EgressRequest) ProtoMessage()

func (*EgressRequest) Reset

func (m *EgressRequest) Reset()

func (*EgressRequest) String

func (m *EgressRequest) String() string

type EgressServer

type EgressServer interface {
	BoshMetrics(*EgressRequest, Egress_BoshMetricsServer) error
}

type Egress_BoshMetricsClient

type Egress_BoshMetricsClient interface {
	Recv() (*Event, error)
	grpc.ClientStream
}

type Egress_BoshMetricsServer

type Egress_BoshMetricsServer interface {
	Send(*Event) error
	grpc.ServerStream
}

type Event

type Event struct {
	Timestamp  int64  `protobuf:"varint,1,opt,name=timestamp" json:"timestamp,omitempty"`
	Id         string `protobuf:"bytes,2,opt,name=id" json:"id,omitempty"`
	Deployment string `protobuf:"bytes,3,opt,name=deployment" json:"deployment,omitempty"`
	// Types that are valid to be assigned to Message:
	//	*Event_Heartbeat
	//	*Event_Alert
	Message isEvent_Message `protobuf_oneof:"message"`
}

func (*Event) Descriptor

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

func (*Event) GetAlert

func (m *Event) GetAlert() *Alert

func (*Event) GetDeployment

func (m *Event) GetDeployment() string

func (*Event) GetHeartbeat

func (m *Event) GetHeartbeat() *Heartbeat

func (*Event) GetId

func (m *Event) GetId() string

func (*Event) GetMessage

func (m *Event) GetMessage() isEvent_Message

func (*Event) GetTimestamp

func (m *Event) GetTimestamp() int64

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) Reset

func (m *Event) Reset()

func (*Event) String

func (m *Event) String() string

func (*Event) XXX_OneofFuncs

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

XXX_OneofFuncs is for the internal use of the proto package.

type Event_Alert

type Event_Alert struct {
	Alert *Alert `protobuf:"bytes,5,opt,name=alert,oneof"`
}

type Event_Heartbeat

type Event_Heartbeat struct {
	Heartbeat *Heartbeat `protobuf:"bytes,4,opt,name=heartbeat,oneof"`
}

type Heartbeat

type Heartbeat struct {
	AgentId    string              `protobuf:"bytes,1,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	Job        string              `protobuf:"bytes,2,opt,name=job" json:"job,omitempty"`
	Index      int32               `protobuf:"varint,3,opt,name=index" json:"index,omitempty"`
	InstanceId string              `protobuf:"bytes,4,opt,name=instance_id,json=instanceId" json:"instance_id,omitempty"`
	JobState   string              `protobuf:"bytes,5,opt,name=job_state,json=jobState" json:"job_state,omitempty"`
	Metrics    []*Heartbeat_Metric `protobuf:"bytes,6,rep,name=metrics" json:"metrics,omitempty"`
}

func (*Heartbeat) Descriptor

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

func (*Heartbeat) GetAgentId

func (m *Heartbeat) GetAgentId() string

func (*Heartbeat) GetIndex

func (m *Heartbeat) GetIndex() int32

func (*Heartbeat) GetInstanceId

func (m *Heartbeat) GetInstanceId() string

func (*Heartbeat) GetJob

func (m *Heartbeat) GetJob() string

func (*Heartbeat) GetJobState

func (m *Heartbeat) GetJobState() string

func (*Heartbeat) GetMetrics

func (m *Heartbeat) GetMetrics() []*Heartbeat_Metric

func (*Heartbeat) ProtoMessage

func (*Heartbeat) ProtoMessage()

func (*Heartbeat) Reset

func (m *Heartbeat) Reset()

func (*Heartbeat) String

func (m *Heartbeat) String() string

type Heartbeat_Metric

type Heartbeat_Metric struct {
	Name      string            `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Value     float64           `protobuf:"fixed64,2,opt,name=value" json:"value,omitempty"`
	Timestamp int64             `protobuf:"varint,3,opt,name=timestamp" json:"timestamp,omitempty"`
	Tags      map[string]string `` /* 128-byte string literal not displayed */
}

func (*Heartbeat_Metric) Descriptor

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

func (*Heartbeat_Metric) GetName

func (m *Heartbeat_Metric) GetName() string

func (*Heartbeat_Metric) GetTags

func (m *Heartbeat_Metric) GetTags() map[string]string

func (*Heartbeat_Metric) GetTimestamp

func (m *Heartbeat_Metric) GetTimestamp() int64

func (*Heartbeat_Metric) GetValue

func (m *Heartbeat_Metric) GetValue() float64

func (*Heartbeat_Metric) ProtoMessage

func (*Heartbeat_Metric) ProtoMessage()

func (*Heartbeat_Metric) Reset

func (m *Heartbeat_Metric) Reset()

func (*Heartbeat_Metric) String

func (m *Heartbeat_Metric) String() string