bus

type Bus interface {
	Publish(ctx context.Context, event cloudevents.Event)
	Subscribe(ctx context.Context, channelName string) <-chan BusEvent
}

type BusEvent struct {
	Event cloudevents.Event
	Raw   []byte
	Err   error
}

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

type Connector interface {
	Publish(ctx context.Context, data []byte) error
	Subscribe(ctx context.Context, channel chan []byte)
	Len() int
}

type FuncNewEvent func(ctx context.Context, channelName string) Connector