clients

package
v0.0.0-...-2081a44 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 10, 2018 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrRELPClosed = RELPClientError(eerrors.New("Closed"))
View Source 
var ErrRELPNoHost = RELPClientError(eerrors.New("Empty host or empty unix socket path"))
View Source 
var ErrRELPNoPort = RELPClientError(eerrors.New("Empty port"))
View Source 
var ErrRELPNotConnected = RELPClientError(eerrors.New("Not connected"))
View Source 
var ErrRELPTimeout = RELPClientError(eerrors.New("Timeout waiting for RELP response"))
View Source 
var ErrTCPClosed = eerrors.WithTypes(eerrors.New("TCPClient: closed"), "Closed")
View Source 
var ErrTCPNotConnected = eerrors.WithTypes(eerrors.New("TCPClient: not connected"), "NotConnected")
View Source 
var OPEN = []byte("relp_version=0\nrelp_software=skewer\ncommands=syslog")

Functions

func RELPClientError 

func RELPClientError(err error) error

Types

type IntKey 

type IntKey int32

func (IntKey) Equals 

func (self IntKey) Equals(t gotomic.Thing) bool

func (IntKey) HashCode 

func (self IntKey) HashCode() uint32

type KafkaClient 

type KafkaClient struct {
}

func (*KafkaClient) Ack 

func (k *KafkaClient) Ack() *queue.AckQueue

func (*KafkaClient) Close 

func (k *KafkaClient) Close() error

func (*KafkaClient) Connect 

func (k *KafkaClient) Connect() error

func (*KafkaClient) Flush 

func (k *KafkaClient) Flush() error

func (*KafkaClient) Nack 

func (k *KafkaClient) Nack() *queue.AckQueue

func (*KafkaClient) Send 

func (k *KafkaClient) Send(msg *model.FullMessage) error

type RELPClient 

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

func NewRELPClient 

func NewRELPClient(logger log15.Logger) *RELPClient

func (*RELPClient) Ack 

func (c *RELPClient) Ack() *queue.AckQueue

func (*RELPClient) Close 

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

func (*RELPClient) ConnTimeout 

func (c *RELPClient) ConnTimeout(timeout time.Duration) *RELPClient

func (*RELPClient) Connect 

func (c *RELPClient) Connect() (err error)

func (*RELPClient) Flush 

func (c *RELPClient) Flush() error

func (*RELPClient) FlushPeriod 

func (c *RELPClient) FlushPeriod(period time.Duration) *RELPClient

func (*RELPClient) Format 

func (c *RELPClient) Format(format baseenc.Format) *RELPClient

func (*RELPClient) Host 

func (c *RELPClient) Host(host string) *RELPClient

func (*RELPClient) KeepAlive 

func (c *RELPClient) KeepAlive(keepAlive bool) *RELPClient

func (*RELPClient) KeepAlivePeriod 

func (c *RELPClient) KeepAlivePeriod(period time.Duration) *RELPClient

func (*RELPClient) Nack 

func (c *RELPClient) Nack() *queue.AckQueue

func (*RELPClient) Path 

func (c *RELPClient) Path(path string) *RELPClient

func (*RELPClient) Port 

func (c *RELPClient) Port(port int) *RELPClient

func (*RELPClient) RelpTimeout 

func (c *RELPClient) RelpTimeout(timeout time.Duration) *RELPClient

func (*RELPClient) Send 

func (c *RELPClient) Send(ctx context.Context, msg *model.FullMessage) error

func (*RELPClient) TLS 

func (c *RELPClient) TLS(config *tls.Config) *RELPClient

func (*RELPClient) WindowSize 

func (c *RELPClient) WindowSize(size int32) *RELPClient

type SyslogTCPClient 

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

func NewSyslogTCPClient 

func NewSyslogTCPClient(logger log15.Logger) *SyslogTCPClient

func (*SyslogTCPClient) Ack 

func (c *SyslogTCPClient) Ack() *queue.AckQueue

func (*SyslogTCPClient) Close 

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

func (*SyslogTCPClient) ConnTimeout 

func (c *SyslogTCPClient) ConnTimeout(timeout time.Duration) *SyslogTCPClient

func (*SyslogTCPClient) Connect 

func (c *SyslogTCPClient) Connect(ctx context.Context) (err error)

func (*SyslogTCPClient) Flush 

func (c *SyslogTCPClient) Flush() error

func (*SyslogTCPClient) FlushPeriod 

func (c *SyslogTCPClient) FlushPeriod(period time.Duration) *SyslogTCPClient

func (*SyslogTCPClient) Format 

func (c *SyslogTCPClient) Format(format baseenc.Format) *SyslogTCPClient

func (*SyslogTCPClient) FrameDelimiter 

func (c *SyslogTCPClient) FrameDelimiter(delimiter uint8) *SyslogTCPClient

func (*SyslogTCPClient) Host 

func (c *SyslogTCPClient) Host(host string) *SyslogTCPClient

func (*SyslogTCPClient) KeepAlive 

func (c *SyslogTCPClient) KeepAlive(keepAlive bool) *SyslogTCPClient

func (*SyslogTCPClient) KeepAlivePeriod 

func (c *SyslogTCPClient) KeepAlivePeriod(period time.Duration) *SyslogTCPClient

func (*SyslogTCPClient) LineFraming 

func (c *SyslogTCPClient) LineFraming(framing bool) *SyslogTCPClient

func (*SyslogTCPClient) Nack 

func (c *SyslogTCPClient) Nack() *queue.AckQueue

func (*SyslogTCPClient) Path 

func (c *SyslogTCPClient) Path(path string) *SyslogTCPClient

func (*SyslogTCPClient) Port 

func (c *SyslogTCPClient) Port(port int) *SyslogTCPClient

func (*SyslogTCPClient) Send 

func (c *SyslogTCPClient) Send(ctx context.Context, msg *model.FullMessage) (err error)

func (*SyslogTCPClient) TLS 

func (c *SyslogTCPClient) TLS(config *tls.Config) *SyslogTCPClient

type SyslogUDPClient 

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

func NewSyslogUDPClient 

func NewSyslogUDPClient(logger log15.Logger) *SyslogUDPClient

func (*SyslogUDPClient) Ack 

func (c *SyslogUDPClient) Ack() chan ulid.ULID

func (*SyslogUDPClient) Close 

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

func (*SyslogUDPClient) Connect 

func (c *SyslogUDPClient) Connect() (err error)

func (*SyslogUDPClient) Flush 

func (c *SyslogUDPClient) Flush() error

func (*SyslogUDPClient) Format 

func (c *SyslogUDPClient) Format(format baseenc.Format) *SyslogUDPClient

func (*SyslogUDPClient) Host 

func (c *SyslogUDPClient) Host(host string) *SyslogUDPClient

func (*SyslogUDPClient) Nack 

func (c *SyslogUDPClient) Nack() chan ulid.ULID

func (*SyslogUDPClient) Path 

func (c *SyslogUDPClient) Path(path string) *SyslogUDPClient

func (*SyslogUDPClient) Port 

func (c *SyslogUDPClient) Port(port int) *SyslogUDPClient

func (*SyslogUDPClient) Send 

func (c *SyslogUDPClient) Send(msg *model.FullMessage) (err error)

type Txnr2UidMap 

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

func NewTxnrMap 

func NewTxnrMap(maxsize int32) *Txnr2UidMap

func (*Txnr2UidMap) Dispose 

func (m *Txnr2UidMap) Dispose()

func (*Txnr2UidMap) ForEach 

func (m *Txnr2UidMap) ForEach(f func(int32, utils.MyULID))

func (*Txnr2UidMap) Get 

func (m *Txnr2UidMap) Get(txnr int32) (uid utils.MyULID, err error)

func (*Txnr2UidMap) Put 

func (m *Txnr2UidMap) Put(txnr int32, uid utils.MyULID) (err error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.