file

Aug 15, 2020

Changes in this version

+ var ErrNilChan error = fmt.Errorf("Source channel is nil")

+ var ErrNoDest error = fmt.Errorf("No destination path set")

+ func NewPublisher(opts *Opts, src <-chan *sse.Event) (publisher.Publisher, error)

+ type Opts struct

+ Destination string

+ type Publisher struct

+ func (f *Publisher) GetResumeID() string

+ func (f *Publisher) ProcessEvent(e *sse.Event) error

+ func (f *Publisher) ReadAndPublish() (int64, error)

+ func (f *Publisher) ValidateConnection() error

+ type PublisherConfig struct

+ Destination string