publisher

Documentation

Index

• Variables
• type Publisher
  • func New(publisherID int, eventTopic string, storage services.Storage, ...) *Publisher
  • func (p *Publisher) Handle(ctx context.Context, fileChannel chan models.File)

Variables

var ErrEmptyFile = errors.New("file size is empty")

Types

type Publisher

type Publisher struct {
	ID         int
	EventTopic string
	// contains filtered or unexported fields
}

func New

func New(
	publisherID int,
	eventTopic string,
	storage services.Storage,
	eventCh chan models.Event,
	waitGroup *sync.WaitGroup,
) *Publisher

func (*Publisher) Handle

func (p *Publisher) Handle(ctx context.Context, fileChannel chan models.File)