kafka

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 7, 2023 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Integration

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

Integration implements an Kafka integration.

func New

New creates a new Kafka integration.

func (*Integration) Close

func (i *Integration) Close() error

Close shuts down the integration, closing the Kafka writer.

func (*Integration) DataDownChan

func (i *Integration) DataDownChan() chan models.DataDownPayload

DataDownChan return nil.

func (*Integration) HandleAckEvent

func (i *Integration) HandleAckEvent(ctx context.Context, _ models.Integration, vars map[string]string, pl pb.AckEvent) error

HandleAckEvent sends an AckEvent.

func (*Integration) HandleErrorEvent

func (i *Integration) HandleErrorEvent(ctx context.Context, _ models.Integration, vars map[string]string, pl pb.ErrorEvent) error

HandleErrorEvent sends an ErrorEvent.

func (*Integration) HandleIntegrationEvent

func (i *Integration) HandleIntegrationEvent(ctx context.Context, _ models.Integration, vars map[string]string, pl pb.IntegrationEvent) error

HandleIntegrationEvent sends an IntegrationEvent.

func (*Integration) HandleJoinEvent

func (i *Integration) HandleJoinEvent(ctx context.Context, _ models.Integration, vars map[string]string, pl pb.JoinEvent) error

HandleJoinEvent sends a JoinEvent.

func (*Integration) HandleLocationEvent

func (i *Integration) HandleLocationEvent(ctx context.Context, _ models.Integration, vars map[string]string, pl pb.LocationEvent) error

HandleLocationEvent sends a LocationEvent.

func (*Integration) HandleStatusEvent

func (i *Integration) HandleStatusEvent(ctx context.Context, _ models.Integration, vars map[string]string, pl pb.StatusEvent) error

HandleStatusEvent sends a StatusEvent.

func (*Integration) HandleTxAckEvent

func (i *Integration) HandleTxAckEvent(ctx context.Context, _ models.Integration, vars map[string]string, pl pb.TxAckEvent) error

HandleTxAckEvent sends a TxAckEvent.

func (*Integration) HandleUplinkEvent

func (i *Integration) HandleUplinkEvent(ctx context.Context, _ models.Integration, vars map[string]string, pl pb.UplinkEvent) error

HandleUplinkEvent sends an UplinkEvent.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL