queue

Documentation

Index

• type IEstuaryRpcEngine
  • func NewEstuaryRpcEngine(cfg *config.Estuary, log *zap.SugaredLogger, handlerFn types.MessageHandlerFn) (IEstuaryRpcEngine, error)
• type IShuttleRpcEngine
  • func NewShuttleRpcEngine(cfg *config.Shuttle, handle string, log *zap.SugaredLogger, ...) (IShuttleRpcEngine, error)

Types

type IEstuaryRpcEngine

type IEstuaryRpcEngine interface {
	SendMessage(topic string, handle string, msg *rpcevent.Command) error
}

func NewEstuaryRpcEngine

func NewEstuaryRpcEngine(cfg *config.Estuary, log *zap.SugaredLogger, handlerFn types.MessageHandlerFn) (IEstuaryRpcEngine, error)

type IShuttleRpcEngine

type IShuttleRpcEngine interface {
	SendMessage(topic string, msg *rpcevent.Message) error
}

func NewShuttleRpcEngine

func NewShuttleRpcEngine(cfg *config.Shuttle, handle string, log *zap.SugaredLogger, handlerFn types.CommandHandlerFn) (IShuttleRpcEngine, error)