websocket

Documentation

Index

• Variables
• type Connection
  • func (sc *Connection) SendMessage(ctx context.Context, cmd *rpcevent.Command) error
• type IEstuaryRpcEngine
  • func NewEstuaryRpcEngine(ctx context.Context, db *gorm.DB, cfg *config.Estuary, log *zap.SugaredLogger, ...) IEstuaryRpcEngine

Variables

var ErrNoShuttleConnection = fmt.Errorf("no connection to requested shuttle")

Types

type Connection

type Connection struct {
	Handle string
	Ctx    context.Context
	// contains filtered or unexported fields
}

func (*Connection) SendMessage

func (sc *Connection) SendMessage(ctx context.Context, cmd *rpcevent.Command) error

type IEstuaryRpcEngine

type IEstuaryRpcEngine interface {
	Connect(c echo.Context, handle string, done chan struct{}) error
	GetShuttleConnection(handle string) (*Connection, bool)
}

func NewEstuaryRpcEngine

func NewEstuaryRpcEngine(ctx context.Context, db *gorm.DB, cfg *config.Estuary, log *zap.SugaredLogger, handlerFn types.MessageHandlerFn) IEstuaryRpcEngine