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
	Hostname              string
	AddrInfo              peer.AddrInfo
	Address               address.Address
	Private               bool
	ContentAddingDisabled bool
	SpaceLow              bool
	BlockstoreSize        uint64
	BlockstoreFree        uint64
	PinCount              int64
	PinQueueLength        int64
	QueueEngEnabled       bool
	// 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(ws *gwebsocket.Conn, handle string, done chan struct{}) (func() error, func(), error)
	GetShuttleConnections() []*Connection
	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