event

package
v0.0.0-...-d5b0b98 Latest Latest
Warning

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

Go to latest
Published: Jul 6, 2023 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 1 more Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Event

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

Event include loops, delays, transactions, and real-time events

func New

func New(opts *options.Options, h *handler.Handler,
	redisPool *redigo.Pool, confInfo *cc.ProcessorConfInfo) (*Event, error)

New creates an Event

func (*Event) HandleEvent

func (s *Event) HandleEvent(msg []byte, eventType define.EventType) error

HandleEvent handler events for the dispatcher

func (*Event) HandleEventExternal

func (s *Event) HandleEventExternal(data []byte) error

HandleEventExternal handler external events for the dispatcher

func (*Event) HandleEventInternal

func (s *Event) HandleEventInternal(data []byte) error

HandleEventInternal handler internal events for the dispatcher

func (*Event) Stop

func (s *Event) Stop() error

Stop stops the Kafka connector gracefully.

type Handler

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

Handler is a handler for events of connector

func (*Handler) InternalHandler

func (s *Handler) InternalHandler(ctx context.Context, msg *comm.EvhubMsg) error

InternalHandler internal event handling

func (*Handler) InternalHandlerSuccess

func (s *Handler) InternalHandlerSuccess(ctx context.Context, msg *comm.EvhubMsg)

InternalHandlerSuccess internal event handling

func (*Handler) Send

func (s *Handler) Send(ctx context.Context, msg *comm.EvhubMsg) ([]byte, error)

Send dispatch downstream service processing

Jump to

Keyboard shortcuts

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