internal

package
v0.2.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 10, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var StreamFixtureEventIDs1 = []uuid.UUID{
	uuid.MustParse("01966574-33ba-73c4-a5c0-a0b55249d39a"),
	uuid.MustParse("01966574-69ef-7b02-81cd-7fdbbbead77d"),
	uuid.MustParse("01966574-a5fe-7b22-9229-12a19afc8c32"),
	uuid.MustParse("01966575-47f8-7770-8a3c-56ea2e2b8dee"),
	uuid.MustParse("01966575-7ce6-7923-be83-011cebc8c8d3"),
	uuid.MustParse("01966575-a91e-7829-9f74-5069446071bf"),
	uuid.MustParse("01966576-0654-7f14-be3b-6af31cd6a1f5"),
	uuid.MustParse("01966576-368a-7a53-9f4e-38f9a5ef8ece"),
	uuid.MustParse("01966576-78b4-7711-9d4a-929e8dc29eb6"),
	uuid.MustParse("01966576-a6b5-7e37-8bf2-60e0eb10602e"),
	uuid.MustParse("01966576-e3e3-717d-bc25-324c29056a2f"),
	uuid.MustParse("01966577-3210-7562-8f1e-5a85200907b8"),
	uuid.MustParse("01966577-65f9-7cbb-ae74-93c7766c7d80"),
	uuid.MustParse("01966577-bff2-7829-b14b-7041be6c56b5"),
	uuid.MustParse("01966577-f76b-73b0-ae60-64d241ce4e8a"),
	uuid.MustParse("01966578-4544-729f-b968-b5893ea9fbdc"),
	uuid.MustParse("01966578-7675-7004-820f-d85b3e7616a7"),
	uuid.MustParse("01966578-acbf-735c-a318-6393dc267599"),
	uuid.MustParse("01966578-fe83-7cbd-8790-1a93dbf62e18"),
	uuid.MustParse("01966579-28d4-7c43-b4b2-f29238540587"),
}

UUIDv7 values for event IDs in timestamp order. These should be used in conjunction with the stream for the channel: "changesets_db58eda8-36c6-4180-a9cb-557f3392361c".

View Source 
var StreamFixtureEventIDs2 = []uuid.UUID{
	uuid.MustParse("0124e053-3580-7000-af52-4ac381dd6b44"),
	uuid.MustParse("0124e053-3582-7000-8206-d47b8e228491"),
	uuid.MustParse("0124e053-3584-7000-890a-36c56957891e"),
	uuid.MustParse("0124e053-3586-7000-9655-2786c4fe6265"),
	uuid.MustParse("0124e053-3588-7000-879b-ecdfab5040fb"),
	uuid.MustParse("0124e053-358a-7000-a35b-4e89ad94ea3b"),
	uuid.MustParse("0124e053-358c-7000-811b-f6ea3ae88425"),
	uuid.MustParse("0124e053-358e-7000-b5f0-4312eb6182f0"),
	uuid.MustParse("0124e053-3590-7000-9909-509308ef9a23"),
	uuid.MustParse("0124e053-3592-7000-846d-4aef540b6464"),
	uuid.MustParse("0124e053-3594-7000-8ed0-be0e4f5da934"),
	uuid.MustParse("0124e053-3596-7000-9336-8c37401e324c"),
	uuid.MustParse("0124e053-3598-7000-afa5-d0eecccba403"),
	uuid.MustParse("0124e053-359a-7000-a136-99afc1b30c9c"),
	uuid.MustParse("0124e053-359c-7000-9e42-48c82b6fe8eb"),
	uuid.MustParse("0124e053-359e-7000-8915-e35a14b642ba"),
	uuid.MustParse("0124e053-35a0-7000-90d6-e95020933403"),
	uuid.MustParse("0124e053-35a2-7000-8497-c67c6f11d926"),
	uuid.MustParse("0124e053-35a4-7000-8d69-12e2ac28ffb0"),
	uuid.MustParse("0124e053-35a6-7000-b03c-bb1fa7943039"),
}

UUIDv7 values for event IDs in timestamp order. These should be used in conjunction with the stream for the channel: "changesets_eabba2f8-5c74-4c51-a068-b340f718314a".

Functions

func AssertInstanceStatesEqual 

func AssertInstanceStatesEqual(expected, actual *state.InstanceState, s *suite.Suite)

AssertInstanceStatesEqual asserts that the actual instance state is equal to the expected instance state. This normalises nil slice and map fields to empty slices and maps as they are considered equivalent in this context.

func AssertInstanceStatusInfo 

func AssertInstanceStatusInfo(
	expected state.InstanceStatusInfo,
	actual state.InstanceState,
	s *suite.Suite,
)

AssertInstanceStatusInfo asserts that the actual instance status info is equal to the expected instance status info.

func AssertLinkStatesEqual 

func AssertLinkStatesEqual(
	expected *state.LinkState,
	actual *state.LinkState,
	s *suite.Suite,
)

AssertLinkStatesEqual asserts that the actual link state is equal to the expected link state. This normalises nil slice and map fields to empty slices and maps as they are considered equivalent in this context.

func AssertLinkStatusInfo 

func AssertLinkStatusInfo(
	expected state.LinkStatusInfo,
	actual state.LinkState,
	s *suite.Suite,
)

AssertLinkStatusInfo asserts that the actual link status info is equal to the expected link status info.

func AssertResourceDriftEqual 

func AssertResourceDriftEqual(expected, actual *state.ResourceDriftState, s *suite.Suite)

AssertResourceDriftEqual asserts that the actual resource drift state is equal to the expected resource drift state. This normalises nil slice and map fields to empty slices and maps as they are considered equivalent in this context.

func AssertResourceStatesEqual 

func AssertResourceStatesEqual(expected, actual *state.ResourceState, s *suite.Suite)

AssertResourceStatesEqual asserts that the actual resource state is equal to the expected resource state. This normalises nil slice and map fields to empty slices and maps as they are considered equivalent in this context.

func AssertResourceStatusInfo 

func AssertResourceStatusInfo(
	expected state.ResourceStatusInfo,
	actual state.ResourceState,
	s *suite.Suite,
)

AssertResourceStatusInfo asserts that the actual resource status info is equal to the expected resource status info.

func CreateTestInstanceStatusInfo 

func CreateTestInstanceStatusInfo() state.InstanceStatusInfo

CreateTestInstanceStatusInfo creates instance status info for testing status updates.

func CreateTestLinkStatusInfo 

func CreateTestLinkStatusInfo() state.LinkStatusInfo

CreateTestLinkStatusInfo creates link status info for testing status updates.

func CreateTestResourceStatusInfo 

func CreateTestResourceStatusInfo() state.ResourceStatusInfo

CreateTestResourceStatusInfo creates resource status info for testing status updates.

func IsEmptyDriftState 

func IsEmptyDriftState(actual state.ResourceDriftState) bool

IsEmptyDriftState checks if all the values in a given drift state are empty.

func SaveAllExportsInput 

func SaveAllExportsInput() map[string]*state.ExportState

SaveAllExportsInput returns a map of export states for testing behaviour to save exports.

func SaveMetadataInput 

func SaveMetadataInput() map[string]*core.MappingNode

SaveMetadataInput returns a map of metadata for testing behaviour to save metadata.

func SaveSingleExportInput 

func SaveSingleExportInput() state.ExportState

SaveSingleExportInput returns a single export state for testing behaviour to save a single export.

func SetupSaveBlueprintFixtures 

func SetupSaveBlueprintFixtures(dirPath string, updates []int) (map[int]SaveBlueprintFixture, error)

func SetupSaveBlueprintValidationFixtures 

func SetupSaveBlueprintValidationFixtures(
	dirPath string,
) (map[int]SaveBlueprintValidationFixture, error)

func SetupSaveChangesetFixtures 

func SetupSaveChangesetFixtures(dirPath string) (map[int]SaveChangesetFixture, error)

func SetupSaveEventFixtures 

func SetupSaveEventFixtures(dirPath string) (map[int]SaveEventFixture, error)

func SetupSaveLinkFixtures 

func SetupSaveLinkFixtures(dirPath string, updates []int) (map[int]SaveLinkFixture, error)

func SetupSaveResourceDriftFixtures 

func SetupSaveResourceDriftFixtures(dirPath string, updates []int) (map[int]SaveResourceDriftFixture, error)

func SetupSaveResourceFixtures 

func SetupSaveResourceFixtures(dirPath string, updates []int) (map[int]SaveResourceFixture, error)

func TestEndOfEventStream 

func TestEndOfEventStream(
	events manage.Events,
	channelType string,
	channelID string,
	s *suite.Suite,
)

func TestStreamEvents 

func TestStreamEvents(
	fixtures []SaveEventFixture,
	events manage.Events,
	channelType string,
	channelID string,
	expectedInitialEventIDs []string,
	s *suite.Suite,
)

Types

type MockClock 

type MockClock struct {
	Timestamp int64
}

func (*MockClock) Now 

func (m *MockClock) Now() time.Time

type SaveBlueprintFixture 

type SaveBlueprintFixture struct {
	InstanceState *state.InstanceState
	Update        bool
}

type SaveBlueprintValidationFixture 

type SaveBlueprintValidationFixture struct {
	Validation *manage.BlueprintValidation
}

type SaveChangesetFixture 

type SaveChangesetFixture struct {
	Changeset *manage.Changeset
}

type SaveEventFixture 

type SaveEventFixture struct {
	Event *manage.Event
}

func CreateEventStreamSaveFixtures 

func CreateEventStreamSaveFixtures(
	channelType string,
	channelID string,
	streamFixtureEventIDs []uuid.UUID,
) ([]SaveEventFixture, error)

type SaveLinkFixture 

type SaveLinkFixture struct {
	LinkState *state.LinkState
	Update    bool
}

type SaveResourceDriftFixture 

type SaveResourceDriftFixture struct {
	DriftState *state.ResourceDriftState
	Update     bool
}

type SaveResourceFixture 

type SaveResourceFixture struct {
	ResourceState *state.ResourceState
	Update        bool
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.