devosender

package

Go to main page

Versions in this module

v1

v1.0.3

Oct 13, 2023

Changes in this version

type ClientBuilder

+ func (dsb *ClientBuilder) TLSNoLoadPublicCAs(noLoadPublicCAs bool) *ClientBuilder

v1.0.2

Sep 20, 2022

v1.0.1

May 5, 2022

v1.0.0

Feb 23, 2022

Changes in this version

+ const DefaultClientReconnDaemonInitDelay

+ const DefaultClientReconnDaemonWaitBtwChecks

+ const DefaultDaemonMicroWait

+ const DefaultHouseKeepingDaemonInitDelay

+ const DefaultHouseKeepingDaemonWaitBtwChecks

+ const DefaultMaxRecordsResendByFlush

+ const DefaultResendEventsDaemonInitDelay

+ const DefaultResendEventsDaemonWaitBtwChecks

+ var ErrPayloadNoDefined = errors.New("payload to check connection is not defined")

type Client

+ func (dsc *Client) AsyncError(id string) (bool, error)

+ func (dsc *Client) AsyncErrorsIds() []string

+ func (dsc *Client) IsConnWorking() (bool, error)

type ClientBuilder

+ func (dsb *ClientBuilder) IsConnWorkingCheckPayload(s string) *ClientBuilder

type LazyClient

+ func (lc *LazyClient) IsLimitReachedLastFlush() bool

+ func (lc *LazyClient) OnlyInMemory() bool

+ func (lc *LazyClient) PendingEventsNoConn() int

type LazyClientBuilder

+ func (lcb *LazyClientBuilder) MaxRecordsResendByFlush(max int) *LazyClientBuilder

type LazyClientStats

+ BufferCount int

type ReliableClient

+ func (dsrc *ReliableClient) IsConnWorking() (bool, error)

+ func (dsrc *ReliableClient) IsLimitReachedLastFlush() bool

+ func (dsrc *ReliableClient) OnlyInMemory() bool

+ func (dsrc *ReliableClient) PendingEventsNoConn() int

type ReliableClientBuilder

+ func (dsrcb *ReliableClientBuilder) HouseKeepingDaemonInitDelay(d time.Duration) *ReliableClientBuilder

+ func (dsrcb *ReliableClientBuilder) HouseKeepingDaemonWaitBtwChecks(d time.Duration) *ReliableClientBuilder

+ func (dsrcb *ReliableClientBuilder) MaxRecordsResendByFlush(max int) *ReliableClientBuilder

+ func (dsrcb *ReliableClientBuilder) StatusBuilder(sb status.Builder) *ReliableClientBuilder

type SwitchDevoSender

+ IsLimitReachedLastFlush func() bool

+ OnlyInMemory func() bool

+ PendingEventsNoConn func() int

v0

v0.1.3

Dec 9, 2021

v0.1.2

Dec 3, 2021

v0.1.1

Dec 3, 2021

Changes in this version

type SwitchDevoSender

+ LastSendCallTimestamp func() time.Time

v0.1.0

Dec 2, 2021

Changes in this version

+ const ClientBuilderDefaultCompressorMinSize

+ const ClientBuilderRelayEU

+ const ClientBuilderRelayUS

+ const DefaultBufferEventsSize

+ const DefaultDaemonInitDelay

+ const DefaultDaemonStopTimeout

+ const DefaultDaemonWaitBtwChecks

+ const DefaultEnableStandByModeTimeout

+ const DefaultEventTimeToLive

+ const DefaultFlushAsyncTimeout

+ const DefaultSyslogLevel

+ const DevoCentralRelayEU

+ const DevoCentralRelayUS

+ const LCBDefaultBufferEventsSize

+ const LCBDefaultFlushTimeout

+ var ErrBufferFull = errors.New("Buffer is full")

+ var ErrBufferOverflow = errors.New("Overwriting item(s) because buffer is full")

+ var ErrNilPointerReceiver = errors.New("Receiver func call with nil pointer")

+ var ErrWaitAsyncTimeout = errors.New("Timeout when wait for pending items")

+ var ErrorTagEmpty error = errors.New("Tag can not be empty")

+ func StringCompressorAlgorithm(a CompressorAlgorithm) string

+ type ClienBuilderDevoCentralRelay int

+ func ParseDevoCentralEntrySite(s string) (ClienBuilderDevoCentralRelay, error)

+ type Client struct

+ ReplaceSequences map[string]string

+ func (dsc *Client) AddReplaceSequences(old, new string) error

+ func (dsc *Client) AreAsyncOps() bool

+ func (dsc *Client) AsyncErrors() map[string]error

+ func (dsc *Client) AsyncErrorsNumber() int

+ func (dsc *Client) AsyncIds() []string

+ func (dsc *Client) AsyncsNumber() int

+ func (dsc *Client) Close() error

+ func (dsc *Client) GetEntryPoint() string

+ func (dsc *Client) IsAsyncActive(id string) bool

+ func (dsc *Client) LastSendCallTimestamp() time.Time

+ func (dsc *Client) PurgeAsyncErrors()

+ func (dsc *Client) Send(m string) error

+ func (dsc *Client) SendAsync(m string) string

+ func (dsc *Client) SendWTag(t, m string) error

+ func (dsc *Client) SendWTagAndCompressor(t, m string, c *Compressor) error

+ func (dsc *Client) SendWTagAndCompressorAsync(t, m string, c *Compressor) string

+ func (dsc *Client) SendWTagAsync(t, m string) string

+ func (dsc *Client) SetDefaultTag(t string) error

+ func (dsc *Client) SetSyslogHostName(host string)

+ func (dsc *Client) String() string

+ func (dsc *Client) WaitForPendingAsyncMessages() error

+ func (dsc *Client) WaitForPendingAsyncMsgsOrTimeout(timeout time.Duration) error

+ func (dsc *Client) Write(p []byte) (n int, err error)

+ type ClientBuilder struct

+ func NewClientBuilder() *ClientBuilder

+ func (dsb *ClientBuilder) Build() (*Client, error)

+ func (dsb *ClientBuilder) CompressorMinSize(s int) *ClientBuilder

+ func (dsb *ClientBuilder) ConnectionExpiration(t time.Duration) *ClientBuilder

+ func (dsb *ClientBuilder) DefaultCompressor(c CompressorAlgorithm) *ClientBuilder

+ func (dsb *ClientBuilder) DefaultDevoTag(t string) *ClientBuilder

+ func (dsb *ClientBuilder) DevoCentralEntryPoint(relay ClienBuilderDevoCentralRelay) *ClientBuilder

+ func (dsb *ClientBuilder) EntryPoint(entrypoint string) *ClientBuilder

+ func (dsb *ClientBuilder) TCPKeepAlive(t time.Duration) *ClientBuilder

+ func (dsb *ClientBuilder) TCPTimeout(t time.Duration) *ClientBuilder

+ func (dsb *ClientBuilder) TLSCerts(key []byte, cert []byte, chain []byte) *ClientBuilder

+ func (dsb *ClientBuilder) TLSFiles(keyFileName string, certFileName string, chainFileName *string) *ClientBuilder

+ func (dsb *ClientBuilder) TLSInsecureSkipVerify(insecureSkipVerify bool) *ClientBuilder

+ func (dsb *ClientBuilder) TLSRenegotiation(renegotiation tls.RenegotiationSupport) *ClientBuilder

+ type Compressor struct

+ Algorithm CompressorAlgorithm

+ MinimumSize int

+ func (mc *Compressor) Compress(bs []byte) ([]byte, error)

+ func (mc *Compressor) StringAlgoritm() string

+ type CompressorAlgorithm int

+ const CompressorGzip

+ const CompressorNoComprs

+ const CompressorZlib

+ func ParseAlgorithm(s string) (CompressorAlgorithm, error)

+ type DevoSender interface

+ AreAsyncOps func() bool

+ AsyncErrors func() map[string]error

+ AsyncErrorsNumber func() int

+ AsyncIds func() []string

+ AsyncsNumber func() int

+ GetEntryPoint func() string

+ IsAsyncActive func(id string) bool

+ LastSendCallTimestamp func() time.Time

+ PurgeAsyncErrors func()

+ Send func(m string) error

+ SendAsync func(m string) string

+ SendWTag func(t, m string) error

+ SendWTagAsync func(t, m string) string

+ SetDefaultTag func(t string) error

+ String func() string

+ WaitForPendingAsyncMessages func() error

+ func NewDevoSender(entrypoint string) (DevoSender, error)

+ func NewDevoSenderTLS(entrypoint string, key []byte, cert []byte, chain []byte) (DevoSender, error)

+ func NewDevoSenderTLSFiles(entrypoint string, keyFileName string, certFileName string, ...) (DevoSender, error)

+ type LazyClient struct

+ Stats LazyClientStats

+ func (lc *LazyClient) Close() error

+ func (lc *LazyClient) Flush() error

+ func (lc *LazyClient) IsStandBy() bool

+ func (lc *LazyClient) SendAsync(m string) string

+ func (lc *LazyClient) SendWTagAndCompressorAsync(t, m string, c *Compressor) string

+ func (lc *LazyClient) SendWTagAsync(t, m string) string

+ func (lc *LazyClient) StandBy() error

+ func (lc *LazyClient) String() string

+ func (lc *LazyClient) WakeUp() error

+ type LazyClientBuilder struct

+ func NewLazyClientBuilder() *LazyClientBuilder

+ func (lcb *LazyClientBuilder) AppLogger(log applogger.SimpleAppLogger) *LazyClientBuilder

+ func (lcb *LazyClientBuilder) BufferSize(s uint32) *LazyClientBuilder

+ func (lcb *LazyClientBuilder) Build() (*LazyClient, error)

+ func (lcb *LazyClientBuilder) ClientBuilder(cb *ClientBuilder) *LazyClientBuilder

+ func (lcb *LazyClientBuilder) EnableStandByModeTimeout(d time.Duration) *LazyClientBuilder

+ func (lcb *LazyClientBuilder) FlushTimeout(d time.Duration) *LazyClientBuilder

+ type LazyClientStats struct

+ AsyncEvents uint

+ BufferedLost uint

+ SendFromBuffer uint

+ TotalBuffered uint

+ func (lcs LazyClientStats) String() string

+ type ReliableClient struct

+ func (dsrc *ReliableClient) Close() error

+ func (dsrc *ReliableClient) Flush() error

+ func (dsrc *ReliableClient) IsStandBy() bool

+ func (dsrc *ReliableClient) ResetSessionStats() error

+ func (dsrc *ReliableClient) SendAsync(m string) string

+ func (dsrc *ReliableClient) SendWTagAndCompressorAsync(t string, m string, c *Compressor) string

+ func (dsrc *ReliableClient) SendWTagAsync(t, m string) string

+ func (dsrc *ReliableClient) StandBy() error

+ func (dsrc *ReliableClient) Stats() ReliableClientStats

+ func (dsrc *ReliableClient) String() string

+ func (dsrc *ReliableClient) WakeUp() error

+ type ReliableClientBuilder struct

+ func NewReliableClientBuilder() *ReliableClientBuilder

+ func (dsrcb *ReliableClientBuilder) AppLogger(lg applogger.SimpleAppLogger) *ReliableClientBuilder

+ func (dsrcb *ReliableClientBuilder) BufferEventsSize(size uint) *ReliableClientBuilder

+ func (dsrcb *ReliableClientBuilder) Build() (*ReliableClient, error)

+ func (dsrcb *ReliableClientBuilder) ClientBuilder(cb *ClientBuilder) *ReliableClientBuilder

+ func (dsrcb *ReliableClientBuilder) ClientReconnDaemonInitDelay(d time.Duration) *ReliableClientBuilder

+ func (dsrcb *ReliableClientBuilder) ClientReconnDaemonWaitBtwChecks(d time.Duration) *ReliableClientBuilder

+ func (dsrcb *ReliableClientBuilder) DaemonStopTimeout(d time.Duration) *ReliableClientBuilder

+ func (dsrcb *ReliableClientBuilder) DbPath(path string) *ReliableClientBuilder

+ func (dsrcb *ReliableClientBuilder) EnableStandByModeTimeout(d time.Duration) *ReliableClientBuilder

+ func (dsrcb *ReliableClientBuilder) EventTimeToLiveInSeconds(d uint32) *ReliableClientBuilder

+ func (dsrcb *ReliableClientBuilder) FlushTimeout(d time.Duration) *ReliableClientBuilder

+ func (dsrcb *ReliableClientBuilder) RetryDaemonInitDelay(d time.Duration) *ReliableClientBuilder

+ func (dsrcb *ReliableClientBuilder) RetryDaemonWaitBtwChecks(d time.Duration) *ReliableClientBuilder

+ type ReliableClientStats struct

+ Count int

+ Dropped int

+ Evicted int

+ Finished int

+ Updated int

+ type SwitchDevoSender interface

+ AreAsyncOps func() bool

+ AsyncErrors func() map[string]error

+ AsyncErrorsNumber func() int

+ AsyncIds func() []string

+ Flush func() error

+ IsAsyncActive func(id string) bool

+ IsStandBy func() bool

+ SendAsync func(m string) string

+ SendWTagAndCompressorAsync func(t string, m string, c *Compressor) string

+ SendWTagAsync func(t, m string) string

+ StandBy func() error

+ String func() string

+ WaitForPendingAsyncMsgsOrTimeout func(timeout time.Duration) error

+ WakeUp func() error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL