rpc

Documentation

Index

• Variables
• type IManager
  • func NewEstuaryRpcManager(ctx context.Context, db *gorm.DB, cfg *config.Estuary, log *zap.SugaredLogger, ...) (IManager, error)

Variables

var ErrNilParams = fmt.Errorf("shuttle message had nil params")

Types

type IManager

type IManager interface {
	Connect(ws *websocket.Conn, handle string, done chan struct{}) (func() error, func(), error)
	SendRPCMessage(ctx context.Context, handle string, cmd *rpcevent.Command) error
	GetShuttleConnections() []*websocketeng.Connection
	GetShuttleConnection(handle string) (*websocketeng.Connection, bool)
	GetTransferStatus(dealID uint) (*filclient.ChannelState, error)
}

func NewEstuaryRpcManager

func NewEstuaryRpcManager(ctx context.Context, db *gorm.DB, cfg *config.Estuary, log *zap.SugaredLogger, sanitycheckMgr sanitycheck.IManager, cntQueueMgr contentqueue.IQueueManager) (IManager, error)