chproducer

Documentation

Index

• Variables
• type BlockController
• type Handler
  • func NewHandler(ctx context.Context, chName string, ttl time.Duration, activeTransfers uint, ...) (*Handler, error)
  • func (h *Handler) Exec(ctx context.Context) error
• type HealthcheckController
• type PoolController

Variables

var ErrChanClosed = errors.New("channel closed")

Types

type BlockController

type BlockController interface {
	GetData() <-chan *model.BlockData
	Close()
	StreamReady() <-chan struct{}
}

type Handler

type Handler struct {
	// contains filtered or unexported fields
}

func NewHandler

func NewHandler(
	ctx context.Context,
	chName string,
	ttl time.Duration,
	activeTransfers uint,
	storage *redis.Storage,
	poolController PoolController,
	newest <-chan model.TransferRequest,
) (*Handler, error)

func (*Handler) Exec

func (h *Handler) Exec(ctx context.Context) error

type HealthcheckController

type HealthcheckController interface {
	State(bool)
}

type PoolController

type PoolController interface {
	Executor(channel string) (*hlf.ChExecutor, error)
	Has(channel string) bool
	Expand(ctx context.Context, channel string) error
	Readiness(channel string) (<-chan struct{}, error)
	Events(channel string) (<-chan struct{}, error)
}