Documentation ¶
Index ¶
Constants ¶
View Source
const ( SubscribeBuffer = 1 SubscriptionName = "events" )
Variables ¶
This section is empty.
Functions ¶
func NewNATSConnection ¶
Types ¶
type EventBusMock ¶ added in v1.5.33
type EventBusMock struct {
// contains filtered or unexported fields
}
func NewEventBusMock ¶ added in v1.5.33
func NewEventBusMock() *EventBusMock
func (*EventBusMock) Close ¶ added in v1.5.33
func (b *EventBusMock) Close() error
func (*EventBusMock) Publish ¶ added in v1.5.33
func (b *EventBusMock) Publish(event testkube.Event) error
func (*EventBusMock) Subscribe ¶ added in v1.5.33
func (b *EventBusMock) Subscribe(queue string, handler Handler) error
func (*EventBusMock) Unsubscribe ¶ added in v1.5.33
func (b *EventBusMock) Unsubscribe(queue string) error
type NATSBus ¶
type NATSBus struct {
// contains filtered or unexported fields
}
func NewNATSBus ¶
func NewNATSBus(nc *nats.EncodedConn) *NATSBus
func (*NATSBus) Unsubscribe ¶
Click to show internal directories.
Click to hide internal directories.