logstreamer

Documentation

Index

• Constants
• Variables
• func NewChannelPool(initialCap, maxCap int, factory Factory, isTls bool) (*channelPool, error)
• type Factory
• type LogStreamer
  • func NewLogStreamer(ctx context.Context, critool *cri.CRITool) (*LogStreamer, error)
  • func (ls *LogStreamer) Done() chan struct{}
  • func (ls *LogStreamer) StreamLogs() error
• type PoolConn
  • func (p *PoolConn) Close() error
  • func (p *PoolConn) MarkUnusable()

Constants

const CaCert = `` /* 1874-byte string literal not displayed */

Variables

var ErrClosed = errors.New("pool is closed")

Functions

func NewChannelPool

func NewChannelPool(initialCap, maxCap int, factory Factory, isTls bool) (*channelPool, error)

Types

type Factory

type Factory func() (net.Conn, error)

Factory is a function to create new connections.

type LogStreamer

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

func NewLogStreamer

func NewLogStreamer(ctx context.Context, critool *cri.CRITool) (*LogStreamer, error)

func (*LogStreamer) Done

func (ls *LogStreamer) Done() chan struct{}

func (*LogStreamer) StreamLogs

func (ls *LogStreamer) StreamLogs() error

type PoolConn

type PoolConn struct {
	net.Conn
	// contains filtered or unexported fields
}

func (*PoolConn) Close

func (p *PoolConn) Close() error

Close() puts the given connects back to the pool instead of closing it.

func (*PoolConn) MarkUnusable

func (p *PoolConn) MarkUnusable()

MarkUnusable() marks the connection not usable any more, to let the pool close it instead of returning it to pool.