lib

type CloudEventOption func(*cloudevents.Event)

type Consumer interface {
	Start(ctx context.Context) error
	GetStoredEvents() []StoredEvent
	GetConsumerEndPoint() string
	WaitForEvent(timeout time.Duration, filters ...EventFilterOption) bool
}

type EventFilterOption func(event *cloudevents.Event) bool

type Producer interface {
	Produce(ctx context.Context, event cloudevents.Event) error
	GetStoredEvents() []StoredEvent
}

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

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

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

type StoredEvent struct {
	Time   time.Time
	Event  cloudevents.Event
	Result cloudevents.Result
	Reply  cloudevents.Event
}

type StoredEventOption func(*StoredEvent)