Documentation ¶
Index ¶
- Constants
- Variables
- 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
- type Receiver
- func (r *Receiver) Config() interface{}
- func (h *Receiver) GetTraceId(r *http.Request) string
- func (r *Receiver) Name() string
- func (r *Receiver) Plugin() string
- func (h *Receiver) Receive(next receiver.NextFn) error
- func (h *Receiver) StopReceiving(ctx context.Context) error
- func (r *Receiver) Tenant() tenant.Id
- type ReceiverConfig
- type Sender
- 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
Constants ¶
View Source
const DEFAULT_TIMEOUT = 10
Variables ¶
View Source
var ( Name = "http" Version = "v0.0.0" CommitID = "" )
Functions ¶
func NewPluginVersion ¶
func NewReceiver ¶
Types ¶
type BadHttpStatusError ¶
type BadHttpStatusError struct {
// contains filtered or unexported fields
}
func (*BadHttpStatusError) Error ¶
func (e *BadHttpStatusError) Error() string
type ReceiverConfig ¶
type ReceiverConfig struct { Path string `json:"path"` Method string `json:"method"` Port *int `json:"port"` Trace *bool `json:"trace,omitempty"` }
func (*ReceiverConfig) Validate ¶
func (rc *ReceiverConfig) Validate() error
Validate returns an error upon validation failure
type Sender ¶
type Sender struct {
// contains filtered or unexported fields
}
func (*Sender) StopSending ¶
type SenderConfig ¶
Click to show internal directories.
Click to hide internal directories.