evtproc

Documentation

Index

• Variables
• func AsOption(f any) any
• func DispatchEvent[T event.DroneEvents](ctx context.Context, subscriber bus.Subscriber, topic string, ...) error
• type DroneProcessor
• type Option
  • func WithLogger(logger zerolog.Logger) Option
• type Server
  • func NewServer(opts ...Option) *Server
  • func (ep *Server) Run(ctx context.Context, addr string) error

Variables

var Module = fx.Module("processor",
	fx.Provide(
		fx.Annotate(
			NewServer,
			fx.ParamTags(`group:"processorOptions"`),
		),
	),
)

Functions

func AsOption

func AsOption(f any) any

func DispatchEvent

func DispatchEvent[T event.DroneEvents](ctx context.Context, subscriber bus.Subscriber, topic string, p DroneProcessor[T]) error

Types

type DroneProcessor

type DroneProcessor[T event.DroneEvents] func(ctx context.Context, evt *T) error

type Option

type Option func(s *Server)

func WithLogger

func WithLogger(logger zerolog.Logger) Option

type Server

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

func NewServer

func NewServer(opts ...Option) *Server

func (*Server) Run

func (ep *Server) Run(ctx context.Context, addr string) error