store

type Collector interface {
	Collect(context context.Context, event *cloudevents.Event) error
}

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

type ConsumerTimedOut struct {
	WaitConsumerConfiguration
}

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

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

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

type DistributedLock interface {
	Lock(ctx context.Context, identifier string) error
	Release(identifier string) error
}

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

type EventAcknowledgment struct {
	EventId      string `json:"event_id"`
	ConsumerName string `json:"consumer_name"`
}

type EventLoader interface {
	MatchingStream(ctx context.Context, matcher events.Matcher) chan cloudevents.Event
}

type EventNotFound struct{}

type EventStore interface {
	Store(ctx context.Context, stream string, event *cloudevents.Event) error
	Find(ctx context.Context, id string) (*cloudevents.Event, error)
}

type EventStreamFactory struct {
	Source      chan cloudevents.Event
	Broadcaster *concurrency.ChannelBroadcaster
	// contains filtered or unexported fields
}

type InMemoryPublisher struct {
	Events []*cloudevents.Event
}

type InMemoryStorage struct {
	Events []cloudevents.Event
}

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

type Publisher interface {
	Publish(context context.Context, stream string, event *cloudevents.Event) error
}

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

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

type SequenceNumberDoNotMatchError struct{}

type WaitConsumerConfiguration struct {
	EventId      string
	ConsumerName string
	Timeout      time.Duration
}