event

type Bus[Key, Event any] struct {
	// contains filtered or unexported fields
}

type Forwarder interface {
	ForwardUserEvents(ctx context.Context, events ...*eventpb.UserEvent) error
}

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

type Handler[Key, Event any] interface {
	OnEvent(key Key, e Event)
}

type HandlerFunc[Key, Event any] func(Key, Event)

type KeyAndEvent[Key, Event any] struct {
	Key   Key
	Event Event
}

type ProtoEventStream[E any, P proto.Message] struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type Rendezvous struct {
	Key       string
	Address   string
	ExpiresAt time.Time
}

type Server struct {
	eventpb.UnimplementedEventStreamingServer
	// contains filtered or unexported fields
}

type StaleEventDetector[Event any] interface {
	ShouldDrop(event Event) bool
}

type StaleEventDetectorCtor[Event any] func() StaleEventDetector[Event]

type Store interface {
	// CreateRendezvous creates a new rendezvous for an event stream
	CreateRendezvous(ctx context.Context, rendezvous *Rendezvous) error

	// GetRendezvous gets an event stream rendezvous for a given key
	GetRendezvous(ctx context.Context, key string) (*Rendezvous, error)

	// ExtendRendezvousxpiry extends a rendezvous' expiry for a given key and address
	ExtendRendezvousExpiry(ctx context.Context, key, address string, expiresAt time.Time) error

	// DeleteRendezvous deletes an event stream rendezvous for a given key and address
	DeleteRendezvous(ctx context.Context, key, address string) error
}

type Stream[E any] interface {
	ID() string
	Notify(event E, timeout time.Duration) error
	Close()
}

type TestEventObserver[Key, Event any] struct {
	// contains filtered or unexported fields
}