Method WriteNetworkChannel

internal/store/store.go:88–88 · view source on GitHub ↗

(ctx context.Context, entry NetworkChannelEntry)

Source from the content-addressed store, hash-verified

86	// NetworkChannelStore manages durable network channel metadata.
87	type NetworkChannelStore interface {
88	WriteNetworkChannel(ctx context.Context, entry NetworkChannelEntry) error
89	GetNetworkChannel(ctx context.Context, ref NetworkChannelRef) (NetworkChannelEntry, error)
90	ListNetworkChannels(ctx context.Context, query NetworkChannelQuery) ([]NetworkChannelEntry, error)
91	PatchNetworkChannel(ctx context.Context, ref NetworkChannelRef, patch NetworkChannelPatch) error

TestSchedulerRecoversExpiredHistoricalNetworkLeaseIntegrationFunction · 0.65

TestTaskManagerHistoricalNetworkChannelOwnershipIntegrationFunction · 0.65

TestTaskManagerHistoricalNetworkChannelIntegrationFunction · 0.65

TestGlobalDBClaimNextRunReturnsSafeCoordinationChannelMetadataFunction · 0.65

TestGlobalDBClaimNextRunReturnsWorkspaceNetworkChannelMetadataFunction · 0.65

assertGlobalDBWriteAndListNetworkChannelsFunction · 0.65

assertGlobalDBPatchNetworkChannelsPreservesUnspecifiedFieldsFunction · 0.65

assertGlobalDBPatchNetworkChannelRejectsInvalidFanoutCouplingFunction · 0.65

assertGlobalDBDeleteNetworkChannelFunction · 0.65

assertGlobalDBDeleteWorkspaceCascadesNetworkChannelsFunction · 0.65

UpsertNetworkSubscriptionMethod · 0.65

finalizeCreatedNetworkChannelMethod · 0.65

GlobalDBinternal/store/globaldb/global_db.go

agentCoreNetworkStoreinternal/api/core/agent_channels_inter

StubNetworkStoreinternal/api/testutil/network_stub.go

recordingRegistryinternal/daemon/daemon_test.go

no outgoing calls

TestSchedulerRecoversExpiredHistoricalNetworkLeaseIntegrationFunction · 0.52

TestTaskManagerHistoricalNetworkChannelOwnershipIntegrationFunction · 0.52

TestTaskManagerHistoricalNetworkChannelIntegrationFunction · 0.52

TestGlobalDBClaimNextRunReturnsSafeCoordinationChannelMetadataFunction · 0.52

TestGlobalDBClaimNextRunReturnsWorkspaceNetworkChannelMetadataFunction · 0.52

assertGlobalDBWriteAndListNetworkChannelsFunction · 0.52

assertGlobalDBPatchNetworkChannelsPreservesUnspecifiedFieldsFunction · 0.52

assertGlobalDBPatchNetworkChannelRejectsInvalidFanoutCouplingFunction · 0.52

assertGlobalDBDeleteNetworkChannelFunction · 0.52

assertGlobalDBDeleteWorkspaceCascadesNetworkChannelsFunction · 0.52

createObserveNetworkChannelFunction · 0.52

seedNetworkStatusObserverThreadFunction · 0.52