http

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
  • func (e *BadHttpStatusError) Error() string
• type Receiver
  • func (r *Receiver) Config() interface{}
  • 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()
  • func (r *Receiver) Name() string
  • func (r *Receiver) Plugin() string
  • func (r *Receiver) Receive(next receiver.NextFn) error
  • func (r *Receiver) StopReceiving(ctx context.Context) error
  • func (r *Receiver) Tenant() tenant.Id
  • func (r *Receiver) Trigger(e event.Event)
• type ReceiverConfig
  • func (rc *ReceiverConfig) Validate() error
  • func (rc *ReceiverConfig) WithDefaults() ReceiverConfig
• type Response
• type Sender
  • func (r *Sender) Config() interface{}
  • 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
  • func (s *Sender) Name() string
  • func (s *Sender) Plugin() string
  • func (s *Sender) Send(event event.Event)
  • func (s *Sender) StopSending(ctx context.Context)
  • func (s *Sender) Tenant() tenant.Id
  • func (s *Sender) Unwrap() sender.Sender
• type SenderConfig
  • func (sc *SenderConfig) Validate() error
• type Status
• type Tracing

Constants

const DEFAULT_TIMEOUT = 10

Variables

var (
	Name     = "http"
	Version  = "v0.0.0"
	CommitID = ""
)

var DefaultReceiverConfig = ReceiverConfig{
	SuccessStatus:      pointer.Int(200),
	FailureStatus:      pointer.Int(400),
	TracePayloadOnNack: pointer.Bool(false),
}

Functions

func NewPlugin

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

func NewPluginVersion

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

func NewReceiver

func NewReceiver(tid tenant.Id, plugin string, name string, config interface{}, secrets secret.Vault, tableSyncer syncer.DeltaSyncer) (receiver.Receiver, error)

func NewSender

func NewSender(tid tenant.Id, plugin string, name string, config interface{}, secrets secret.Vault, tableSyncer syncer.DeltaSyncer) (sender.Sender, error)

Types

type BadHttpStatusError

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

func (*BadHttpStatusError) Error

func (e *BadHttpStatusError) Error() string

type Receiver

type Receiver struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*Receiver) Config

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

func (*Receiver) EventErrorCount

func (r *Receiver) EventErrorCount() int

func (*Receiver) EventErrorVelocity

func (r *Receiver) EventErrorVelocity() int

func (*Receiver) EventSuccessCount

func (r *Receiver) EventSuccessCount() int

func (*Receiver) EventSuccessVelocity

func (r *Receiver) EventSuccessVelocity() int

func (*Receiver) EventTs

func (r *Receiver) EventTs() int64

func (*Receiver) Hash

func (r *Receiver) Hash() string

func (*Receiver) LogSuccess

func (r *Receiver) LogSuccess()

func (*Receiver) Name

func (r *Receiver) Name() string

func (*Receiver) Plugin

func (r *Receiver) Plugin() string

func (*Receiver) Receive

func (r *Receiver) Receive(next receiver.NextFn) error

func (*Receiver) StopReceiving

func (r *Receiver) StopReceiving(ctx context.Context) error

func (*Receiver) Tenant

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

func (*Receiver) Trigger

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

type ReceiverConfig

type ReceiverConfig struct {
	Path               string `json:"path"`
	Method             string `json:"method"`
	Port               *int   `json:"port"`
	TracePayloadOnNack *bool  `json:"tracePayloadOnNack,omitempty"`
	SuccessStatus      *int   `json:"successStatus"`
	FailureStatus      *int   `json:"failureStatus"`
}

func (*ReceiverConfig) Validate

func (rc *ReceiverConfig) Validate() error

Validate returns an error upon validation failure

func (*ReceiverConfig) WithDefaults

func (rc *ReceiverConfig) WithDefaults() ReceiverConfig

WithDefaults

type Response

type Response struct {
	Status  *Status  `json:"status,omitempty" xml:"status,omitempty"`
	Tracing *Tracing `json:"tx,omitempty" xml:"tx,omitempty"`
}

type Sender

type Sender struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*Sender) Config

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

func (*Sender) EventErrorCount

func (s *Sender) EventErrorCount() int

func (*Sender) EventErrorVelocity

func (s *Sender) EventErrorVelocity() int

func (*Sender) EventSuccessCount

func (s *Sender) EventSuccessCount() int

func (*Sender) EventSuccessVelocity

func (s *Sender) EventSuccessVelocity() int

func (*Sender) EventTs

func (s *Sender) EventTs() int64

func (*Sender) Hash

func (s *Sender) Hash() string

func (*Sender) Name

func (s *Sender) Name() string

func (*Sender) Plugin

func (s *Sender) Plugin() string

func (*Sender) Send

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

func (*Sender) StopSending

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

func (*Sender) Tenant

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

func (*Sender) Unwrap

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

type SenderConfig

type SenderConfig struct {
	Url    string `json:"url"`
	Method string `json:"method"`
}

func (*SenderConfig) Validate

func (sc *SenderConfig) Validate() error

Validate

type Status

type Status struct {
	Code    int    `json:"code,omitempty" xml:"code,omitempty"`
	Message string `json:"message,omitempty" xml:"message,omitempty"`
}

type Tracing

type Tracing struct {
	TraceId string `json:"traceId,omitempty" xml:"traceId,omitempty"`
}