pubsubtest

type TestPublishMsg struct {
	// Key represents the message key.
	Key string
	// Body represents the message body.
	Body []byte
}

type TestPublisher struct {
	// Published will contain a list of all messages that have been published.
	Published []TestPublishMsg

	// GivenError will be returned by the TestPublisher on publish.
	// Good for testing error scenarios.
	GivenError error

	// FoundError will contain any errors encountered while marshalling
	// the protobuf struct.
	FoundError error
	// contains filtered or unexported fields
}

type TestSubsMessage struct {
	Msg         []byte
	DoneTimeout time.Duration
	Doned       bool
}

type TestSubscriber struct {
	// ProtoMessages will be marshalled into []byte and used to mock out
	// a feed if it is populated.
	ProtoMessages []proto.Message

	// JSONMessages will be marshalled into []byte and used to mock out
	// a feed if it is populated.
	JSONMessages []interface{}

	// GivenErrError will be returned by the TestSubscriber on Err().
	// Good for testing error scenarios.
	GivenErrError error

	// GivenStopError will be returned by the TestSubscriber on Stop().
	// Good for testing error scenarios.
	GivenStopError error

	// FoundError will contain any errors encountered while marshalling
	// the JSON and protobuf struct.
	FoundError error
}