Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNilParams = fmt.Errorf("shuttle message had nil params")
Functions ¶
This section is empty.
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)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.