blocking

Documentation

Index

• type Manager
• type Params
• type Result
  • func New(params Params) Result

Types

type Manager

type Manager interface {
	Filter(ctx context.Context, hashes []protocol.ID) ([]protocol.ID, error)
	Block(ctx context.Context, hashes []protocol.ID) error
	Flush(ctx context.Context) error
}

type Params

type Params struct {
	fx.In
	Dao         lazy.Lazy[*dao.Query]
	PgxPoolWait *sync.WaitGroup `name:"pgx_pool_wait"`
}

type Result

type Result struct {
	fx.Out
	Manager lazy.Lazy[Manager]
	AppHook fx.Hook `group:"app_hooks"`
}

func New

func New(params Params) Result