nakadi

Jun 27, 2022

Changes in this version

+ type BatchOptions struct

+ BatchCollectionTimeout time.Duration

+ BatchQueueSize int

+ MaxBatchSize int

+ type BatchPublishAPI struct

+ func NewBatchPublishAPI(client *Client, eventType string, publishOptions *PublishOptions, ...) *BatchPublishAPI

+ func (p *BatchPublishAPI) Close()

+ func (p *BatchPublishAPI) Publish(event interface{}) error

type ClientOptions

+ Middleware Middleware

+ type Middleware func(transport *http.Transport) http.RoundTripper

+ func NewTracingMiddleware(options *TracingOptions) Middleware

+ type TracingMiddleware struct

+ func (t *TracingMiddleware) CloseIdleConnections()

+ func (t *TracingMiddleware) RoundTrip(req *http.Request) (*http.Response, error)

+ type TracingOptions struct

+ ComponentName string

+ Tracer opentracing.Tracer

+ Verbose bool

Mar 9, 2021

Changes in this version

type EventMetadata

+ SpanCtx map[string]string

Aug 6, 2019

Changes in this version

+ type AuthorizationAttribute struct

+ DataType string

+ Value string

type Subscription

+ Authorization *SubscriptionAuthorization

+ type SubscriptionAuthorization struct

+ Admins []AuthorizationAttribute

+ Readers []AuthorizationAttribute

Aug 16, 2018

Changes in this version

type BatchItemsError

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

Feb 5, 2018

Changes in this version

type ProcessorOptions

+ MaxUncommittedEvents uint

type StreamOptions

+ MaxUncommittedEvents uint

Dec 4, 2017

Changes in this version

type ProcessorOptions

+ FlushTimeout uint

type StreamOptions

+ FlushTimeout uint

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

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

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