Documentation ¶
Index ¶
- Variables
- func InitRegistry()
- func IsEncodingError(err error) bool
- type Destination
- func NewDestination(ctx context.Context, typ conf.DestinationType, e *Env) (Destination, error)
- func NewElasticDestination(ctx context.Context, e *Env) (Destination, error)
- func NewFileDestination(ctx context.Context, e *Env) (Destination, error)
- func NewGraylogDestination(ctx context.Context, e *Env) (Destination, error)
- func NewHTTPDestination(ctx context.Context, e *Env) (Destination, error)
- func NewHTTPServerDestination(ctx context.Context, e *Env) (Destination, error)
- func NewKafkaDestination(ctx context.Context, e *Env) (Destination, error)
- func NewNATSDestination(ctx context.Context, e *Env) (Destination, error)
- func NewRELPDestination(ctx context.Context, e *Env) (Destination, error)
- func NewRedisDestination(ctx context.Context, e *Env) (Destination, error)
- func NewStderrDestination(ctx context.Context, e *Env) (Destination, error)
- func NewTCPDestination(ctx context.Context, e *Env) (Destination, error)
- func NewUDPDestination(ctx context.Context, e *Env) (Destination, error)
- func NewWebsocketServerDestination(ctx context.Context, e *Env) (Destination, error)
- type ElasticDestination
- func (base ElasticDestination) ACK(uid utils.MyULID)
- func (d *ElasticDestination) Close() error
- func (base ElasticDestination) Fatal() chan error
- func (base ElasticDestination) ForEach(ctx context.Context, f func(context.Context, *model.FullMessage) error, ...) (err eerrors.ErrorSlice)
- func (base ElasticDestination) ForEachWithTopic(ctx context.Context, ...) (err eerrors.ErrorSlice)
- func (base ElasticDestination) NACK(uid utils.MyULID)
- func (base ElasticDestination) NACKAll(msgQ *message.Ring)
- func (base ElasticDestination) NACKAllSlice(msgs []*model.FullMessage)
- func (base ElasticDestination) NACKRemaining(msgs []model.OutputMsg)
- func (base ElasticDestination) PermError(uid utils.MyULID)
- func (d *ElasticDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
- type Env
- type FileDestination
- func (base FileDestination) ACK(uid utils.MyULID)
- func (d *FileDestination) Close() error
- func (base FileDestination) Fatal() chan error
- func (base FileDestination) ForEach(ctx context.Context, f func(context.Context, *model.FullMessage) error, ...) (err eerrors.ErrorSlice)
- func (base FileDestination) ForEachWithTopic(ctx context.Context, ...) (err eerrors.ErrorSlice)
- func (base FileDestination) NACK(uid utils.MyULID)
- func (base FileDestination) NACKAll(msgQ *message.Ring)
- func (base FileDestination) NACKAllSlice(msgs []*model.FullMessage)
- func (base FileDestination) NACKRemaining(msgs []model.OutputMsg)
- func (base FileDestination) PermError(uid utils.MyULID)
- func (d *FileDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
- type GraylogDestination
- func (base GraylogDestination) ACK(uid utils.MyULID)
- func (d *GraylogDestination) Close() error
- func (base GraylogDestination) Fatal() chan error
- func (base GraylogDestination) ForEach(ctx context.Context, f func(context.Context, *model.FullMessage) error, ...) (err eerrors.ErrorSlice)
- func (base GraylogDestination) ForEachWithTopic(ctx context.Context, ...) (err eerrors.ErrorSlice)
- func (base GraylogDestination) NACK(uid utils.MyULID)
- func (base GraylogDestination) NACKAll(msgQ *message.Ring)
- func (base GraylogDestination) NACKAllSlice(msgs []*model.FullMessage)
- func (base GraylogDestination) NACKRemaining(msgs []model.OutputMsg)
- func (base GraylogDestination) PermError(uid utils.MyULID)
- func (d *GraylogDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
- type HTTPDestination
- func (base HTTPDestination) ACK(uid utils.MyULID)
- func (d *HTTPDestination) Close() error
- func (base HTTPDestination) Fatal() chan error
- func (base HTTPDestination) ForEach(ctx context.Context, f func(context.Context, *model.FullMessage) error, ...) (err eerrors.ErrorSlice)
- func (base HTTPDestination) ForEachWithTopic(ctx context.Context, ...) (err eerrors.ErrorSlice)
- func (base HTTPDestination) NACK(uid utils.MyULID)
- func (base HTTPDestination) NACKAll(msgQ *message.Ring)
- func (base HTTPDestination) NACKAllSlice(msgs []*model.FullMessage)
- func (base HTTPDestination) NACKRemaining(msgs []model.OutputMsg)
- func (base HTTPDestination) PermError(uid utils.MyULID)
- func (d *HTTPDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
- type HTTPServerDestination
- func (base HTTPServerDestination) ACK(uid utils.MyULID)
- func (d *HTTPServerDestination) Close() (err error)
- func (base HTTPServerDestination) Fatal() chan error
- func (base HTTPServerDestination) ForEach(ctx context.Context, f func(context.Context, *model.FullMessage) error, ...) (err eerrors.ErrorSlice)
- func (base HTTPServerDestination) ForEachWithTopic(ctx context.Context, ...) (err eerrors.ErrorSlice)
- func (base HTTPServerDestination) NACK(uid utils.MyULID)
- func (base HTTPServerDestination) NACKAll(msgQ *message.Ring)
- func (base HTTPServerDestination) NACKAllSlice(msgs []*model.FullMessage)
- func (base HTTPServerDestination) NACKRemaining(msgs []model.OutputMsg)
- func (base HTTPServerDestination) PermError(uid utils.MyULID)
- func (d *HTTPServerDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
- func (d *HTTPServerDestination) ServeHTTP(w http.ResponseWriter, r *http.Request)
- func (d *HTTPServerDestination) Write(p []byte) (n int, err error)
- type KafkaDestination
- func (base KafkaDestination) ACK(uid utils.MyULID)
- func (d *KafkaDestination) Close() error
- func (base KafkaDestination) Fatal() chan error
- func (base KafkaDestination) ForEach(ctx context.Context, f func(context.Context, *model.FullMessage) error, ...) (err eerrors.ErrorSlice)
- func (base KafkaDestination) ForEachWithTopic(ctx context.Context, ...) (err eerrors.ErrorSlice)
- func (base KafkaDestination) NACK(uid utils.MyULID)
- func (base KafkaDestination) NACKAll(msgQ *message.Ring)
- func (base KafkaDestination) NACKAllSlice(msgs []*model.FullMessage)
- func (base KafkaDestination) NACKRemaining(msgs []model.OutputMsg)
- func (base KafkaDestination) PermError(uid utils.MyULID)
- func (d *KafkaDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
- type NATSDestination
- func (base NATSDestination) ACK(uid utils.MyULID)
- func (d *NATSDestination) Close() error
- func (base NATSDestination) Fatal() chan error
- func (base NATSDestination) ForEach(ctx context.Context, f func(context.Context, *model.FullMessage) error, ...) (err eerrors.ErrorSlice)
- func (base NATSDestination) ForEachWithTopic(ctx context.Context, ...) (err eerrors.ErrorSlice)
- func (base NATSDestination) NACK(uid utils.MyULID)
- func (base NATSDestination) NACKAll(msgQ *message.Ring)
- func (base NATSDestination) NACKAllSlice(msgs []*model.FullMessage)
- func (base NATSDestination) NACKRemaining(msgs []model.OutputMsg)
- func (base NATSDestination) PermError(uid utils.MyULID)
- func (d *NATSDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
- type RELPDestination
- func (base RELPDestination) ACK(uid utils.MyULID)
- func (d *RELPDestination) Close() (err error)
- func (base RELPDestination) Fatal() chan error
- func (base RELPDestination) ForEach(ctx context.Context, f func(context.Context, *model.FullMessage) error, ...) (err eerrors.ErrorSlice)
- func (base RELPDestination) ForEachWithTopic(ctx context.Context, ...) (err eerrors.ErrorSlice)
- func (base RELPDestination) NACK(uid utils.MyULID)
- func (base RELPDestination) NACKAll(msgQ *message.Ring)
- func (base RELPDestination) NACKAllSlice(msgs []*model.FullMessage)
- func (base RELPDestination) NACKRemaining(msgs []model.OutputMsg)
- func (base RELPDestination) PermError(uid utils.MyULID)
- func (d *RELPDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
- type RedisDestination
- func (base RedisDestination) ACK(uid utils.MyULID)
- func (d *RedisDestination) Close() error
- func (base RedisDestination) Fatal() chan error
- func (base RedisDestination) ForEach(ctx context.Context, f func(context.Context, *model.FullMessage) error, ...) (err eerrors.ErrorSlice)
- func (base RedisDestination) ForEachWithTopic(ctx context.Context, ...) (err eerrors.ErrorSlice)
- func (base RedisDestination) NACK(uid utils.MyULID)
- func (base RedisDestination) NACKAll(msgQ *message.Ring)
- func (base RedisDestination) NACKAllSlice(msgs []*model.FullMessage)
- func (base RedisDestination) NACKRemaining(msgs []model.OutputMsg)
- func (base RedisDestination) PermError(uid utils.MyULID)
- func (d *RedisDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
- type RemoteClient
- type StderrDestination
- func (base StderrDestination) ACK(uid utils.MyULID)
- func (d *StderrDestination) Close() error
- func (base StderrDestination) Fatal() chan error
- func (base StderrDestination) ForEach(ctx context.Context, f func(context.Context, *model.FullMessage) error, ...) (err eerrors.ErrorSlice)
- func (base StderrDestination) ForEachWithTopic(ctx context.Context, ...) (err eerrors.ErrorSlice)
- func (base StderrDestination) NACK(uid utils.MyULID)
- func (base StderrDestination) NACKAll(msgQ *message.Ring)
- func (base StderrDestination) NACKAllSlice(msgs []*model.FullMessage)
- func (base StderrDestination) NACKRemaining(msgs []model.OutputMsg)
- func (base StderrDestination) PermError(uid utils.MyULID)
- func (d *StderrDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
- type TCPDestination
- func (base TCPDestination) ACK(uid utils.MyULID)
- func (d *TCPDestination) Close() error
- func (base TCPDestination) Fatal() chan error
- func (base TCPDestination) ForEach(ctx context.Context, f func(context.Context, *model.FullMessage) error, ...) (err eerrors.ErrorSlice)
- func (base TCPDestination) ForEachWithTopic(ctx context.Context, ...) (err eerrors.ErrorSlice)
- func (base TCPDestination) NACK(uid utils.MyULID)
- func (base TCPDestination) NACKAll(msgQ *message.Ring)
- func (base TCPDestination) NACKAllSlice(msgs []*model.FullMessage)
- func (base TCPDestination) NACKRemaining(msgs []model.OutputMsg)
- func (base TCPDestination) PermError(uid utils.MyULID)
- func (d *TCPDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
- type UDPDestination
- func (base UDPDestination) ACK(uid utils.MyULID)
- func (d *UDPDestination) Close() error
- func (base UDPDestination) Fatal() chan error
- func (base UDPDestination) ForEach(ctx context.Context, f func(context.Context, *model.FullMessage) error, ...) (err eerrors.ErrorSlice)
- func (base UDPDestination) ForEachWithTopic(ctx context.Context, ...) (err eerrors.ErrorSlice)
- func (base UDPDestination) NACK(uid utils.MyULID)
- func (base UDPDestination) NACKAll(msgQ *message.Ring)
- func (base UDPDestination) NACKAllSlice(msgs []*model.FullMessage)
- func (base UDPDestination) NACKRemaining(msgs []model.OutputMsg)
- func (base UDPDestination) PermError(uid utils.MyULID)
- func (d *UDPDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
- type WebsocketServerDestination
- func (base WebsocketServerDestination) ACK(uid utils.MyULID)
- func (d *WebsocketServerDestination) Close() (err error)
- func (base WebsocketServerDestination) Fatal() chan error
- func (base WebsocketServerDestination) ForEach(ctx context.Context, f func(context.Context, *model.FullMessage) error, ...) (err eerrors.ErrorSlice)
- func (base WebsocketServerDestination) ForEachWithTopic(ctx context.Context, ...) (err eerrors.ErrorSlice)
- func (base WebsocketServerDestination) NACK(uid utils.MyULID)
- func (base WebsocketServerDestination) NACKAll(msgQ *message.Ring)
- func (base WebsocketServerDestination) NACKAllSlice(msgs []*model.FullMessage)
- func (base WebsocketServerDestination) NACKRemaining(msgs []model.OutputMsg)
- func (base WebsocketServerDestination) PermError(uid utils.MyULID)
- func (d *WebsocketServerDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrCalculateURL = eerrors.New("Error calculating target URL from template")
View Source
var Registry *prometheus.Registry
Functions ¶
func InitRegistry ¶
func InitRegistry()
func IsEncodingError ¶
IsEncodingError returns true when the given error is a message encoding error
Types ¶
type Destination ¶
type Destination interface { Send(ctx context.Context, m []model.OutputMsg) eerrors.ErrorSlice Fatal() chan error Close() error ACK(utils.MyULID) NACK(utils.MyULID) PermError(utils.MyULID) NACKAllSlice([]*model.FullMessage) }
func NewDestination ¶
func NewDestination(ctx context.Context, typ conf.DestinationType, e *Env) (Destination, error)
func NewElasticDestination ¶
func NewElasticDestination(ctx context.Context, e *Env) (Destination, error)
func NewFileDestination ¶
func NewFileDestination(ctx context.Context, e *Env) (Destination, error)
func NewGraylogDestination ¶
func NewGraylogDestination(ctx context.Context, e *Env) (Destination, error)
func NewHTTPDestination ¶
func NewHTTPDestination(ctx context.Context, e *Env) (Destination, error)
func NewHTTPServerDestination ¶
func NewHTTPServerDestination(ctx context.Context, e *Env) (Destination, error)
func NewKafkaDestination ¶
func NewKafkaDestination(ctx context.Context, e *Env) (Destination, error)
func NewNATSDestination ¶
func NewNATSDestination(ctx context.Context, e *Env) (Destination, error)
func NewRELPDestination ¶
func NewRELPDestination(ctx context.Context, e *Env) (Destination, error)
func NewRedisDestination ¶
func NewRedisDestination(ctx context.Context, e *Env) (Destination, error)
func NewStderrDestination ¶
func NewStderrDestination(ctx context.Context, e *Env) (Destination, error)
func NewTCPDestination ¶
func NewTCPDestination(ctx context.Context, e *Env) (Destination, error)
func NewUDPDestination ¶
func NewUDPDestination(ctx context.Context, e *Env) (Destination, error)
func NewWebsocketServerDestination ¶
func NewWebsocketServerDestination(ctx context.Context, e *Env) (Destination, error)
type ElasticDestination ¶
type ElasticDestination struct {
// contains filtered or unexported fields
}
func (*ElasticDestination) Close ¶
func (d *ElasticDestination) Close() error
func (ElasticDestination) ForEachWithTopic ¶
func (ElasticDestination) NACKAllSlice ¶
func (base ElasticDestination) NACKAllSlice(msgs []*model.FullMessage)
func (ElasticDestination) NACKRemaining ¶
func (*ElasticDestination) Send ¶
func (d *ElasticDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
type FileDestination ¶
type FileDestination struct {
// contains filtered or unexported fields
}
func (*FileDestination) Close ¶
func (d *FileDestination) Close() error
func (FileDestination) ForEachWithTopic ¶
func (FileDestination) NACKAllSlice ¶
func (base FileDestination) NACKAllSlice(msgs []*model.FullMessage)
func (FileDestination) NACKRemaining ¶
func (*FileDestination) Send ¶
func (d *FileDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
type GraylogDestination ¶
type GraylogDestination struct {
// contains filtered or unexported fields
}
func (*GraylogDestination) Close ¶
func (d *GraylogDestination) Close() error
func (GraylogDestination) ForEachWithTopic ¶
func (GraylogDestination) NACKAllSlice ¶
func (base GraylogDestination) NACKAllSlice(msgs []*model.FullMessage)
func (GraylogDestination) NACKRemaining ¶
func (*GraylogDestination) Send ¶
func (d *GraylogDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
type HTTPDestination ¶
type HTTPDestination struct {
// contains filtered or unexported fields
}
func (*HTTPDestination) Close ¶
func (d *HTTPDestination) Close() error
func (HTTPDestination) ForEachWithTopic ¶
func (HTTPDestination) NACKAllSlice ¶
func (base HTTPDestination) NACKAllSlice(msgs []*model.FullMessage)
func (HTTPDestination) NACKRemaining ¶
func (*HTTPDestination) Send ¶
func (d *HTTPDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
type HTTPServerDestination ¶
type HTTPServerDestination struct {
// contains filtered or unexported fields
}
func (*HTTPServerDestination) Close ¶
func (d *HTTPServerDestination) Close() (err error)
func (HTTPServerDestination) ForEachWithTopic ¶
func (HTTPServerDestination) NACKAllSlice ¶
func (base HTTPServerDestination) NACKAllSlice(msgs []*model.FullMessage)
func (HTTPServerDestination) NACKRemaining ¶
func (*HTTPServerDestination) Send ¶
func (d *HTTPServerDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
func (*HTTPServerDestination) ServeHTTP ¶
func (d *HTTPServerDestination) ServeHTTP(w http.ResponseWriter, r *http.Request)
type KafkaDestination ¶
type KafkaDestination struct {
// contains filtered or unexported fields
}
func (*KafkaDestination) Close ¶
func (d *KafkaDestination) Close() error
func (KafkaDestination) ForEachWithTopic ¶
func (KafkaDestination) NACKAllSlice ¶
func (base KafkaDestination) NACKAllSlice(msgs []*model.FullMessage)
func (KafkaDestination) NACKRemaining ¶
func (*KafkaDestination) Send ¶
func (d *KafkaDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
type NATSDestination ¶
type NATSDestination struct {
// contains filtered or unexported fields
}
func (*NATSDestination) Close ¶
func (d *NATSDestination) Close() error
func (NATSDestination) ForEachWithTopic ¶
func (NATSDestination) NACKAllSlice ¶
func (base NATSDestination) NACKAllSlice(msgs []*model.FullMessage)
func (NATSDestination) NACKRemaining ¶
func (*NATSDestination) Send ¶
func (d *NATSDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
type RELPDestination ¶
type RELPDestination struct {
// contains filtered or unexported fields
}
func (*RELPDestination) Close ¶
func (d *RELPDestination) Close() (err error)
func (RELPDestination) ForEachWithTopic ¶
func (RELPDestination) NACKAllSlice ¶
func (base RELPDestination) NACKAllSlice(msgs []*model.FullMessage)
func (RELPDestination) NACKRemaining ¶
func (*RELPDestination) Send ¶
func (d *RELPDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
type RedisDestination ¶
type RedisDestination struct {
// contains filtered or unexported fields
}
func (*RedisDestination) Close ¶
func (d *RedisDestination) Close() error
func (RedisDestination) ForEachWithTopic ¶
func (RedisDestination) NACKAllSlice ¶
func (base RedisDestination) NACKAllSlice(msgs []*model.FullMessage)
func (RedisDestination) NACKRemaining ¶
func (*RedisDestination) Send ¶
func (d *RedisDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
type RemoteClient ¶
type StderrDestination ¶
type StderrDestination struct {
// contains filtered or unexported fields
}
func (*StderrDestination) Close ¶
func (d *StderrDestination) Close() error
func (StderrDestination) ForEachWithTopic ¶
func (StderrDestination) NACKAllSlice ¶
func (base StderrDestination) NACKAllSlice(msgs []*model.FullMessage)
func (StderrDestination) NACKRemaining ¶
func (*StderrDestination) Send ¶
func (d *StderrDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
type TCPDestination ¶
type TCPDestination struct {
// contains filtered or unexported fields
}
func (*TCPDestination) Close ¶
func (d *TCPDestination) Close() error
func (TCPDestination) ForEachWithTopic ¶
func (TCPDestination) NACKAllSlice ¶
func (base TCPDestination) NACKAllSlice(msgs []*model.FullMessage)
func (TCPDestination) NACKRemaining ¶
func (*TCPDestination) Send ¶
func (d *TCPDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
type UDPDestination ¶
type UDPDestination struct {
// contains filtered or unexported fields
}
func (*UDPDestination) Close ¶
func (d *UDPDestination) Close() error
func (UDPDestination) ForEachWithTopic ¶
func (UDPDestination) NACKAllSlice ¶
func (base UDPDestination) NACKAllSlice(msgs []*model.FullMessage)
func (UDPDestination) NACKRemaining ¶
func (*UDPDestination) Send ¶
func (d *UDPDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
type WebsocketServerDestination ¶
type WebsocketServerDestination struct {
// contains filtered or unexported fields
}
func (*WebsocketServerDestination) Close ¶
func (d *WebsocketServerDestination) Close() (err error)
func (WebsocketServerDestination) ForEachWithTopic ¶
func (WebsocketServerDestination) NACKAllSlice ¶
func (base WebsocketServerDestination) NACKAllSlice(msgs []*model.FullMessage)
func (WebsocketServerDestination) NACKRemaining ¶
func (*WebsocketServerDestination) Send ¶
func (d *WebsocketServerDestination) Send(ctx context.Context, msgs []model.OutputMsg) (err eerrors.ErrorSlice)
Click to show internal directories.
Click to hide internal directories.