flusher

Documentation

Overview

Package flusher is a generated protocol buffer package.

It is generated from these files:

flusher/flusher.proto

It has these top-level messages:

Event
Update
Error

Index

• type Error
  • func (*Error) Descriptor() ([]byte, []int)
  • func (m *Error) GetKind() string
  • func (m *Error) GetLevel() string
  • func (m *Error) GetMessage() string
  • func (m *Error) GetNode() string
  • func (m *Error) GetTaskKey() string
  • func (m *Error) GetTimestamp() int64
  • func (*Error) ProtoMessage()
  • func (m *Error) Reset()
  • func (m *Error) String() string
• type Event
  • func (*Event) Descriptor() ([]byte, []int)
  • func (m *Event) GetKind() string
  • func (m *Event) GetPayload() []*blackhole.Payload
  • func (m *Event) GetSpanContext() *stellar.SpanContext
  • func (m *Event) GetTaskKey() string
  • func (*Event) ProtoMessage()
  • func (m *Event) Reset()
  • func (m *Event) String() string
• type Update
  • func (*Update) Descriptor() ([]byte, []int)
  • func (m *Update) GetKind() string
  • func (m *Update) GetNode() string
  • func (m *Update) GetSpanContext() *stellar.SpanContext
  • func (m *Update) GetTaskKey() string
  • func (*Update) ProtoMessage()
  • func (m *Update) Reset()
  • func (m *Update) String() string

Types

type Error

type Error struct {
	TaskKey   string `protobuf:"bytes,1,opt,name=taskKey" json:"taskKey,omitempty"`
	Kind      string `protobuf:"bytes,2,opt,name=kind" json:"kind,omitempty"`
	Node      string `protobuf:"bytes,3,opt,name=node" json:"node,omitempty"`
	Message   string `protobuf:"bytes,4,opt,name=message" json:"message,omitempty"`
	Timestamp int64  `protobuf:"varint,5,opt,name=timestamp" json:"timestamp,omitempty"`
	Level     string `protobuf:"bytes,6,opt,name=level" json:"level,omitempty"`
}

func (*Error) Descriptor

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

func (*Error) GetKind

func (m *Error) GetKind() string

func (*Error) GetLevel

func (m *Error) GetLevel() string

func (*Error) GetMessage

func (m *Error) GetMessage() string

func (*Error) GetNode

func (m *Error) GetNode() string

func (*Error) GetTaskKey

func (m *Error) GetTaskKey() string

func (*Error) GetTimestamp

func (m *Error) GetTimestamp() int64

func (*Error) ProtoMessage

func (*Error) ProtoMessage()

func (*Error) Reset

func (m *Error) Reset()

func (*Error) String

func (m *Error) String() string

type Event

type Event struct {
	TaskKey     string               `protobuf:"bytes,1,opt,name=taskKey" json:"taskKey,omitempty"`
	Kind        string               `protobuf:"bytes,2,opt,name=kind" json:"kind,omitempty"`
	Payload     []*blackhole.Payload `protobuf:"bytes,3,rep,name=payload" json:"payload,omitempty"`
	SpanContext *stellar.SpanContext `protobuf:"bytes,4,opt,name=spanContext" json:"spanContext,omitempty"`
}

func (*Event) Descriptor

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

func (*Event) GetKind

func (m *Event) GetKind() string

func (*Event) GetPayload

func (m *Event) GetPayload() []*blackhole.Payload

func (*Event) GetSpanContext

func (m *Event) GetSpanContext() *stellar.SpanContext

func (*Event) GetTaskKey

func (m *Event) GetTaskKey() string

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) Reset

func (m *Event) Reset()

func (*Event) String

func (m *Event) String() string

type Update

type Update struct {
	TaskKey     string               `protobuf:"bytes,1,opt,name=taskKey" json:"taskKey,omitempty"`
	Kind        string               `protobuf:"bytes,2,opt,name=kind" json:"kind,omitempty"`
	Node        string               `protobuf:"bytes,3,opt,name=node" json:"node,omitempty"`
	SpanContext *stellar.SpanContext `protobuf:"bytes,4,opt,name=spanContext" json:"spanContext,omitempty"`
}

func (*Update) Descriptor

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

func (*Update) GetKind

func (m *Update) GetKind() string

func (*Update) GetNode

func (m *Update) GetNode() string

func (*Update) GetSpanContext

func (m *Update) GetSpanContext() *stellar.SpanContext

func (*Update) GetTaskKey

func (m *Update) GetTaskKey() string

func (*Update) ProtoMessage

func (*Update) ProtoMessage()

func (*Update) Reset

func (m *Update) Reset()

func (*Update) String

func (m *Update) String() string