events

Documentation

Index

• func NewIterator(ch <-chan Message) core.Iterator
• type Iterator
  • func (e *Iterator) Next(ctx context.Context) (value core.Value, key core.Value, err error)
• type Message
  • func WithErr(err error) Message
  • func WithValue(val core.Value) Message
• type Observable
• type Stream
  • func Merge(inputs ...Stream) Stream
  • func New(source chan Message) Stream
• type Subscription

Functions

func NewIterator

func NewIterator(ch <-chan Message) core.Iterator

Types

type Iterator

type Iterator struct {
	// contains filtered or unexported fields
}

func (*Iterator) Next

func (e *Iterator) Next(ctx context.Context) (value core.Value, key core.Value, err error)

type Message

type Message interface {
	Value() core.Value
	Err() error
}

Message represents an event message that an Observable can emit.

func WithErr

func WithErr(err error) Message

func WithValue

func WithValue(val core.Value) Message

type Observable

type Observable interface {
	Subscribe(ctx context.Context, subscription Subscription) (Stream, error)
}

Observable represents an interface of complex types that returns stream of events.

type Stream

type Stream interface {
	Close(ctx context.Context) error
	Read(ctx context.Context) <-chan Message
}

Stream represents an event stream that produces target event objects.

func Merge

func Merge(inputs ...Stream) Stream

func New

func New(source chan Message) Stream

type Subscription

type Subscription struct {
	EventName string
	Options   *values.Object
}

Subscription represents an event subscription object that contains target event name and optional event options.