feedx

Jun 18, 2021

Changes in this version

type Consumer

+ LastConsumed func() time.Time

Oct 28, 2020

Changes in this version

+ var FlateCompression = flateCompression

Jul 15, 2019

Changes in this version

type Reader

+ func (r *Reader) Read(p []byte) (int, error)

type Writer

+ func (w *Writer) Write(p []byte) (int, error)

+ func (w *Writer) WriteString(s string) (int, error)

May 20, 2019

Changes in this version

+ type ConsumerSync struct

+ PreviousData interface{}

+ Updated bool

+ type ProducerPush struct

+ Updated bool

May 15, 2019

Changes in this version

+ type FormatPureEncoder interface

+ Encode func(v interface{}) error

+ type ProduceFunc func(FormatPureEncoder) error

+ type Producer struct

+ func NewProducer(ctx context.Context, remoteURL string, opt *ProducerOptions, pfn ProduceFunc) (*Producer, error)

+ func NewProducerForRemote(ctx context.Context, remote *bfs.Object, opt *ProducerOptions, pfn ProduceFunc) (*Producer, error)

+ func (p *Producer) Close() error

+ func (p *Producer) LastModified() time.Time

+ func (p *Producer) LastPush() time.Time

+ func (p *Producer) NumWritten() int

+ type ProducerOptions struct

+ AfterPush func(updated bool, consumer *Producer, err error)

+ Interval time.Duration

+ LastModCheck func(context.Context) (time.Time, error)

Feb 7, 2019

Changes in this version

type Writer

+ func (w *Writer) Commit() error

+ func (w *Writer) Discard() error

Dec 17, 2018

Changes in this version

+ var ErrNotModified = errors.New("feedx: not modified")

+ type ConsumeFunc func(FormatDecoder) (data interface{}, err error)

type Consumer

+ func NewConsumerForRemote(ctx context.Context, remote *bfs.Object, opt *ConsumerOptions, cfn ConsumeFunc) (Consumer, error)

+ LastSync func() time.Time

+ NumRead func() int

+ type Reader struct

+ func NewReader(ctx context.Context, remote *bfs.Object, opt *ReaderOptions) (*Reader, error)

+ func (r *Reader) Close() error

+ func (r *Reader) Decode(v interface{}) error

+ func (r *Reader) LastModified() (time.Time, error)

+ func (r *Reader) NumRead() int

+ type ReaderOptions struct

+ Compression Compression

+ Format Format

+ type Writer struct

+ func NewWriter(ctx context.Context, remote *bfs.Object, opt *WriterOptions) (*Writer, error)

+ func (w *Writer) Close() error

+ func (w *Writer) Encode(v interface{}) error

+ func (w *Writer) NumWritten() int

+ type WriterOptions struct

+ Compression Compression

+ Format Format

+ LastMod time.Time

Dec 14, 2018

Changes in this version

+ var GZipCompression = gzipCompression

+ var JSONFormat = jsonFormat

+ var NoCompression = noCompression

+ var ProtobufFormat = protobufFormat

+ type Compression interface

+ NewReader func(io.Reader) (io.ReadCloser, error)

+ NewWriter func(io.Writer) (io.WriteCloser, error)

+ func DetectCompression(name string) Compression

+ type Consumer interface

+ Close func() error

+ Data func() interface{}

+ LastCheck func() time.Time

+ LastModified func() time.Time

+ Size func() int64

+ func NewConsumer(ctx context.Context, srcURL string, opt *ConsumerOptions, parse ParseFunc) (Consumer, error)

+ type ConsumerOptions struct

+ AfterSync func(updated bool, err error)

+ Compression Compression

+ Format Format

+ Interval time.Duration

+ type Format interface

+ NewDecoder func(io.Reader) (FormatDecoder, error)

+ NewEncoder func(io.Writer) (FormatEncoder, error)

+ func DetectFormat(name string) Format

+ type FormatDecoder interface

+ Decode func(v interface{}) error

+ type FormatEncoder interface

+ Encode func(v interface{}) error

+ type ParseFunc func(FormatDecoder) (data interface{}, size int64, err error)