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(c echo.Context, handle string, done chan struct{}) error
	SendRPCMessage(ctx context.Context, handle string, cmd *rpcevent.Command) error
	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)