debug

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

Nov 16, 2021

Changes in this version

type ReceiverConfig

+ TracePayloadOnNack *bool

Jun 17, 2021

Changes in this version

type Receiver

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

type ReceiverConfig

+ Trace *bool

type Sender

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

Jun 4, 2021

Changes in this version

type Receiver

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

+ func (r *Receiver) Name() string

+ func (r *Receiver) Plugin() string

type Sender

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

+ func (s *Sender) Name() string

+ func (s *Sender) Plugin() string

May 26, 2021

Changes in this version

+ var CommitID = ""

+ var DefaultReceiverConfig = ReceiverConfig

+ var DefaultSenderConfig = SenderConfig

+ var InfiniteRounds = pointer.Int(-1)

+ var Name = "debug"

+ var Version = "v0.0.0"

+ func DestinationTypeSliceContains(enums []DestinationType, sunEnums ...DestinationType) bool

+ func DestinationTypeSliceContainsAny(enums []DestinationType, sunEnums ...DestinationType) bool

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

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

+ func NewReceiver(config interface{}) (receiver.Receiver, error)

+ func NewSender(config interface{}) (sender.Sender, error)

+ type DestinationType int

+ const DestinationCustom

+ const DestinationDevNull

+ const DestinationStderr

+ const DestinationStdout

+ const DestinationUnknown

+ func DestinationTypeValues() []DestinationType

+ func ParseDestinationTypeString(s string) (DestinationType, error)

+ func (i *DestinationType) UnmarshalBinary(data []byte) error

+ func (i *DestinationType) UnmarshalJSON(data []byte) error

+ func (i *DestinationType) UnmarshalText(text []byte) error

+ func (i *DestinationType) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (i DestinationType) MarshalBinary() (data []byte, err error)

+ func (i DestinationType) MarshalJSON() ([]byte, error)

+ func (i DestinationType) MarshalText() ([]byte, error)

+ func (i DestinationType) MarshalYAML() (interface{}, error)

+ func (i DestinationType) New() *DestinationType

+ func (i DestinationType) Registered() bool

+ func (i DestinationType) String() string

+ type EventWriter interface

+ Write func(e event.Event) error

+ type Receiver struct

+ func (r *Receiver) Count() int

+ func (r *Receiver) History() []event.Event

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

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

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

+ type ReceiverConfig struct

+ IntervalMs *int

+ MaxHistory *int

+ Payload interface{}

+ Rounds *int

+ func (rc *ReceiverConfig) Validate() error

+ func (rc *ReceiverConfig) WithDefaults() ReceiverConfig

+ type SendSlice struct

+ func (s *SendSlice) Events() []event.Event

+ func (s *SendSlice) Write(e event.Event) error

+ type SendStderr struct

+ func (s *SendStderr) Write(e event.Event) error

+ type SendStdout struct

+ func (s *SendStdout) Write(e event.Event) error

+ type Sender struct

+ func (s *Sender) Count() int

+ func (s *Sender) History() []event.Event

+ func (s *Sender) Reset()

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

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

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

+ type SenderConfig struct

+ Destination DestinationType

+ MaxHistory *int

+ Writer EventWriter

+ func (sc *SenderConfig) Validate() error

+ func (sc SenderConfig) WithDefaults() SenderConfig