logs

Documentation

Index

• Constants
• Variables
• type Encoder
• type JournalEncoder
  • func CreateJournalEncoder() (*JournalEncoder, error)
  • func (c *JournalEncoder) Close() (err error)
  • func (c *JournalEncoder) Encode(logline *types.Log) error
• type StreamEncoder
  • func NewStreamEncoder(wt io.WriteCloser) *StreamEncoder
  • func (e *StreamEncoder) Close() error
  • func (e *StreamEncoder) Encode(logline *types.Log) error
• type Writer
  • func NewWriter(ctx context.Context, addr string, stdout bool) (writer *Writer, err error)
  • func (w *Writer) Write(logline *types.Log) error

Constants

const Discard = "__discard__"

Discard .

Variables

var CloseWaitInterval = time.Second * 5

CloseWaitInterval .

var KeepaliveInterval = time.Second * 30

KeepaliveInterval .

Types

type Encoder

type Encoder interface {
	Encode(*types.Log) error
	Close() error
}

Encoder .

type JournalEncoder

type JournalEncoder struct {
	sync.Mutex
}

JournalEncoder .

func CreateJournalEncoder

func CreateJournalEncoder() (*JournalEncoder, error)

CreateJournalEncoder .

func (*JournalEncoder) Close

func (c *JournalEncoder) Close() (err error)

Close .

func (*JournalEncoder) Encode

func (c *JournalEncoder) Encode(logline *types.Log) error

Encode .

type StreamEncoder

type StreamEncoder struct {
	*json.Encoder
	// contains filtered or unexported fields
}

StreamEncoder .

func NewStreamEncoder

func NewStreamEncoder(wt io.WriteCloser) *StreamEncoder

NewStreamEncoder .

func (*StreamEncoder) Close

func (e *StreamEncoder) Close() error

Close .

func (*StreamEncoder) Encode

func (e *StreamEncoder) Encode(logline *types.Log) error

Encode .

type Writer

type Writer struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Writer is a writer!

func NewWriter

func NewWriter(ctx context.Context, addr string, stdout bool) (writer *Writer, err error)

NewWriter return writer

func (*Writer) Write

func (w *Writer) Write(logline *types.Log) error

Write write log to remote