clientpool

Documentation

Index

• type ClientPool
  • func New(conns ...Conn) *ClientPool
  • func (c *ClientPool) Write(msg []byte) error
• type Conn
• type ConnManager
  • func NewConnManager(c Connector, maxWrites int64) *ConnManager
  • func (m *ConnManager) Write(data []byte) error
• type Connector
• type DialFunc
• type GRPCConnector
  • func MakeGRPCConnector(doppler string, zonePrefix string, df DialFunc, cf IngestorClientFunc, ...) GRPCConnector
  • func (c GRPCConnector) Connect() (io.Closer, plumbing.DopplerIngestor_PusherClient, error)
  • func (c GRPCConnector) String() string
• type IngestorClientFunc

Types

type ClientPool

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

func New

func New(conns ...Conn) *ClientPool

func (*ClientPool) Write

func (c *ClientPool) Write(msg []byte) error

type Conn

type Conn interface {
	Write(data []byte) (err error)
}

type ConnManager

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

func NewConnManager

func NewConnManager(c Connector, maxWrites int64) *ConnManager

func (*ConnManager) Write

func (m *ConnManager) Write(data []byte) error

type Connector

type Connector interface {
	Connect() (io.Closer, plumbing.DopplerIngestor_PusherClient, error)
}

type DialFunc

type DialFunc func(string, ...grpc.DialOption) (*grpc.ClientConn, error)

type GRPCConnector

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

func MakeGRPCConnector

func MakeGRPCConnector(
	doppler string,
	zonePrefix string,
	df DialFunc,
	cf IngestorClientFunc,
	opts ...grpc.DialOption,
) GRPCConnector

func (GRPCConnector) Connect

func (c GRPCConnector) Connect() (io.Closer, plumbing.DopplerIngestor_PusherClient, error)

func (GRPCConnector) String

func (c GRPCConnector) String() string

type IngestorClientFunc

type IngestorClientFunc func(*grpc.ClientConn) plumbing.DopplerIngestorClient