estream

type EstablishRequest struct {
	Stream           string
	StreamFilterName string
	ReplayStartTime  time.Time
	StopTime         time.Time
}

type Filter struct {
	Name   string
	Filter func(*node.Selection) *node.Selection
}

type ModifyRequest struct {
	SubscriptionId   string
	StreamFilterName string
	StopTime         time.Time
}

type Receiver func(e ReceiverEvent) error

type ReceiverEvent struct {
	Name      string
	EventTime time.Time
	Event     *node.Selection
}

type RecvState int

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

type Stream struct {
	Name                  string
	Description           string
	ReplaySupport         bool
	ReplayLogCreationTime time.Time
	ReplayLogAgedTime     time.Time
	Open                  func() (*node.Selection, error)
}

type SubEvent struct {
	EventId      SubEventType
	Subscription *Subscription
	Reason       string
}

type SubEventType int

type SubState int

type Subscription struct {
	Id string

	ConfiguredSubscriptionState SubState
	Recievers                   map[string]*receiverEntry
	// contains filtered or unexported fields
}

type SubscriptionOptions struct {
	Filter          Filter
	Stream          Stream
	ReplayStartTime time.Time
	// configured-replay
	ReplayStartTimeRevision time.Time
	StopTime                time.Time
	// transport
	// encoding
	Purpose       string
	SourceAddress string
}