http

Sep 5, 2023

Changes in this version

type Receiver

+ func (r *Receiver) EventErrorCount() int

+ func (r *Receiver) EventErrorVelocity() int

+ func (r *Receiver) EventSuccessCount() int

+ func (r *Receiver) EventSuccessVelocity() int

+ func (r *Receiver) EventTs() int64

+ func (r *Receiver) Hash() string

+ func (r *Receiver) LogSuccess()

type Sender

+ func (s *Sender) EventErrorCount() int

+ func (s *Sender) EventErrorVelocity() int

+ func (s *Sender) EventSuccessCount() int

+ func (s *Sender) EventSuccessVelocity() int

+ func (s *Sender) EventTs() int64

+ func (s *Sender) Hash() string

May 18, 2023

Changes in this version

type Receiver

+ func (r *Receiver) Trigger(e event.Event)

Feb 10, 2022

Changes in this version

+ var DefaultReceiverConfig = ReceiverConfig

type ReceiverConfig

+ FailureStatus *int

+ SuccessStatus *int

+ func (rc *ReceiverConfig) WithDefaults() ReceiverConfig

+ type Response struct

+ Status *Status

+ Tracing *Tracing

+ type Status struct

+ Code int

+ Message string

+ type Tracing struct

+ TraceId string

Nov 16, 2021

Changes in this version

type ReceiverConfig

+ TracePayloadOnNack *bool

Jun 17, 2021

Changes in this version

+ const DEFAULT_TIMEOUT

+ var CommitID = ""

+ var Name = "http"

+ var Version = "v0.0.0"

+ func NewPlugin() (*pkgplugin.Plugin, error)

+ func NewPluginVersion(name string, version string, commitID string) (*pkgplugin.Plugin, error)

+ func NewReceiver(tid tenant.Id, plugin string, name string, config interface{}) (receiver.Receiver, error)

+ func NewSender(tid tenant.Id, plugin string, name string, config interface{}) (sender.Sender, error)

+ type BadHttpStatusError struct

+ func (e *BadHttpStatusError) Error() string

+ type Receiver struct

+ func (h *Receiver) GetTraceId(r *http.Request) string

+ func (h *Receiver) Receive(next receiver.NextFn) error

+ func (h *Receiver) StopReceiving(ctx context.Context) error

+ func (r *Receiver) Config() interface{}

+ func (r *Receiver) Name() string

+ func (r *Receiver) Plugin() string

+ func (r *Receiver) Tenant() tenant.Id

+ type ReceiverConfig struct

+ Method string

+ Path string

+ Port *int

+ Trace *bool

+ func (rc *ReceiverConfig) Validate() error

+ type Sender struct

+ func (r *Sender) Config() interface{}

+ func (s *Sender) Name() string

+ func (s *Sender) Plugin() string

+ func (s *Sender) Send(event event.Event)

+ func (s *Sender) SetTraceId(r *http.Request, traceId string)

+ func (s *Sender) StopSending(ctx context.Context)

+ func (s *Sender) Tenant() tenant.Id

+ func (s *Sender) Unwrap() sender.Sender

+ type SenderConfig struct

+ Method string

+ Url string

+ func (sc *SenderConfig) Validate() error