nakadi

package module

Go to main page

Versions in this module

v1

v1.4.6

Aug 22, 2018

v1.4.5

Aug 16, 2018

Changes in this version

type BatchItemsError

+ func (err BatchItemsError) Format(s fmt.State, verb rune)

v1.4.4

Aug 3, 2018

v1.4.3

Aug 3, 2018

v1.4.2

Jul 16, 2018

v1.4.1

Feb 23, 2018

v1.4.0

Feb 5, 2018

Changes in this version

type ProcessorOptions

+ MaxUncommittedEvents uint

type StreamOptions

+ MaxUncommittedEvents uint

v1.3.0

Dec 4, 2017

Changes in this version

type ProcessorOptions

+ FlushTimeout uint

type StreamOptions

+ FlushTimeout uint

v1.2.0

Oct 26, 2017

Changes in this version

+ type Operation func(int, string, []byte) error

+ type Processor struct

+ func NewProcessor(client *Client, subscriptionID string, options *ProcessorOptions) *Processor

+ func (p *Processor) Start(operation Operation) error

+ func (p *Processor) Stop() error

+ type ProcessorOptions struct

+ BatchLimit uint

+ CommitMaxElapsedTime time.Duration

+ EventsPerMinute uint

+ InitialRetryInterval time.Duration

+ MaxRetryInterval time.Duration

+ NotifyErr func(uint, error, time.Duration)

+ NotifyOK func(uint)

+ StreamCount uint

type StreamOptions

+ CommitRetry bool

v1.1.0

Sep 15, 2017

Changes in this version

+ type PartitionStats struct

+ Partition string

+ State string

+ StreamID string

+ UnconsumedEvents int

type SubscriptionAPI

+ func (s *SubscriptionAPI) GetStats(id string) ([]*SubscriptionStats, error)

+ type SubscriptionStats struct

+ EventType string

+ Partitions []*PartitionStats

v1.0.0

Aug 28, 2017

Changes in this version

+ type BatchItemResponse struct

+ Detail string

+ EID string

+ PublishingStatus string

+ Step string

+ type BatchItemsError []BatchItemResponse

+ func (err BatchItemsError) Error() string

+ type BusinessEvent struct

+ Metadata EventMetadata

+ OrderNumber string

+ type Client struct

+ func New(url string, options *ClientOptions) *Client

+ type ClientOptions struct

+ ConnectionTimeout time.Duration

+ TokenProvider func() (string, error)

+ type Cursor struct

+ CursorToken string

+ EventType string

+ NakadiStreamID string

+ Offset string

+ Partition string

+ type DataChangeEvent struct

+ Data interface{}

+ DataOP string

+ DataType string

+ Metadata EventMetadata

+ type EventAPI struct

+ func NewEventAPI(client *Client, options *EventOptions) *EventAPI

+ func (e *EventAPI) Create(eventType *EventType) error

+ func (e *EventAPI) Delete(name string) error

+ func (e *EventAPI) Get(name string) (*EventType, error)

+ func (e *EventAPI) List() ([]*EventType, error)

+ func (e *EventAPI) Update(eventType *EventType) error

+ type EventMetadata struct

+ EID string

+ EventType string

+ FlowID string

+ OccurredAt time.Time

+ ParentEIDs []string

+ Partition string

+ ReceivedAt *time.Time

+ type EventOptions struct

+ InitialRetryInterval time.Duration

+ MaxElapsedTime time.Duration

+ MaxRetryInterval time.Duration

+ Retry bool

+ type EventType struct

+ Category string

+ CompatibilityMode string

+ CreatedAt time.Time

+ DefaultStatistics *EventTypeStatistics

+ EnrichmentStrategies []string

+ Name string

+ Options *EventTypeOptions

+ OwningApplication string

+ PartitionKeyFields []string

+ PartitionStrategy string

+ Schema *EventTypeSchema

+ UpdatedAt time.Time

+ type EventTypeOptions struct

+ RetentionTime int64

+ type EventTypeSchema struct

+ CreatedAt time.Time

+ Schema string

+ Type string

+ Version string

+ type EventTypeStatistics struct

+ MessageSize int

+ MessagesPerMinute int

+ ReadParallelism int

+ WriteParallelism int

+ type PublishAPI struct

+ func NewPublishAPI(client *Client, eventType string, options *PublishOptions) *PublishAPI

+ func (p *PublishAPI) Publish(events interface{}) error

+ func (p *PublishAPI) PublishBusinessEvent(events []BusinessEvent) error

+ func (p *PublishAPI) PublishDataChangeEvent(events []DataChangeEvent) error

+ type PublishOptions struct

+ InitialRetryInterval time.Duration

+ MaxElapsedTime time.Duration

+ MaxRetryInterval time.Duration

+ Retry bool

+ type StreamAPI struct

+ func NewStream(client *Client, subscriptionID string, options *StreamOptions) *StreamAPI

+ func (s *StreamAPI) Close() error

+ func (s *StreamAPI) CommitCursor(cursor Cursor) error

+ func (s *StreamAPI) NextEvents() (Cursor, []byte, error)

+ type StreamOptions struct

+ BatchLimit int

+ CommitMaxElapsedTime time.Duration

+ InitialRetryInterval time.Duration

+ MaxRetryInterval time.Duration

+ NotifyErr func(error, time.Duration)

+ NotifyOK func()

+ type Subscription struct

+ ConsumerGroup string

+ CreatedAt time.Time

+ EventTypes []string

+ ID string

+ OwningApplication string

+ ReadFrom string

+ type SubscriptionAPI struct

+ func NewSubscriptionAPI(client *Client, options *SubscriptionOptions) *SubscriptionAPI

+ func (s *SubscriptionAPI) Create(subscription *Subscription) (*Subscription, error)

+ func (s *SubscriptionAPI) Delete(id string) error

+ func (s *SubscriptionAPI) Get(id string) (*Subscription, error)

+ func (s *SubscriptionAPI) List() ([]*Subscription, error)

+ type SubscriptionOptions struct

+ InitialRetryInterval time.Duration

+ MaxElapsedTime time.Duration

+ MaxRetryInterval time.Duration

+ Retry bool

+ type UndefinedEvent struct

+ Metadata EventMetadata

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