log_streamer

Documentation

Index

• Constants
• func NewLogRateLimiter(ctx context.Context, metronClient loggingclient.IngressClient, ...) *logRateLimiter
• type ConcurrentBuffer
  • func NewConcurrentBuffer(payload *bytes.Buffer) *ConcurrentBuffer
  • func (b *ConcurrentBuffer) Read(buf []byte) (int, error)
  • func (b *ConcurrentBuffer) Reset()
  • func (b *ConcurrentBuffer) Write(buf []byte) (int, error)
• type LogStreamer
  • func New(config executor.LogConfig, metronClient loggingclient.IngressClient, ...) LogStreamer
  • func NewBufferStreamer(stdout, stderr io.Writer) LogStreamer
  • func NewNoopStreamer() LogStreamer

Constants

const (
	AppInstanceExceededLogRateLimitCount = "AppInstanceExceededLogRateLimitCount"
	LogRateLimitExceededLogInterval      = time.Second
)

const (
	MAX_MESSAGE_SIZE = 61440

	DefaultLogSource = "LOG"
)

Functions

func NewLogRateLimiter

func NewLogRateLimiter(
	ctx context.Context,
	metronClient loggingclient.IngressClient,
	tags map[string]string,
	maxLogLinesPerSecond int,
	maxLogBytesPerSecond int64,
	logMetricsEmitInterval time.Duration,
) *logRateLimiter

Types

type ConcurrentBuffer

type ConcurrentBuffer struct {
	Buffer *bytes.Buffer
	*sync.Mutex
}

func NewConcurrentBuffer

func NewConcurrentBuffer(payload *bytes.Buffer) *ConcurrentBuffer

func (*ConcurrentBuffer) Read

func (b *ConcurrentBuffer) Read(buf []byte) (int, error)

func (*ConcurrentBuffer) Reset

func (b *ConcurrentBuffer) Reset()

func (*ConcurrentBuffer) Write

func (b *ConcurrentBuffer) Write(buf []byte) (int, error)

type LogStreamer

type LogStreamer interface {
	Stdout() io.Writer
	Stderr() io.Writer

	UpdateTags(map[string]string)
	Flush()

	WithSource(sourceName string) LogStreamer
	SourceName() string

	Stop()
}

func New

func New(config executor.LogConfig, metronClient loggingclient.IngressClient, maxLogLinesPerSecond int, maxLogBytesPerSecond int64, metricReportInterval time.Duration) LogStreamer

func NewBufferStreamer

func NewBufferStreamer(stdout, stderr io.Writer) LogStreamer

func NewNoopStreamer

func NewNoopStreamer() LogStreamer