riemannpb

Documentation

Index

• Variables
• type Attribute
  • func (*Attribute) Descriptor() ([]byte, []int)
  • func (m *Attribute) GetKey() string
  • func (m *Attribute) GetValue() string
  • func (m *Attribute) Marshal() (dAtA []byte, err error)
  • func (m *Attribute) MarshalTo(dAtA []byte) (int, error)
  • func (m *Attribute) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Attribute) ProtoMessage()
  • func (m *Attribute) Reset()
  • func (m *Attribute) Size() (n int)
  • func (m *Attribute) String() string
  • func (m *Attribute) Unmarshal(dAtA []byte) error
  • func (m *Attribute) XXX_DiscardUnknown()
  • func (m *Attribute) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Attribute) XXX_Merge(src proto.Message)
  • func (m *Attribute) XXX_Size() int
  • func (m *Attribute) XXX_Unmarshal(b []byte) error
• type Event
  • func (*Event) Descriptor() ([]byte, []int)
  • func (m *Event) GetAttributes() []*Attribute
  • func (m *Event) GetDescription() string
  • func (m *Event) GetHost() string
  • func (m *Event) GetMetricD() float64
  • func (m *Event) GetMetricF() float32
  • func (m *Event) GetMetricSint64() int64
  • func (m *Event) GetService() string
  • func (m *Event) GetState() string
  • func (m *Event) GetTags() []string
  • func (m *Event) GetTime() int64
  • func (m *Event) GetTimeMicros() int64
  • func (m *Event) GetTtl() float32
  • func (m *Event) Marshal() (dAtA []byte, err error)
  • func (m *Event) MarshalTo(dAtA []byte) (int, error)
  • func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Event) ProtoMessage()
  • func (m *Event) Reset()
  • func (m *Event) Size() (n int)
  • func (m *Event) String() string
  • func (m *Event) Unmarshal(dAtA []byte) error
  • func (m *Event) XXX_DiscardUnknown()
  • func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Event) XXX_Merge(src proto.Message)
  • func (m *Event) XXX_Size() int
  • func (m *Event) XXX_Unmarshal(b []byte) error
• type Msg
  • func (*Msg) Descriptor() ([]byte, []int)
  • func (m *Msg) GetError() string
  • func (m *Msg) GetEvents() []*Event
  • func (m *Msg) GetOk() bool
  • func (m *Msg) Marshal() (dAtA []byte, err error)
  • func (m *Msg) MarshalTo(dAtA []byte) (int, error)
  • func (m *Msg) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Msg) ProtoMessage()
  • func (m *Msg) Reset()
  • func (m *Msg) Size() (n int)
  • func (m *Msg) String() string
  • func (m *Msg) Unmarshal(dAtA []byte) error
  • func (m *Msg) XXX_DiscardUnknown()
  • func (m *Msg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Msg) XXX_Merge(src proto.Message)
  • func (m *Msg) XXX_Size() int
  • func (m *Msg) XXX_Unmarshal(b []byte) error

Variables

var (
	ErrInvalidLengthRiemann = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRiemann   = fmt.Errorf("proto: integer overflow")
)

Types

type Attribute

type Attribute struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Attribute) Descriptor

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

func (*Attribute) GetKey

func (m *Attribute) GetKey() string

func (*Attribute) GetValue

func (m *Attribute) GetValue() string

func (*Attribute) Marshal

func (m *Attribute) Marshal() (dAtA []byte, err error)

func (*Attribute) MarshalTo

func (m *Attribute) MarshalTo(dAtA []byte) (int, error)

func (*Attribute) MarshalToSizedBuffer

func (m *Attribute) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Attribute) ProtoMessage

func (*Attribute) ProtoMessage()

func (*Attribute) Reset

func (m *Attribute) Reset()

func (*Attribute) Size

func (m *Attribute) Size() (n int)

func (*Attribute) String

func (m *Attribute) String() string

func (*Attribute) Unmarshal

func (m *Attribute) Unmarshal(dAtA []byte) error

func (*Attribute) XXX_DiscardUnknown

func (m *Attribute) XXX_DiscardUnknown()

func (*Attribute) XXX_Marshal

func (m *Attribute) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Attribute) XXX_Merge

func (m *Attribute) XXX_Merge(src proto.Message)

func (*Attribute) XXX_Size

func (m *Attribute) XXX_Size() int

func (*Attribute) XXX_Unmarshal

func (m *Attribute) XXX_Unmarshal(b []byte) error

type Event

type Event struct {
	Time         int64        `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	State        string       `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	Service      string       `protobuf:"bytes,3,opt,name=service,proto3" json:"service,omitempty"`
	Host         string       `protobuf:"bytes,4,opt,name=host,proto3" json:"host,omitempty"`
	Description  string       `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	Tags         []string     `protobuf:"bytes,7,rep,name=tags,proto3" json:"tags,omitempty"`
	Ttl          float32      `protobuf:"fixed32,8,opt,name=ttl,proto3" json:"ttl,omitempty"`
	Attributes   []*Attribute `protobuf:"bytes,9,rep,name=attributes,proto3" json:"attributes,omitempty"`
	TimeMicros   int64        `protobuf:"varint,10,opt,name=time_micros,json=timeMicros,proto3" json:"time_micros,omitempty"`
	MetricSint64 int64        `protobuf:"zigzag64,13,opt,name=metric_sint64,json=metricSint64,proto3" json:"metric_sint64,omitempty"`
	MetricD      float64      `protobuf:"fixed64,14,opt,name=metric_d,json=metricD,proto3" json:"metric_d,omitempty"`
	MetricF      float32      `protobuf:"fixed32,15,opt,name=metric_f,json=metricF,proto3" json:"metric_f,omitempty"`
}

func (*Event) Descriptor

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

func (*Event) GetAttributes

func (m *Event) GetAttributes() []*Attribute

func (*Event) GetDescription

func (m *Event) GetDescription() string

func (*Event) GetHost

func (m *Event) GetHost() string

func (*Event) GetMetricD

func (m *Event) GetMetricD() float64

func (*Event) GetMetricF

func (m *Event) GetMetricF() float32

func (*Event) GetMetricSint64

func (m *Event) GetMetricSint64() int64

func (*Event) GetService

func (m *Event) GetService() string

func (*Event) GetState

func (m *Event) GetState() string

func (*Event) GetTags

func (m *Event) GetTags() []string

func (*Event) GetTime

func (m *Event) GetTime() int64

func (*Event) GetTimeMicros

func (m *Event) GetTimeMicros() int64

func (*Event) GetTtl

func (m *Event) GetTtl() float32

func (*Event) Marshal

func (m *Event) Marshal() (dAtA []byte, err error)

func (*Event) MarshalTo

func (m *Event) MarshalTo(dAtA []byte) (int, error)

func (*Event) MarshalToSizedBuffer

func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) Reset

func (m *Event) Reset()

func (*Event) Size

func (m *Event) Size() (n int)

func (*Event) String

func (m *Event) String() string

func (*Event) Unmarshal

func (m *Event) Unmarshal(dAtA []byte) error

func (*Event) XXX_DiscardUnknown

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal

func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event) XXX_Merge

func (m *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_Size

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal

func (m *Event) XXX_Unmarshal(b []byte) error

type Msg

type Msg struct {
	Ok     bool     `protobuf:"varint,2,opt,name=ok,proto3" json:"ok,omitempty"`
	Error  string   `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	Events []*Event `protobuf:"bytes,6,rep,name=events,proto3" json:"events,omitempty"`
}

func (*Msg) Descriptor

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

func (*Msg) GetError

func (m *Msg) GetError() string

func (*Msg) GetEvents

func (m *Msg) GetEvents() []*Event

func (*Msg) GetOk

func (m *Msg) GetOk() bool

func (*Msg) Marshal

func (m *Msg) Marshal() (dAtA []byte, err error)

func (*Msg) MarshalTo

func (m *Msg) MarshalTo(dAtA []byte) (int, error)

func (*Msg) MarshalToSizedBuffer

func (m *Msg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Msg) ProtoMessage

func (*Msg) ProtoMessage()

func (*Msg) Reset

func (m *Msg) Reset()

func (*Msg) Size

func (m *Msg) Size() (n int)

func (*Msg) String

func (m *Msg) String() string

func (*Msg) Unmarshal

func (m *Msg) Unmarshal(dAtA []byte) error

func (*Msg) XXX_DiscardUnknown

func (m *Msg) XXX_DiscardUnknown()

func (*Msg) XXX_Marshal

func (m *Msg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Msg) XXX_Merge

func (m *Msg) XXX_Merge(src proto.Message)

func (*Msg) XXX_Size

func (m *Msg) XXX_Size() int

func (*Msg) XXX_Unmarshal

func (m *Msg) XXX_Unmarshal(b []byte) error