events

Documentation

Index

• Variables
• func EventMatches(event cloudevents.Event, matcher Matcher) bool
• func EventsAreEquals(left cloudevents.Event, right cloudevents.Event) (bool, error)
• func ExpectEventWithId(t *testing.T, event cloudevents.Event, id string)
• func GetConsumersWaitedForAcknowledgmentFromEvent(event cloudevents.Event) []string
• func GetEventNumber(event cloudevents.Event) int
• func GetExpectedSequenceNumber(event cloudevents.Event) int
• func GetSequenceNumberInStream(event cloudevents.Event) int
• func GetStreamFromEvent(event cloudevents.Event) string
• func IsReplacingAnotherEvent(event cloudevents.Event) bool
• func NewEvent(id string, stream string, number int, sequenceNumberInStream int) cloudevents.Event
• func SetConsumersWaitedForAcknowledgmentFromEvent(event *cloudevents.Event, consumers []string)
• func SetEventNumber(event *cloudevents.Event, number int)
• func SetEventToReplaceExistingOne(event *cloudevents.Event)
• func SetExpectedSequenceNumber(event *cloudevents.Event, number int)
• func SetSequenceNumberInStream(event *cloudevents.Event, number int)
• func SetStream(event *cloudevents.Event, stream string)
• type Matcher

Variables

var SequenceNumberInStreamExtensionName = "fossilsequenceinstream"

Functions

func EventMatches

func EventMatches(event cloudevents.Event, matcher Matcher) bool

func EventsAreEquals

func EventsAreEquals(left cloudevents.Event, right cloudevents.Event) (bool, error)

func ExpectEventWithId

func ExpectEventWithId(t *testing.T, event cloudevents.Event, id string)

func GetConsumersWaitedForAcknowledgmentFromEvent

func GetConsumersWaitedForAcknowledgmentFromEvent(event cloudevents.Event) []string

func GetEventNumber

func GetEventNumber(event cloudevents.Event) int

func GetExpectedSequenceNumber

func GetExpectedSequenceNumber(event cloudevents.Event) int

func GetSequenceNumberInStream

func GetSequenceNumberInStream(event cloudevents.Event) int

func GetStreamFromEvent

func GetStreamFromEvent(event cloudevents.Event) string

func IsReplacingAnotherEvent

func IsReplacingAnotherEvent(event cloudevents.Event) bool

func NewEvent

func NewEvent(id string, stream string, number int, sequenceNumberInStream int) cloudevents.Event

func SetConsumersWaitedForAcknowledgmentFromEvent

func SetConsumersWaitedForAcknowledgmentFromEvent(event *cloudevents.Event, consumers []string)

func SetEventNumber

func SetEventNumber(event *cloudevents.Event, number int)

func SetEventToReplaceExistingOne

func SetEventToReplaceExistingOne(event *cloudevents.Event)

func SetExpectedSequenceNumber

func SetExpectedSequenceNumber(event *cloudevents.Event, number int)

func SetSequenceNumberInStream

func SetSequenceNumberInStream(event *cloudevents.Event, number int)

func SetStream

func SetStream(event *cloudevents.Event, stream string)

Types

type Matcher

type Matcher struct {
	UriTemplates    []string
	LastEventNumber int
}