consumers

Documentation

Index

• Constants
• type Consumer
  • func NewESConsumer(url, username, password string) (Consumer, error)
  • func NewLokiConsumer(url string) (Consumer, error)
• type PushRequest
• type Stream

Constants

const (
	// APIPush push url
	APIPush = "/loki/api/v1/push"
)

Types

type Consumer

type Consumer interface {
	C() chan *common.Message
	Consume()
}

Consumer consume messages

func NewESConsumer

func NewESConsumer(url, username, password string) (Consumer, error)

NewESConsumer create ealsticsearch consumer

func NewLokiConsumer

func NewLokiConsumer(url string) (Consumer, error)

NewLokiConsumer create loki consumer

type PushRequest

type PushRequest struct {
	Streams []Stream `json:"streams"`
}

PushRequest POST /loki/api/v1/push body struct

type Stream

type Stream struct {
	Labels  map[string]string `json:"stream"`
	Entries [][]string        `json:"values"`
}

Stream struct