lint

Documentation

Index

• func Publisher(input *PublisherInput)
• func Subscriber(input *SubscriberInput)
• type PublisherInput
• type SubscriberInput

Functions

func Publisher

func Publisher(input *PublisherInput)

Publisher lints publishers.

func Subscriber

func Subscriber(input *SubscriberInput)

Subscriber lints subscribers.

Types

type PublisherInput

type PublisherInput struct {
	Subject  bps.Publisher
	Messages func(string, int) ([]*bps.PubMessage, error)
	Setup    func(topics ...string) error
	Teardown func(topics ...string) error
}

PublisherInput for the shared test.

type SubscriberInput

type SubscriberInput struct {
	// Subject should return a subject to be tested, with given topic/messages seeded.
	// Caller should handle all the subject teardown/cleanup.
	// Topics are guaranteed to be prefixed with "bps-unittest-".
	Subject func(topic string, messages []bps.SubMessage) bps.Subscriber
}

SubscriberInput for the shared test.