MCPcopy Create free account
hub / github.com/compozy/agh / StubNetworkStore

Struct StubNetworkStore

internal/api/testutil/network_stub.go:24–89  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

22var ErrStubNetworkServiceWaitInboxNotImplemented = errors.New("stub network service WaitInbox not implemented")
23
24type StubNetworkStore struct {
25 ResolveDirectRoomFn func(context.Context, store.NetworkDirectRoomEntry) (store.NetworkDirectRoomSummary, error)
26 WriteConversationMessageFn func(
27 context.Context,
28 store.NetworkConversationMessage,
29 ) (store.NetworkConversationWriteResult, error)
30 ListThreadsFn func(
31 context.Context,
32 store.NetworkChannelRef,
33 store.NetworkThreadQuery,
34 ) ([]store.NetworkThreadSummary, error)
35 GetThreadFn func(context.Context, store.NetworkChannelRef, string) (store.NetworkThreadSummary, error)
36 ListDirectRoomsFn func(
37 context.Context,
38 store.NetworkChannelRef,
39 store.NetworkDirectRoomQuery,
40 ) ([]store.NetworkDirectRoomSummary, error)
41 ListThreadParticipantsFn func(
42 context.Context,
43 store.NetworkChannelRef,
44 string,
45 ) ([]store.NetworkThreadParticipant, error)
46 UpdateNetworkThreadPeerTokenStatsFn func(context.Context, store.NetworkThreadPeerTokenStatsUpdate) error
47 ListNetworkThreadPeerTokenStatsFn func(
48 context.Context,
49 store.NetworkThreadPeerTokenStatsQuery,
50 ) ([]store.NetworkThreadPeerTokenStats, error)
51 GetDirectRoomFn func(
52 context.Context,
53 store.NetworkChannelRef,
54 string,
55 ) (store.NetworkDirectRoomSummary, error)
56 ListConversationMessagesFn func(
57 context.Context,
58 store.NetworkConversationRef,
59 store.NetworkConversationMessageQuery,
60 ) ([]store.NetworkConversationMessage, error)
61 GetWorkFn func(context.Context, string, string) (store.NetworkWorkEntry, error)
62 GetNetworkChannelFn func(context.Context, store.NetworkChannelRef) (store.NetworkChannelEntry, error)
63 ListNetworkChannelsFn func(context.Context, store.NetworkChannelQuery) ([]store.NetworkChannelEntry, error)
64 WriteNetworkChannelFn func(context.Context, store.NetworkChannelEntry) error
65 PatchNetworkChannelFn func(context.Context, store.NetworkChannelRef, store.NetworkChannelPatch) error
66 DeleteNetworkChannelFn func(context.Context, store.NetworkChannelRef) error
67 WriteNetworkAuditFn func(context.Context, store.NetworkAuditEntry) error
68 ListNetworkAuditFn func(context.Context, store.NetworkAuditQuery) ([]store.NetworkAuditEntry, error)
69 WriteNetworkMessageFn func(context.Context, store.NetworkMessageEntry) error
70 ListNetworkMessagesFn func(context.Context, store.NetworkMessageQuery) ([]store.NetworkMessageEntry, error)
71 PutNetworkSubscriptionFn func(context.Context, store.NetworkSubscriptionEntry) error
72 ListNetworkSubscriptionsFn func(
73 context.Context,
74 store.NetworkSubscriptionQuery,
75 ) ([]store.NetworkSubscriptionEntry, error)
76 DeleteNetworkSubscriptionFn func(context.Context, store.NetworkSubscriptionRef) error
77 GetNetworkDeliveryGuidanceStateFn func(context.Context, string) (store.NetworkDeliveryGuidanceState, error)
78 PutNetworkDeliveryGuidanceStateFn func(context.Context, store.NetworkDeliveryGuidanceState) error
79 PutNetworkTaskThreadOriginFn func(context.Context, store.NetworkTaskThreadOrigin) error
80 ListNetworkTaskThreadOriginsFn func(
81 context.Context,

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected