client

package module

Go to main page

Versions in this module

v0

v0.2.7

Jan 21, 2020

Changes in this version

+ const ITEM_CAPACITY

+ const ITEM_SIZE

+ var ErrChecksumFailed = errors.New("Checksum failed")

+ func CopyN(w io.Writer, r io.Reader, h io.Writer, size uint64, buffer []byte) error

+ func NewRawSegment() *rawSegment

+ type IndexEntry [64]byte

+ func (ie *IndexEntry) ReadFrom(r io.Reader) (int, error)

+ func (ie *IndexEntry) SetChecksum(checksum uint32)

+ func (ie *IndexEntry) SetEventID(eventID uuid.UUID)

+ func (ie *IndexEntry) SetLSN(lsn uint64)

+ func (ie *IndexEntry) SetOffset(offset uint64)

+ func (ie *IndexEntry) SetSize(size uint64)

+ func (ie *IndexEntry) SetTimestamp(value uint64)

+ func (ie IndexEntry) Checksum() uint32

+ func (ie IndexEntry) EventID() uuid.UUID

+ func (ie IndexEntry) LSN() uint64

+ func (ie IndexEntry) Offset() uint64

+ func (ie IndexEntry) Size() uint64

+ func (ie IndexEntry) Timestamp() uint64

+ func (ie IndexEntry) WriteTo(w io.Writer) (int, error)

type OptionFunc

+ func WithName(s string) OptionFunc

+ func WithSubscription(s string) OptionFunc

+ func WithTopicIn(s string) OptionFunc

+ func WithTopicOut(s string) OptionFunc

+ type Producer interface

+ Close func() error

+ Produce func(context.Context, Segment) error

+ func NewProducer(opts ...OptionFunc) (Producer, error)

+ type Segment interface

+ type SegmentCloser interface

+ Close func()

+ type SegmentHeaderer interface

+ Header func() IndexEntry

+ SetHeader func(IndexEntry)

+ type SegmentReader interface

+ Read func([]byte) (int, error)

+ type SegmentWriter interface

+ Write func([]byte) (int, error)

+ type Subscriber interface

+ Ack func(Segment) error

+ Close func() error

+ Consume func(context.Context, Segment) error

+ func NewSubscriber(opts ...OptionFunc) (Subscriber, error)

v0.2.6

Jan 21, 2020

v0.2.4

Nov 12, 2019

v0.2.3

Nov 12, 2019

Changes in this version

+ func NewDefaultLogger(endpoint, id string) *defaultLogger

+ func NewLogUploader(ctx context.Context, endpoint string) (*logUploader, error)

type DefaultWorker

+ func (w *DefaultWorker) Close() error

+ type LogCloser interface

+ Close func() error

+ type NullLogCloser struct

+ func (NullLogCloser) Close() error

type OptionFunc

+ func WithCloser(closer io.Closer) OptionFunc

+ func WithConsumeTimeout(s string) OptionFunc

+ func WithMaxIntake(num string) OptionFunc

type Worker

+ Close func() error

v0.2.2

Oct 3, 2019

Changes in this version

+ var EmptyMessage = Message

+ func IsNotFoundErr(err error) bool

+ type AckOptionFunc func(r *ackRequest) error

+ func WithFilter() AckOptionFunc

+ func WithMessage(message Message) AckOptionFunc

+ type BackOffFunc func() backoff.BackOff

type Config

+ FlowID uuid.UUID

+ WorkerID uuid.UUID

+ type Content []byte

+ func JsonContent(v interface{}) Content

+ func StringContent(s string) Content

+ type DefaultWorker struct

+ func (c *DefaultWorker) Ack(ref Reference, options ...AckOptionFunc) error

+ func (c *DefaultWorker) Consume() (Reference, error)

+ func (c *DefaultWorker) Get(ref Reference) (Message, error)

+ func (c *DefaultWorker) Produce(message Message) error

+ type EventID string

+ func (e EventID) String() string

+ type Logger interface

+ Debugf func(msg string, args ...interface{})

+ Errorf func(msg string, args ...interface{})

+ Fatalf func(msg string, args ...interface{})

+ Infof func(msg string, args ...interface{})

+ var DefaultLogger Logger = &defaultLogger{}

type Message

+ MetaData []Metadata

+ func NewMessage() Message

+ func (r *Message) UnmarshalJSON(data []byte) error

+ func (r Message) MarshalJSON() ([]byte, error)

+ type Metadata struct

+ Key string

+ Value string

+ type OptionFunc func(*Config) error

+ func CustomEnvironment(ravenURL, flowID, workerID string) OptionFunc

+ func DefaultEnvironment() OptionFunc

+ func WithBackOff(fn BackOffFunc) OptionFunc

+ func WithFlowID(s string) (OptionFunc, error)

+ func WithLogger(l Logger) (OptionFunc, error)

+ func WithRavenURL(urlStr string) (OptionFunc, error)

+ func WithWorkerID(s string) (OptionFunc, error)

type Reference

+ EventID string

+ type Worker interface

+ Ack func(Reference, ...AckOptionFunc) error

+ Consume func() (Reference, error)

+ Get func(Reference) (Message, error)

+ Produce func(Message) error

+ func New(opts ...OptionFunc) (Worker, error)

v0.1.2

Aug 7, 2019

v0.1.1

Aug 6, 2019

Changes in this version

+ type Config struct

+ FlowId string

+ RavenURL string

+ WorkerId string

+ func NewRavenworker(ravenURL, flowId, workerId string) (*Config, error)

+ func (c Config) Consume() (Message, error)

+ func (c Config) NewEvent(msg string) error

+ func (c Config) Produce(msg Message) error

+ type Message struct

+ Content string

+ Ref Reference

+ type Reference struct

+ AckID string

+ EventId string

+ FlowId string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL