lokiutil

Documentation

Index

• type Batch
• type Client
  • func New(url string, maxSize int, maxWait time.Duration, keys []string) *Client
  • func (c *Client) Errc() <-chan error
  • func (c *Client) Log(m Message)
  • func (c *Client) Run() error
  • func (c *Client) Stop()
• type Message

Types

type Batch

type Batch = []*logproto.Stream

type Client

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

func New

func New(url string, maxSize int, maxWait time.Duration, keys []string) *Client

func (*Client) Errc

func (c *Client) Errc() <-chan error

func (*Client) Log

func (c *Client) Log(m Message)

func (*Client) Run

func (c *Client) Run() error

Run processes the messages in the background. It needs to get stopped by Stop() to not lose messages. It is not controlled by a context, because logging should be the last component that gets stopped.

func (*Client) Stop

func (c *Client) Stop()

Stop sends the remaining messages and stops processing new ones.

type Message

type Message = map[string]interface{}