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 Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. 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{} Source Files ¶ View all Source files buf.go client.go message.go Click to show internal directories. Click to hide internal directories.