producer

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

type BasicConcurrentProducerConfig struct {
	// JobsNumber should be relatively high, since IPFS communication can sometimes block for extend periods
	JobsNumber     uint          `envconfig:"JOBS_NUMBER" default:"20"`
	ProduceTimeout time.Duration `envconfig:"PRODUCE_TIMEOUT" default:"2m"`
	ErrBuf         uint          `envconfig:"ERR_CHAN_BUFF" default:"50"`
	MessageBuf     uint          `envconfig:"MESSAGE_BUFF" default:"250"`
}

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

type ConcurrentProducer interface {
	Messages() chan<- proto.Message
	Errors() <-chan Error
}

type Error struct {
	Err     error
	Message proto.Message
}

type Producer interface {
	Produce(ctx context.Context, message proto.Message) error
}