firehose

Documentation

Index

• func NewRawAdapter(route *router.Route) (router.LogAdapter, error)
• type Adapter
  • func (adapter *Adapter) Stream(logstream chan *router.Message)
• type ContainerInfo
• type Record

Functions

func NewRawAdapter

func NewRawAdapter(route *router.Route) (router.LogAdapter, error)

Types

type Adapter

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

func (*Adapter) Stream

func (adapter *Adapter) Stream(logstream chan *router.Message)

Stream decode message and send it to the firehose queue

type ContainerInfo

type ContainerInfo struct {
	Name      string `json:"name"`
	Fullpod   string `json:"full-pod,omitempty"`
	Podprefix string `json:"pod,omitempty"`
	Namespace string `json:"ns,omitempty"`
	ID        string `json:"id,omitempty"`
}

type Record

type Record map[string]interface{}