Documentation ¶
Index ¶
- Constants
- func NewAdminServiceHandler(svc AdminServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
- func NewApiKeyServiceHandler(svc ApiKeyServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
- func NewAuth0SupportHandler(svc Auth0SupportHandler, opts ...connect.HandlerOption) (string, http.Handler)
- func NewBookmarksServiceHandler(svc BookmarksServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
- func NewChangesServiceHandler(svc ChangesServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
- func NewConfigServiceHandler(svc ConfigServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
- func NewInviteServiceHandler(svc InviteServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
- func NewKeepaliveSourcesInterceptor(managementClient ManagementServiceClient) connect.Interceptor
- func NewManagementServiceHandler(svc ManagementServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
- func NewRevlinkServiceHandler(svc RevlinkServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
- func NewSnapshotsServiceHandler(svc SnapshotsServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
- func WaitForSources(ctx context.Context) error
- type AdminServiceClient
- type AdminServiceHandler
- type ApiKeyServiceClient
- type ApiKeyServiceHandler
- type Auth0SupportClient
- type Auth0SupportHandler
- type BookmarksServiceClient
- type BookmarksServiceHandler
- type ChangesServiceClient
- type ChangesServiceHandler
- type ConfigServiceClient
- type ConfigServiceHandler
- type InviteServiceClient
- type InviteServiceHandler
- type KeepaliveSourcesInterceptor
- func (i *KeepaliveSourcesInterceptor) WrapStreamingClient(next connect.StreamingClientFunc) connect.StreamingClientFunc
- func (i *KeepaliveSourcesInterceptor) WrapStreamingHandler(next connect.StreamingHandlerFunc) connect.StreamingHandlerFunc
- func (i *KeepaliveSourcesInterceptor) WrapUnary(next connect.UnaryFunc) connect.UnaryFunc
- type ManagementServiceClient
- type ManagementServiceHandler
- type RevlinkServiceClient
- type RevlinkServiceHandler
- type SnapshotsServiceClient
- type SnapshotsServiceHandler
- type UnimplementedAdminServiceHandler
- func (UnimplementedAdminServiceHandler) CreateAccount(context.Context, *connect.Request[sdp_go.CreateAccountRequest]) (*connect.Response[sdp_go.CreateAccountResponse], error)
- func (UnimplementedAdminServiceHandler) CreateSource(context.Context, *connect.Request[sdp_go.AdminCreateSourceRequest]) (*connect.Response[sdp_go.CreateSourceResponse], error)
- func (UnimplementedAdminServiceHandler) CreateToken(context.Context, *connect.Request[sdp_go.AdminCreateTokenRequest]) (*connect.Response[sdp_go.CreateTokenResponse], error)
- func (UnimplementedAdminServiceHandler) DeleteAccount(context.Context, *connect.Request[sdp_go.DeleteAccountRequest]) (*connect.Response[sdp_go.DeleteAccountResponse], error)
- func (UnimplementedAdminServiceHandler) DeleteSource(context.Context, *connect.Request[sdp_go.AdminDeleteSourceRequest]) (*connect.Response[sdp_go.DeleteSourceResponse], error)
- func (UnimplementedAdminServiceHandler) GetAccount(context.Context, *connect.Request[sdp_go.AdminGetAccountRequest]) (*connect.Response[sdp_go.GetAccountResponse], error)
- func (UnimplementedAdminServiceHandler) GetSource(context.Context, *connect.Request[sdp_go.AdminGetSourceRequest]) (*connect.Response[sdp_go.GetSourceResponse], error)
- func (UnimplementedAdminServiceHandler) KeepaliveSources(context.Context, *connect.Request[sdp_go.AdminKeepaliveSourcesRequest]) (*connect.Response[sdp_go.KeepaliveSourcesResponse], error)
- func (UnimplementedAdminServiceHandler) ListAccounts(context.Context, *connect.Request[sdp_go.ListAccountsRequest]) (*connect.Response[sdp_go.ListAccountsResponse], error)
- func (UnimplementedAdminServiceHandler) ListSources(context.Context, *connect.Request[sdp_go.AdminListSourcesRequest]) (*connect.Response[sdp_go.ListSourcesResponse], error)
- func (UnimplementedAdminServiceHandler) UpdateSource(context.Context, *connect.Request[sdp_go.AdminUpdateSourceRequest]) (*connect.Response[sdp_go.UpdateSourceResponse], error)
- type UnimplementedApiKeyServiceHandler
- func (UnimplementedApiKeyServiceHandler) CreateAPIKey(context.Context, *connect.Request[sdp_go.CreateAPIKeyRequest]) (*connect.Response[sdp_go.CreateAPIKeyResponse], error)
- func (UnimplementedApiKeyServiceHandler) DeleteAPIKey(context.Context, *connect.Request[sdp_go.DeleteAPIKeyRequest]) (*connect.Response[sdp_go.DeleteAPIKeyResponse], error)
- func (UnimplementedApiKeyServiceHandler) ExchangeKeyForToken(context.Context, *connect.Request[sdp_go.ExchangeKeyForTokenRequest]) (*connect.Response[sdp_go.ExchangeKeyForTokenResponse], error)
- func (UnimplementedApiKeyServiceHandler) GetAPIKey(context.Context, *connect.Request[sdp_go.GetAPIKeyRequest]) (*connect.Response[sdp_go.GetAPIKeyResponse], error)
- func (UnimplementedApiKeyServiceHandler) ListAPIKeys(context.Context, *connect.Request[sdp_go.ListAPIKeysRequest]) (*connect.Response[sdp_go.ListAPIKeysResponse], error)
- func (UnimplementedApiKeyServiceHandler) UpdateAPIKey(context.Context, *connect.Request[sdp_go.UpdateAPIKeyRequest]) (*connect.Response[sdp_go.UpdateAPIKeyResponse], error)
- type UnimplementedAuth0SupportHandler
- func (UnimplementedAuth0SupportHandler) CreateUser(context.Context, *connect.Request[sdp_go.Auth0CreateUserRequest]) (*connect.Response[sdp_go.Auth0CreateUserResponse], error)
- func (UnimplementedAuth0SupportHandler) KeepaliveSources(context.Context, *connect.Request[sdp_go.AdminKeepaliveSourcesRequest]) (*connect.Response[sdp_go.KeepaliveSourcesResponse], error)
- type UnimplementedBookmarksServiceHandler
- func (UnimplementedBookmarksServiceHandler) CreateBookmark(context.Context, *connect.Request[sdp_go.CreateBookmarkRequest]) (*connect.Response[sdp_go.CreateBookmarkResponse], error)
- func (UnimplementedBookmarksServiceHandler) DeleteBookmark(context.Context, *connect.Request[sdp_go.DeleteBookmarkRequest]) (*connect.Response[sdp_go.DeleteBookmarkResponse], error)
- func (UnimplementedBookmarksServiceHandler) GetAffectedBookmarks(context.Context, *connect.Request[sdp_go.GetAffectedBookmarksRequest]) (*connect.Response[sdp_go.GetAffectedBookmarksResponse], error)
- func (UnimplementedBookmarksServiceHandler) GetBookmark(context.Context, *connect.Request[sdp_go.GetBookmarkRequest]) (*connect.Response[sdp_go.GetBookmarkResponse], error)
- func (UnimplementedBookmarksServiceHandler) ListBookmarks(context.Context, *connect.Request[sdp_go.ListBookmarksRequest]) (*connect.Response[sdp_go.ListBookmarkResponse], error)
- func (UnimplementedBookmarksServiceHandler) UpdateBookmark(context.Context, *connect.Request[sdp_go.UpdateBookmarkRequest]) (*connect.Response[sdp_go.UpdateBookmarkResponse], error)
- type UnimplementedChangesServiceHandler
- func (UnimplementedChangesServiceHandler) CalculateBlastRadius(context.Context, *connect.Request[sdp_go.CalculateBlastRadiusRequest], ...) error
- func (UnimplementedChangesServiceHandler) CreateApp(context.Context, *connect.Request[sdp_go.CreateAppRequest]) (*connect.Response[sdp_go.CreateAppResponse], error)
- func (UnimplementedChangesServiceHandler) CreateChange(context.Context, *connect.Request[sdp_go.CreateChangeRequest]) (*connect.Response[sdp_go.CreateChangeResponse], error)
- func (UnimplementedChangesServiceHandler) CreateSimpleApp(context.Context, *connect.Request[sdp_go.CreateSimpleAppRequest]) (*connect.Response[sdp_go.CreateSimpleAppResponse], error)
- func (UnimplementedChangesServiceHandler) DeleteApp(context.Context, *connect.Request[sdp_go.DeleteAppRequest]) (*connect.Response[sdp_go.DeleteAppResponse], error)
- func (UnimplementedChangesServiceHandler) DeleteChange(context.Context, *connect.Request[sdp_go.DeleteChangeRequest]) (*connect.Response[sdp_go.DeleteChangeResponse], error)
- func (UnimplementedChangesServiceHandler) EndChange(context.Context, *connect.Request[sdp_go.EndChangeRequest], ...) error
- func (UnimplementedChangesServiceHandler) GetAffectedApps(context.Context, *connect.Request[sdp_go.GetAffectedAppsRequest]) (*connect.Response[sdp_go.GetAffectedAppsResponse], error)
- func (UnimplementedChangesServiceHandler) GetApp(context.Context, *connect.Request[sdp_go.GetAppRequest]) (*connect.Response[sdp_go.GetAppResponse], error)
- func (UnimplementedChangesServiceHandler) GetAppSummaries(context.Context, *connect.Request[sdp_go.GetAppSummariesRequest]) (*connect.Response[sdp_go.GetAppSummariesResponse], error)
- func (UnimplementedChangesServiceHandler) GetAppSummary(context.Context, *connect.Request[sdp_go.GetAppSummaryRequest]) (*connect.Response[sdp_go.GetAppSummaryResponse], error)
- func (UnimplementedChangesServiceHandler) GetChange(context.Context, *connect.Request[sdp_go.GetChangeRequest]) (*connect.Response[sdp_go.GetChangeResponse], error)
- func (UnimplementedChangesServiceHandler) GetChangeArchive(context.Context, *connect.Request[sdp_go.GetChangeArchiveRequest]) (*connect.Response[sdp_go.GetChangeArchiveResponse], error)
- func (UnimplementedChangesServiceHandler) GetChangeRisks(context.Context, *connect.Request[sdp_go.GetChangeRisksRequest]) (*connect.Response[sdp_go.GetChangeRisksResponse], error)
- func (UnimplementedChangesServiceHandler) GetChangeTimeline(context.Context, *connect.Request[sdp_go.GetChangeTimelineRequest]) (*connect.Response[sdp_go.GetChangeTimelineResponse], error)
- func (UnimplementedChangesServiceHandler) GetDiff(context.Context, *connect.Request[sdp_go.GetDiffRequest]) (*connect.Response[sdp_go.GetDiffResponse], error)
- func (UnimplementedChangesServiceHandler) GetOnboarding(context.Context, *connect.Request[sdp_go.GetOnboardingRequest]) (*connect.Response[sdp_go.GetOnboardingResponse], error)
- func (UnimplementedChangesServiceHandler) ListAppChanges(context.Context, *connect.Request[sdp_go.ListAppChangesRequest]) (*connect.Response[sdp_go.ListAppChangesResponse], error)
- func (UnimplementedChangesServiceHandler) ListAppChangesSummary(context.Context, *connect.Request[sdp_go.ListAppChangesSummaryRequest]) (*connect.Response[sdp_go.ListAppChangesSummaryResponse], error)
- func (UnimplementedChangesServiceHandler) ListApps(context.Context, *connect.Request[sdp_go.ListAppsRequest]) (*connect.Response[sdp_go.ListAppsResponse], error)
- func (UnimplementedChangesServiceHandler) ListChanges(context.Context, *connect.Request[sdp_go.ListChangesRequest]) (*connect.Response[sdp_go.ListChangesResponse], error)
- func (UnimplementedChangesServiceHandler) ListChangesByStatus(context.Context, *connect.Request[sdp_go.ListChangesByStatusRequest]) (*connect.Response[sdp_go.ListChangesByStatusResponse], error)
- func (UnimplementedChangesServiceHandler) ListChangingItemsSummary(context.Context, *connect.Request[sdp_go.ListChangingItemsSummaryRequest]) (*connect.Response[sdp_go.ListChangingItemsSummaryResponse], error)
- func (UnimplementedChangesServiceHandler) ListHomeApps(context.Context, *connect.Request[sdp_go.ListHomeAppsRequest]) (*connect.Response[sdp_go.ListHomeAppsResponse], error)
- func (UnimplementedChangesServiceHandler) ListHomeChanges(context.Context, *connect.Request[sdp_go.ListHomeChangesRequest]) (*connect.Response[sdp_go.ListHomeChangesResponse], error)
- func (UnimplementedChangesServiceHandler) RefreshState(context.Context, *connect.Request[sdp_go.RefreshStateRequest]) (*connect.Response[sdp_go.RefreshStateResponse], error)
- func (UnimplementedChangesServiceHandler) SimulateChange(context.Context, *connect.Request[sdp_go.SimulateChangeRequest], ...) error
- func (UnimplementedChangesServiceHandler) StartChange(context.Context, *connect.Request[sdp_go.StartChangeRequest], ...) error
- func (UnimplementedChangesServiceHandler) UpdateApp(context.Context, *connect.Request[sdp_go.UpdateAppRequest]) (*connect.Response[sdp_go.UpdateAppResponse], error)
- func (UnimplementedChangesServiceHandler) UpdateChange(context.Context, *connect.Request[sdp_go.UpdateChangeRequest]) (*connect.Response[sdp_go.UpdateChangeResponse], error)
- func (UnimplementedChangesServiceHandler) UpdateChangingItems(context.Context, *connect.Request[sdp_go.UpdateChangingItemsRequest], ...) error
- func (UnimplementedChangesServiceHandler) UpdateOnboarding(context.Context, *connect.Request[sdp_go.UpdateOnboardingRequest]) (*connect.Response[sdp_go.UpdateOnboardingResponse], error)
- func (UnimplementedChangesServiceHandler) UpdatePlannedChanges(context.Context, *connect.Request[sdp_go.UpdatePlannedChangesRequest], ...) error
- type UnimplementedConfigServiceHandler
- func (UnimplementedConfigServiceHandler) GetConfig(context.Context, *connect.Request[sdp_go.GetConfigRequest]) (*connect.Response[sdp_go.GetConfigResponse], error)
- func (UnimplementedConfigServiceHandler) SetConfig(context.Context, *connect.Request[sdp_go.SetConfigRequest]) (*connect.Response[sdp_go.SetConfigResponse], error)
- type UnimplementedInviteServiceHandler
- func (UnimplementedInviteServiceHandler) CreateInvite(context.Context, *connect.Request[sdp_go.CreateInviteRequest]) (*connect.Response[sdp_go.CreateInviteResponse], error)
- func (UnimplementedInviteServiceHandler) ListInvites(context.Context, *connect.Request[sdp_go.ListInvitesRequest]) (*connect.Response[sdp_go.ListInvitesResponse], error)
- func (UnimplementedInviteServiceHandler) ResendInvite(context.Context, *connect.Request[sdp_go.ResendInviteRequest]) (*connect.Response[sdp_go.ResendInviteResponse], error)
- func (UnimplementedInviteServiceHandler) RevokeInvite(context.Context, *connect.Request[sdp_go.RevokeInviteRequest]) (*connect.Response[sdp_go.RevokeInviteResponse], error)
- type UnimplementedManagementServiceHandler
- func (UnimplementedManagementServiceHandler) CreateSource(context.Context, *connect.Request[sdp_go.CreateSourceRequest]) (*connect.Response[sdp_go.CreateSourceResponse], error)
- func (UnimplementedManagementServiceHandler) CreateToken(context.Context, *connect.Request[sdp_go.CreateTokenRequest]) (*connect.Response[sdp_go.CreateTokenResponse], error)
- func (UnimplementedManagementServiceHandler) DeleteSource(context.Context, *connect.Request[sdp_go.DeleteSourceRequest]) (*connect.Response[sdp_go.DeleteSourceResponse], error)
- func (UnimplementedManagementServiceHandler) GetAccount(context.Context, *connect.Request[sdp_go.GetAccountRequest]) (*connect.Response[sdp_go.GetAccountResponse], error)
- func (UnimplementedManagementServiceHandler) GetSource(context.Context, *connect.Request[sdp_go.GetSourceRequest]) (*connect.Response[sdp_go.GetSourceResponse], error)
- func (UnimplementedManagementServiceHandler) KeepaliveSources(context.Context, *connect.Request[sdp_go.KeepaliveSourcesRequest]) (*connect.Response[sdp_go.KeepaliveSourcesResponse], error)
- func (UnimplementedManagementServiceHandler) ListSources(context.Context, *connect.Request[sdp_go.ListSourcesRequest]) (*connect.Response[sdp_go.ListSourcesResponse], error)
- func (UnimplementedManagementServiceHandler) UpdateSource(context.Context, *connect.Request[sdp_go.UpdateSourceRequest]) (*connect.Response[sdp_go.UpdateSourceResponse], error)
- type UnimplementedRevlinkServiceHandler
- func (UnimplementedRevlinkServiceHandler) GetReverseLinks(context.Context, *connect.Request[sdp_go.GetReverseLinksRequest]) (*connect.Response[sdp_go.GetReverseLinksResponse], error)
- func (UnimplementedRevlinkServiceHandler) IngestGatewayResponses(context.Context, *connect.ClientStream[sdp_go.IngestGatewayResponseRequest]) (*connect.Response[sdp_go.IngestGatewayResponsesResponse], error)
- type UnimplementedSnapshotsServiceHandler
- func (UnimplementedSnapshotsServiceHandler) CreateSnapshot(context.Context, *connect.Request[sdp_go.CreateSnapshotRequest]) (*connect.Response[sdp_go.CreateSnapshotResponse], error)
- func (UnimplementedSnapshotsServiceHandler) DeleteSnapshot(context.Context, *connect.Request[sdp_go.DeleteSnapshotRequest]) (*connect.Response[sdp_go.DeleteSnapshotResponse], error)
- func (UnimplementedSnapshotsServiceHandler) GetInitialData(context.Context, *connect.Request[sdp_go.GetInitialDataRequest]) (*connect.Response[sdp_go.GetInitialDataResponse], error)
- func (UnimplementedSnapshotsServiceHandler) GetSnapshot(context.Context, *connect.Request[sdp_go.GetSnapshotRequest]) (*connect.Response[sdp_go.GetSnapshotResponse], error)
- func (UnimplementedSnapshotsServiceHandler) ListSnapshots(context.Context, *connect.Request[sdp_go.ListSnapshotsRequest]) (*connect.Response[sdp_go.ListSnapshotResponse], error)
- func (UnimplementedSnapshotsServiceHandler) UpdateSnapshot(context.Context, *connect.Request[sdp_go.UpdateSnapshotRequest]) (*connect.Response[sdp_go.UpdateSnapshotResponse], error)
Constants ¶
const ( // AdminServiceName is the fully-qualified name of the AdminService service. AdminServiceName = "account.AdminService" // ManagementServiceName is the fully-qualified name of the ManagementService service. ManagementServiceName = "account.ManagementService" )
const ( // AdminServiceListAccountsProcedure is the fully-qualified name of the AdminService's ListAccounts // RPC. AdminServiceListAccountsProcedure = "/account.AdminService/ListAccounts" // AdminServiceCreateAccountProcedure is the fully-qualified name of the AdminService's // CreateAccount RPC. AdminServiceCreateAccountProcedure = "/account.AdminService/CreateAccount" // AdminServiceGetAccountProcedure is the fully-qualified name of the AdminService's GetAccount RPC. AdminServiceGetAccountProcedure = "/account.AdminService/GetAccount" // AdminServiceDeleteAccountProcedure is the fully-qualified name of the AdminService's // DeleteAccount RPC. AdminServiceDeleteAccountProcedure = "/account.AdminService/DeleteAccount" // AdminServiceListSourcesProcedure is the fully-qualified name of the AdminService's ListSources // RPC. AdminServiceListSourcesProcedure = "/account.AdminService/ListSources" // AdminServiceCreateSourceProcedure is the fully-qualified name of the AdminService's CreateSource // RPC. AdminServiceCreateSourceProcedure = "/account.AdminService/CreateSource" // AdminServiceGetSourceProcedure is the fully-qualified name of the AdminService's GetSource RPC. AdminServiceGetSourceProcedure = "/account.AdminService/GetSource" // AdminServiceUpdateSourceProcedure is the fully-qualified name of the AdminService's UpdateSource // RPC. AdminServiceUpdateSourceProcedure = "/account.AdminService/UpdateSource" // AdminServiceDeleteSourceProcedure is the fully-qualified name of the AdminService's DeleteSource // RPC. AdminServiceDeleteSourceProcedure = "/account.AdminService/DeleteSource" // AdminServiceKeepaliveSourcesProcedure is the fully-qualified name of the AdminService's // KeepaliveSources RPC. AdminServiceKeepaliveSourcesProcedure = "/account.AdminService/KeepaliveSources" // AdminServiceCreateTokenProcedure is the fully-qualified name of the AdminService's CreateToken // RPC. AdminServiceCreateTokenProcedure = "/account.AdminService/CreateToken" // ManagementServiceGetAccountProcedure is the fully-qualified name of the ManagementService's // GetAccount RPC. ManagementServiceGetAccountProcedure = "/account.ManagementService/GetAccount" // ManagementServiceListSourcesProcedure is the fully-qualified name of the ManagementService's // ListSources RPC. ManagementServiceListSourcesProcedure = "/account.ManagementService/ListSources" // ManagementServiceCreateSourceProcedure is the fully-qualified name of the ManagementService's // CreateSource RPC. ManagementServiceCreateSourceProcedure = "/account.ManagementService/CreateSource" // ManagementServiceGetSourceProcedure is the fully-qualified name of the ManagementService's // GetSource RPC. ManagementServiceGetSourceProcedure = "/account.ManagementService/GetSource" // ManagementServiceUpdateSourceProcedure is the fully-qualified name of the ManagementService's // UpdateSource RPC. ManagementServiceUpdateSourceProcedure = "/account.ManagementService/UpdateSource" // ManagementServiceDeleteSourceProcedure is the fully-qualified name of the ManagementService's // DeleteSource RPC. ManagementServiceDeleteSourceProcedure = "/account.ManagementService/DeleteSource" // ManagementServiceKeepaliveSourcesProcedure is the fully-qualified name of the ManagementService's // KeepaliveSources RPC. ManagementServiceKeepaliveSourcesProcedure = "/account.ManagementService/KeepaliveSources" // ManagementServiceCreateTokenProcedure is the fully-qualified name of the ManagementService's // CreateToken RPC. ManagementServiceCreateTokenProcedure = "/account.ManagementService/CreateToken" )
These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.
Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.
const ( // ApiKeyServiceCreateAPIKeyProcedure is the fully-qualified name of the ApiKeyService's // CreateAPIKey RPC. ApiKeyServiceCreateAPIKeyProcedure = "/apikeys.ApiKeyService/CreateAPIKey" // ApiKeyServiceGetAPIKeyProcedure is the fully-qualified name of the ApiKeyService's GetAPIKey RPC. ApiKeyServiceGetAPIKeyProcedure = "/apikeys.ApiKeyService/GetAPIKey" // ApiKeyServiceUpdateAPIKeyProcedure is the fully-qualified name of the ApiKeyService's // UpdateAPIKey RPC. ApiKeyServiceUpdateAPIKeyProcedure = "/apikeys.ApiKeyService/UpdateAPIKey" // ApiKeyServiceListAPIKeysProcedure is the fully-qualified name of the ApiKeyService's ListAPIKeys // RPC. ApiKeyServiceListAPIKeysProcedure = "/apikeys.ApiKeyService/ListAPIKeys" // ApiKeyServiceDeleteAPIKeyProcedure is the fully-qualified name of the ApiKeyService's // DeleteAPIKey RPC. ApiKeyServiceDeleteAPIKeyProcedure = "/apikeys.ApiKeyService/DeleteAPIKey" // ApiKeyServiceExchangeKeyForTokenProcedure is the fully-qualified name of the ApiKeyService's // ExchangeKeyForToken RPC. ApiKeyServiceExchangeKeyForTokenProcedure = "/apikeys.ApiKeyService/ExchangeKeyForToken" )
These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.
Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.
const ( // Auth0SupportCreateUserProcedure is the fully-qualified name of the Auth0Support's CreateUser RPC. Auth0SupportCreateUserProcedure = "/auth0support.Auth0Support/CreateUser" // Auth0SupportKeepaliveSourcesProcedure is the fully-qualified name of the Auth0Support's // KeepaliveSources RPC. Auth0SupportKeepaliveSourcesProcedure = "/auth0support.Auth0Support/KeepaliveSources" )
These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.
Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.
const ( // BookmarksServiceListBookmarksProcedure is the fully-qualified name of the BookmarksService's // ListBookmarks RPC. BookmarksServiceListBookmarksProcedure = "/bookmarks.BookmarksService/ListBookmarks" // BookmarksServiceCreateBookmarkProcedure is the fully-qualified name of the BookmarksService's // CreateBookmark RPC. BookmarksServiceCreateBookmarkProcedure = "/bookmarks.BookmarksService/CreateBookmark" // BookmarksServiceGetBookmarkProcedure is the fully-qualified name of the BookmarksService's // GetBookmark RPC. BookmarksServiceGetBookmarkProcedure = "/bookmarks.BookmarksService/GetBookmark" // BookmarksServiceUpdateBookmarkProcedure is the fully-qualified name of the BookmarksService's // UpdateBookmark RPC. BookmarksServiceUpdateBookmarkProcedure = "/bookmarks.BookmarksService/UpdateBookmark" // BookmarksServiceDeleteBookmarkProcedure is the fully-qualified name of the BookmarksService's // DeleteBookmark RPC. BookmarksServiceDeleteBookmarkProcedure = "/bookmarks.BookmarksService/DeleteBookmark" // BookmarksServiceGetAffectedBookmarksProcedure is the fully-qualified name of the // BookmarksService's GetAffectedBookmarks RPC. BookmarksServiceGetAffectedBookmarksProcedure = "/bookmarks.BookmarksService/GetAffectedBookmarks" )
These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.
Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.
const ( // ChangesServiceListAppsProcedure is the fully-qualified name of the ChangesService's ListApps RPC. ChangesServiceListAppsProcedure = "/changes.ChangesService/ListApps" // ChangesServiceCreateAppProcedure is the fully-qualified name of the ChangesService's CreateApp // RPC. ChangesServiceCreateAppProcedure = "/changes.ChangesService/CreateApp" // ChangesServiceCreateSimpleAppProcedure is the fully-qualified name of the ChangesService's // CreateSimpleApp RPC. ChangesServiceCreateSimpleAppProcedure = "/changes.ChangesService/CreateSimpleApp" // ChangesServiceGetAppProcedure is the fully-qualified name of the ChangesService's GetApp RPC. ChangesServiceGetAppProcedure = "/changes.ChangesService/GetApp" // ChangesServiceUpdateAppProcedure is the fully-qualified name of the ChangesService's UpdateApp // RPC. ChangesServiceUpdateAppProcedure = "/changes.ChangesService/UpdateApp" // ChangesServiceDeleteAppProcedure is the fully-qualified name of the ChangesService's DeleteApp // RPC. ChangesServiceDeleteAppProcedure = "/changes.ChangesService/DeleteApp" // ChangesServiceListChangesProcedure is the fully-qualified name of the ChangesService's // ListChanges RPC. ChangesServiceListChangesProcedure = "/changes.ChangesService/ListChanges" // ChangesServiceListChangesByStatusProcedure is the fully-qualified name of the ChangesService's // ListChangesByStatus RPC. ChangesServiceListChangesByStatusProcedure = "/changes.ChangesService/ListChangesByStatus" // ChangesServiceCreateChangeProcedure is the fully-qualified name of the ChangesService's // CreateChange RPC. ChangesServiceCreateChangeProcedure = "/changes.ChangesService/CreateChange" // ChangesServiceGetChangeProcedure is the fully-qualified name of the ChangesService's GetChange // RPC. ChangesServiceGetChangeProcedure = "/changes.ChangesService/GetChange" // ChangesServiceGetChangeRisksProcedure is the fully-qualified name of the ChangesService's // GetChangeRisks RPC. ChangesServiceGetChangeRisksProcedure = "/changes.ChangesService/GetChangeRisks" // ChangesServiceGetChangeArchiveProcedure is the fully-qualified name of the ChangesService's // GetChangeArchive RPC. ChangesServiceGetChangeArchiveProcedure = "/changes.ChangesService/GetChangeArchive" // ChangesServiceUpdateChangeProcedure is the fully-qualified name of the ChangesService's // UpdateChange RPC. ChangesServiceUpdateChangeProcedure = "/changes.ChangesService/UpdateChange" // ChangesServiceDeleteChangeProcedure is the fully-qualified name of the ChangesService's // DeleteChange RPC. ChangesServiceDeleteChangeProcedure = "/changes.ChangesService/DeleteChange" // ChangesServiceGetChangeTimelineProcedure is the fully-qualified name of the ChangesService's // GetChangeTimeline RPC. ChangesServiceGetChangeTimelineProcedure = "/changes.ChangesService/GetChangeTimeline" // ChangesServiceRefreshStateProcedure is the fully-qualified name of the ChangesService's // RefreshState RPC. ChangesServiceRefreshStateProcedure = "/changes.ChangesService/RefreshState" // ChangesServiceCalculateBlastRadiusProcedure is the fully-qualified name of the ChangesService's // CalculateBlastRadius RPC. ChangesServiceCalculateBlastRadiusProcedure = "/changes.ChangesService/CalculateBlastRadius" // ChangesServiceStartChangeProcedure is the fully-qualified name of the ChangesService's // StartChange RPC. ChangesServiceStartChangeProcedure = "/changes.ChangesService/StartChange" // ChangesServiceEndChangeProcedure is the fully-qualified name of the ChangesService's EndChange // RPC. ChangesServiceEndChangeProcedure = "/changes.ChangesService/EndChange" // ChangesServiceSimulateChangeProcedure is the fully-qualified name of the ChangesService's // SimulateChange RPC. ChangesServiceSimulateChangeProcedure = "/changes.ChangesService/SimulateChange" // ChangesServiceGetOnboardingProcedure is the fully-qualified name of the ChangesService's // GetOnboarding RPC. ChangesServiceGetOnboardingProcedure = "/changes.ChangesService/GetOnboarding" // ChangesServiceUpdateOnboardingProcedure is the fully-qualified name of the ChangesService's // UpdateOnboarding RPC. ChangesServiceUpdateOnboardingProcedure = "/changes.ChangesService/UpdateOnboarding" // ChangesServiceListHomeAppsProcedure is the fully-qualified name of the ChangesService's // ListHomeApps RPC. ChangesServiceListHomeAppsProcedure = "/changes.ChangesService/ListHomeApps" // ChangesServiceListHomeChangesProcedure is the fully-qualified name of the ChangesService's // ListHomeChanges RPC. ChangesServiceListHomeChangesProcedure = "/changes.ChangesService/ListHomeChanges" // ChangesServiceGetAppSummaryProcedure is the fully-qualified name of the ChangesService's // GetAppSummary RPC. ChangesServiceGetAppSummaryProcedure = "/changes.ChangesService/GetAppSummary" // ChangesServiceGetAppSummariesProcedure is the fully-qualified name of the ChangesService's // GetAppSummaries RPC. ChangesServiceGetAppSummariesProcedure = "/changes.ChangesService/GetAppSummaries" // ChangesServiceListAppChangesProcedure is the fully-qualified name of the ChangesService's // ListAppChanges RPC. ChangesServiceListAppChangesProcedure = "/changes.ChangesService/ListAppChanges" // ChangesServiceListAppChangesSummaryProcedure is the fully-qualified name of the ChangesService's // ListAppChangesSummary RPC. ChangesServiceListAppChangesSummaryProcedure = "/changes.ChangesService/ListAppChangesSummary" // ChangesServiceUpdateChangingItemsProcedure is the fully-qualified name of the ChangesService's // UpdateChangingItems RPC. ChangesServiceUpdateChangingItemsProcedure = "/changes.ChangesService/UpdateChangingItems" // ChangesServiceUpdatePlannedChangesProcedure is the fully-qualified name of the ChangesService's // UpdatePlannedChanges RPC. ChangesServiceUpdatePlannedChangesProcedure = "/changes.ChangesService/UpdatePlannedChanges" // ChangesServiceGetAffectedAppsProcedure is the fully-qualified name of the ChangesService's // GetAffectedApps RPC. ChangesServiceGetAffectedAppsProcedure = "/changes.ChangesService/GetAffectedApps" // ChangesServiceListChangingItemsSummaryProcedure is the fully-qualified name of the // ChangesService's ListChangingItemsSummary RPC. ChangesServiceListChangingItemsSummaryProcedure = "/changes.ChangesService/ListChangingItemsSummary" // ChangesServiceGetDiffProcedure is the fully-qualified name of the ChangesService's GetDiff RPC. ChangesServiceGetDiffProcedure = "/changes.ChangesService/GetDiff" )
These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.
Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.
const ( // ConfigServiceGetConfigProcedure is the fully-qualified name of the ConfigService's GetConfig RPC. ConfigServiceGetConfigProcedure = "/cli.ConfigService/GetConfig" // ConfigServiceSetConfigProcedure is the fully-qualified name of the ConfigService's SetConfig RPC. ConfigServiceSetConfigProcedure = "/cli.ConfigService/SetConfig" )
These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.
Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.
const ( // InviteServiceCreateInviteProcedure is the fully-qualified name of the InviteService's // CreateInvite RPC. InviteServiceCreateInviteProcedure = "/invites.InviteService/CreateInvite" // InviteServiceListInvitesProcedure is the fully-qualified name of the InviteService's ListInvites // RPC. InviteServiceListInvitesProcedure = "/invites.InviteService/ListInvites" // InviteServiceRevokeInviteProcedure is the fully-qualified name of the InviteService's // RevokeInvite RPC. InviteServiceRevokeInviteProcedure = "/invites.InviteService/RevokeInvite" // InviteServiceResendInviteProcedure is the fully-qualified name of the InviteService's // ResendInvite RPC. InviteServiceResendInviteProcedure = "/invites.InviteService/ResendInvite" )
These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.
Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.
const ( // RevlinkServiceGetReverseLinksProcedure is the fully-qualified name of the RevlinkService's // GetReverseLinks RPC. RevlinkServiceGetReverseLinksProcedure = "/revlink.RevlinkService/GetReverseLinks" // RevlinkServiceIngestGatewayResponsesProcedure is the fully-qualified name of the RevlinkService's // IngestGatewayResponses RPC. RevlinkServiceIngestGatewayResponsesProcedure = "/revlink.RevlinkService/IngestGatewayResponses" )
These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.
Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.
const ( // SnapshotsServiceListSnapshotsProcedure is the fully-qualified name of the SnapshotsService's // ListSnapshots RPC. SnapshotsServiceListSnapshotsProcedure = "/snapshots.SnapshotsService/ListSnapshots" // SnapshotsServiceCreateSnapshotProcedure is the fully-qualified name of the SnapshotsService's // CreateSnapshot RPC. SnapshotsServiceCreateSnapshotProcedure = "/snapshots.SnapshotsService/CreateSnapshot" // SnapshotsServiceGetSnapshotProcedure is the fully-qualified name of the SnapshotsService's // GetSnapshot RPC. SnapshotsServiceGetSnapshotProcedure = "/snapshots.SnapshotsService/GetSnapshot" // SnapshotsServiceUpdateSnapshotProcedure is the fully-qualified name of the SnapshotsService's // UpdateSnapshot RPC. SnapshotsServiceUpdateSnapshotProcedure = "/snapshots.SnapshotsService/UpdateSnapshot" // SnapshotsServiceDeleteSnapshotProcedure is the fully-qualified name of the SnapshotsService's // DeleteSnapshot RPC. SnapshotsServiceDeleteSnapshotProcedure = "/snapshots.SnapshotsService/DeleteSnapshot" // SnapshotsServiceGetInitialDataProcedure is the fully-qualified name of the SnapshotsService's // GetInitialData RPC. SnapshotsServiceGetInitialDataProcedure = "/snapshots.SnapshotsService/GetInitialData" )
These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.
Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.
const (
// ApiKeyServiceName is the fully-qualified name of the ApiKeyService service.
ApiKeyServiceName = "apikeys.ApiKeyService"
)
const (
// Auth0SupportName is the fully-qualified name of the Auth0Support service.
Auth0SupportName = "auth0support.Auth0Support"
)
const (
// BookmarksServiceName is the fully-qualified name of the BookmarksService service.
BookmarksServiceName = "bookmarks.BookmarksService"
)
const (
// ChangesServiceName is the fully-qualified name of the ChangesService service.
ChangesServiceName = "changes.ChangesService"
)
const (
// ConfigServiceName is the fully-qualified name of the ConfigService service.
ConfigServiceName = "cli.ConfigService"
)
const (
// InviteServiceName is the fully-qualified name of the InviteService service.
InviteServiceName = "invites.InviteService"
)
const (
// RevlinkServiceName is the fully-qualified name of the RevlinkService service.
RevlinkServiceName = "revlink.RevlinkService"
)
const (
// SnapshotsServiceName is the fully-qualified name of the SnapshotsService service.
SnapshotsServiceName = "snapshots.SnapshotsService"
)
Variables ¶
This section is empty.
Functions ¶
func NewAdminServiceHandler ¶ added in v0.29.0
func NewAdminServiceHandler(svc AdminServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
NewAdminServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.
By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.
func NewApiKeyServiceHandler ¶ added in v0.34.3
func NewApiKeyServiceHandler(svc ApiKeyServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
NewApiKeyServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.
By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.
func NewAuth0SupportHandler ¶ added in v0.50.0
func NewAuth0SupportHandler(svc Auth0SupportHandler, opts ...connect.HandlerOption) (string, http.Handler)
NewAuth0SupportHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.
By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.
func NewBookmarksServiceHandler ¶ added in v0.24.0
func NewBookmarksServiceHandler(svc BookmarksServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
NewBookmarksServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.
By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.
func NewChangesServiceHandler ¶ added in v0.23.0
func NewChangesServiceHandler(svc ChangesServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
NewChangesServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.
By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.
func NewConfigServiceHandler ¶ added in v0.68.1
func NewConfigServiceHandler(svc ConfigServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
NewConfigServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.
By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.
func NewInviteServiceHandler ¶ added in v0.50.0
func NewInviteServiceHandler(svc InviteServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
NewInviteServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.
By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.
func NewKeepaliveSourcesInterceptor ¶ added in v0.61.0
func NewKeepaliveSourcesInterceptor(managementClient ManagementServiceClient) connect.Interceptor
Create a new interceptor that will ensure that sources are alive on all requests. This interceptor will call `KeepaliveSources` on the management service to ensure that the sources are alive. This will be done in a goroutine so that the request is not blocked. If the management service is not set, then this interceptor will do nothing.
For services that actually require the sources to be alive, they can use the WaitForSources function to wait for the sources to be ready. This function will block until the sources are ready.
func NewManagementServiceHandler ¶ added in v0.29.0
func NewManagementServiceHandler(svc ManagementServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
NewManagementServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.
By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.
func NewRevlinkServiceHandler ¶ added in v0.52.0
func NewRevlinkServiceHandler(svc RevlinkServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
NewRevlinkServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.
By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.
func NewSnapshotsServiceHandler ¶ added in v0.24.0
func NewSnapshotsServiceHandler(svc SnapshotsServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
NewSnapshotsServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.
By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.
func WaitForSources ¶ added in v0.61.0
WaitForSources will wait for the sources to be ready after they have been woken up by the `KeepaliveSourcesInterceptor`. If this context was create without the interceptor, then this function will return immediately. If the waking of the sources returns an error it will be returned via this function
Types ¶
type AdminServiceClient ¶ added in v0.29.0
type AdminServiceClient interface { // Lists the details of all NATS Accounts ListAccounts(context.Context, *connect.Request[sdp_go.ListAccountsRequest]) (*connect.Response[sdp_go.ListAccountsResponse], error) // Creates a new account, public_nkey will be autogenerated CreateAccount(context.Context, *connect.Request[sdp_go.CreateAccountRequest]) (*connect.Response[sdp_go.CreateAccountResponse], error) // Get the details of a given account GetAccount(context.Context, *connect.Request[sdp_go.AdminGetAccountRequest]) (*connect.Response[sdp_go.GetAccountResponse], error) // Deletes an account DeleteAccount(context.Context, *connect.Request[sdp_go.DeleteAccountRequest]) (*connect.Response[sdp_go.DeleteAccountResponse], error) // Lists all sources within the closen account ListSources(context.Context, *connect.Request[sdp_go.AdminListSourcesRequest]) (*connect.Response[sdp_go.ListSourcesResponse], error) // Creates a new source within the closen account CreateSource(context.Context, *connect.Request[sdp_go.AdminCreateSourceRequest]) (*connect.Response[sdp_go.CreateSourceResponse], error) // Get the details of a source within the closen account GetSource(context.Context, *connect.Request[sdp_go.AdminGetSourceRequest]) (*connect.Response[sdp_go.GetSourceResponse], error) // Update the details of a source within the closen account UpdateSource(context.Context, *connect.Request[sdp_go.AdminUpdateSourceRequest]) (*connect.Response[sdp_go.UpdateSourceResponse], error) // Deletes a source from a closen account DeleteSource(context.Context, *connect.Request[sdp_go.AdminDeleteSourceRequest]) (*connect.Response[sdp_go.DeleteSourceResponse], error) // Updates sources to keep them running in the background. This can be used // to add explicit action, when the built-in keepalives are not sufficient. KeepaliveSources(context.Context, *connect.Request[sdp_go.AdminKeepaliveSourcesRequest]) (*connect.Response[sdp_go.KeepaliveSourcesResponse], error) // Create a new NATS token for a given public NKey. The user requesting must // control the associated private key also in order to connect to NATS as // the token is not enough on its own CreateToken(context.Context, *connect.Request[sdp_go.AdminCreateTokenRequest]) (*connect.Response[sdp_go.CreateTokenResponse], error) }
AdminServiceClient is a client for the account.AdminService service.
func NewAdminServiceClient ¶ added in v0.29.0
func NewAdminServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) AdminServiceClient
NewAdminServiceClient constructs a client for the account.AdminService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.
The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).
type AdminServiceHandler ¶ added in v0.29.0
type AdminServiceHandler interface { // Lists the details of all NATS Accounts ListAccounts(context.Context, *connect.Request[sdp_go.ListAccountsRequest]) (*connect.Response[sdp_go.ListAccountsResponse], error) // Creates a new account, public_nkey will be autogenerated CreateAccount(context.Context, *connect.Request[sdp_go.CreateAccountRequest]) (*connect.Response[sdp_go.CreateAccountResponse], error) // Get the details of a given account GetAccount(context.Context, *connect.Request[sdp_go.AdminGetAccountRequest]) (*connect.Response[sdp_go.GetAccountResponse], error) // Deletes an account DeleteAccount(context.Context, *connect.Request[sdp_go.DeleteAccountRequest]) (*connect.Response[sdp_go.DeleteAccountResponse], error) // Lists all sources within the closen account ListSources(context.Context, *connect.Request[sdp_go.AdminListSourcesRequest]) (*connect.Response[sdp_go.ListSourcesResponse], error) // Creates a new source within the closen account CreateSource(context.Context, *connect.Request[sdp_go.AdminCreateSourceRequest]) (*connect.Response[sdp_go.CreateSourceResponse], error) // Get the details of a source within the closen account GetSource(context.Context, *connect.Request[sdp_go.AdminGetSourceRequest]) (*connect.Response[sdp_go.GetSourceResponse], error) // Update the details of a source within the closen account UpdateSource(context.Context, *connect.Request[sdp_go.AdminUpdateSourceRequest]) (*connect.Response[sdp_go.UpdateSourceResponse], error) // Deletes a source from a closen account DeleteSource(context.Context, *connect.Request[sdp_go.AdminDeleteSourceRequest]) (*connect.Response[sdp_go.DeleteSourceResponse], error) // Updates sources to keep them running in the background. This can be used // to add explicit action, when the built-in keepalives are not sufficient. KeepaliveSources(context.Context, *connect.Request[sdp_go.AdminKeepaliveSourcesRequest]) (*connect.Response[sdp_go.KeepaliveSourcesResponse], error) // Create a new NATS token for a given public NKey. The user requesting must // control the associated private key also in order to connect to NATS as // the token is not enough on its own CreateToken(context.Context, *connect.Request[sdp_go.AdminCreateTokenRequest]) (*connect.Response[sdp_go.CreateTokenResponse], error) }
AdminServiceHandler is an implementation of the account.AdminService service.
type ApiKeyServiceClient ¶ added in v0.34.3
type ApiKeyServiceClient interface { // Creates an API key, pending access token generation from Auth0. The key // cannot be used until the user has been redirected to the given URL which // allows Auth0 to actually generate an access token CreateAPIKey(context.Context, *connect.Request[sdp_go.CreateAPIKeyRequest]) (*connect.Response[sdp_go.CreateAPIKeyResponse], error) GetAPIKey(context.Context, *connect.Request[sdp_go.GetAPIKeyRequest]) (*connect.Response[sdp_go.GetAPIKeyResponse], error) UpdateAPIKey(context.Context, *connect.Request[sdp_go.UpdateAPIKeyRequest]) (*connect.Response[sdp_go.UpdateAPIKeyResponse], error) ListAPIKeys(context.Context, *connect.Request[sdp_go.ListAPIKeysRequest]) (*connect.Response[sdp_go.ListAPIKeysResponse], error) DeleteAPIKey(context.Context, *connect.Request[sdp_go.DeleteAPIKeyRequest]) (*connect.Response[sdp_go.DeleteAPIKeyResponse], error) // Exchanges an Overmind API key for an Oauth access token. That token can // then be used to access all other Overmind APIs ExchangeKeyForToken(context.Context, *connect.Request[sdp_go.ExchangeKeyForTokenRequest]) (*connect.Response[sdp_go.ExchangeKeyForTokenResponse], error) }
ApiKeyServiceClient is a client for the apikeys.ApiKeyService service.
func NewApiKeyServiceClient ¶ added in v0.34.3
func NewApiKeyServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ApiKeyServiceClient
NewApiKeyServiceClient constructs a client for the apikeys.ApiKeyService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.
The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).
type ApiKeyServiceHandler ¶ added in v0.34.3
type ApiKeyServiceHandler interface { // Creates an API key, pending access token generation from Auth0. The key // cannot be used until the user has been redirected to the given URL which // allows Auth0 to actually generate an access token CreateAPIKey(context.Context, *connect.Request[sdp_go.CreateAPIKeyRequest]) (*connect.Response[sdp_go.CreateAPIKeyResponse], error) GetAPIKey(context.Context, *connect.Request[sdp_go.GetAPIKeyRequest]) (*connect.Response[sdp_go.GetAPIKeyResponse], error) UpdateAPIKey(context.Context, *connect.Request[sdp_go.UpdateAPIKeyRequest]) (*connect.Response[sdp_go.UpdateAPIKeyResponse], error) ListAPIKeys(context.Context, *connect.Request[sdp_go.ListAPIKeysRequest]) (*connect.Response[sdp_go.ListAPIKeysResponse], error) DeleteAPIKey(context.Context, *connect.Request[sdp_go.DeleteAPIKeyRequest]) (*connect.Response[sdp_go.DeleteAPIKeyResponse], error) // Exchanges an Overmind API key for an Oauth access token. That token can // then be used to access all other Overmind APIs ExchangeKeyForToken(context.Context, *connect.Request[sdp_go.ExchangeKeyForTokenRequest]) (*connect.Response[sdp_go.ExchangeKeyForTokenResponse], error) }
ApiKeyServiceHandler is an implementation of the apikeys.ApiKeyService service.
type Auth0SupportClient ¶ added in v0.50.0
type Auth0SupportClient interface { // create a new user on first login CreateUser(context.Context, *connect.Request[sdp_go.Auth0CreateUserRequest]) (*connect.Response[sdp_go.Auth0CreateUserResponse], error) // Updates sources to keep them running in the background. This is called on // login by auth0 to give us a chance to boot up sources while the app is // loading. KeepaliveSources(context.Context, *connect.Request[sdp_go.AdminKeepaliveSourcesRequest]) (*connect.Response[sdp_go.KeepaliveSourcesResponse], error) }
Auth0SupportClient is a client for the auth0support.Auth0Support service.
func NewAuth0SupportClient ¶ added in v0.50.0
func NewAuth0SupportClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) Auth0SupportClient
NewAuth0SupportClient constructs a client for the auth0support.Auth0Support service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.
The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).
type Auth0SupportHandler ¶ added in v0.50.0
type Auth0SupportHandler interface { // create a new user on first login CreateUser(context.Context, *connect.Request[sdp_go.Auth0CreateUserRequest]) (*connect.Response[sdp_go.Auth0CreateUserResponse], error) // Updates sources to keep them running in the background. This is called on // login by auth0 to give us a chance to boot up sources while the app is // loading. KeepaliveSources(context.Context, *connect.Request[sdp_go.AdminKeepaliveSourcesRequest]) (*connect.Response[sdp_go.KeepaliveSourcesResponse], error) }
Auth0SupportHandler is an implementation of the auth0support.Auth0Support service.
type BookmarksServiceClient ¶ added in v0.24.0
type BookmarksServiceClient interface { // ListBookmarks returns all bookmarks of the current user. note that this does not include the actual bookmark data, use GetBookmark for that ListBookmarks(context.Context, *connect.Request[sdp_go.ListBookmarksRequest]) (*connect.Response[sdp_go.ListBookmarkResponse], error) // CreateBookmark creates a new bookmark CreateBookmark(context.Context, *connect.Request[sdp_go.CreateBookmarkRequest]) (*connect.Response[sdp_go.CreateBookmarkResponse], error) // GetBookmark returns the bookmark with the given UUID. This can also return snapshots as bookmarks and will strip the stored items from the response. GetBookmark(context.Context, *connect.Request[sdp_go.GetBookmarkRequest]) (*connect.Response[sdp_go.GetBookmarkResponse], error) UpdateBookmark(context.Context, *connect.Request[sdp_go.UpdateBookmarkRequest]) (*connect.Response[sdp_go.UpdateBookmarkResponse], error) DeleteBookmark(context.Context, *connect.Request[sdp_go.DeleteBookmarkRequest]) (*connect.Response[sdp_go.DeleteBookmarkResponse], error) // a helper method to find all affected apps for a given blast radius snapshot GetAffectedBookmarks(context.Context, *connect.Request[sdp_go.GetAffectedBookmarksRequest]) (*connect.Response[sdp_go.GetAffectedBookmarksResponse], error) }
BookmarksServiceClient is a client for the bookmarks.BookmarksService service.
func NewBookmarksServiceClient ¶ added in v0.24.0
func NewBookmarksServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) BookmarksServiceClient
NewBookmarksServiceClient constructs a client for the bookmarks.BookmarksService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.
The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).
type BookmarksServiceHandler ¶ added in v0.24.0
type BookmarksServiceHandler interface { // ListBookmarks returns all bookmarks of the current user. note that this does not include the actual bookmark data, use GetBookmark for that ListBookmarks(context.Context, *connect.Request[sdp_go.ListBookmarksRequest]) (*connect.Response[sdp_go.ListBookmarkResponse], error) // CreateBookmark creates a new bookmark CreateBookmark(context.Context, *connect.Request[sdp_go.CreateBookmarkRequest]) (*connect.Response[sdp_go.CreateBookmarkResponse], error) // GetBookmark returns the bookmark with the given UUID. This can also return snapshots as bookmarks and will strip the stored items from the response. GetBookmark(context.Context, *connect.Request[sdp_go.GetBookmarkRequest]) (*connect.Response[sdp_go.GetBookmarkResponse], error) UpdateBookmark(context.Context, *connect.Request[sdp_go.UpdateBookmarkRequest]) (*connect.Response[sdp_go.UpdateBookmarkResponse], error) DeleteBookmark(context.Context, *connect.Request[sdp_go.DeleteBookmarkRequest]) (*connect.Response[sdp_go.DeleteBookmarkResponse], error) // a helper method to find all affected apps for a given blast radius snapshot GetAffectedBookmarks(context.Context, *connect.Request[sdp_go.GetAffectedBookmarksRequest]) (*connect.Response[sdp_go.GetAffectedBookmarksResponse], error) }
BookmarksServiceHandler is an implementation of the bookmarks.BookmarksService service.
type ChangesServiceClient ¶ added in v0.23.0
type ChangesServiceClient interface { // Lists all apps ListApps(context.Context, *connect.Request[sdp_go.ListAppsRequest]) (*connect.Response[sdp_go.ListAppsResponse], error) // Creates a new app CreateApp(context.Context, *connect.Request[sdp_go.CreateAppRequest]) (*connect.Response[sdp_go.CreateAppResponse], error) // Creates an app using just a URL as input. This automatically creates and // sets the bookmark UUID, along with the url for display in the GUI CreateSimpleApp(context.Context, *connect.Request[sdp_go.CreateSimpleAppRequest]) (*connect.Response[sdp_go.CreateSimpleAppResponse], error) // Gets the details of an existing app GetApp(context.Context, *connect.Request[sdp_go.GetAppRequest]) (*connect.Response[sdp_go.GetAppResponse], error) // Updates an existing app UpdateApp(context.Context, *connect.Request[sdp_go.UpdateAppRequest]) (*connect.Response[sdp_go.UpdateAppResponse], error) // Deletes an app DeleteApp(context.Context, *connect.Request[sdp_go.DeleteAppRequest]) (*connect.Response[sdp_go.DeleteAppResponse], error) // Lists all changes ListChanges(context.Context, *connect.Request[sdp_go.ListChangesRequest]) (*connect.Response[sdp_go.ListChangesResponse], error) // list all changes in a specific status ListChangesByStatus(context.Context, *connect.Request[sdp_go.ListChangesByStatusRequest]) (*connect.Response[sdp_go.ListChangesByStatusResponse], error) // Creates a new change CreateChange(context.Context, *connect.Request[sdp_go.CreateChangeRequest]) (*connect.Response[sdp_go.CreateChangeResponse], error) // Gets the details of an existing change GetChange(context.Context, *connect.Request[sdp_go.GetChangeRequest]) (*connect.Response[sdp_go.GetChangeResponse], error) // Gets the risks and risk calculation status of an existing change GetChangeRisks(context.Context, *connect.Request[sdp_go.GetChangeRisksRequest]) (*connect.Response[sdp_go.GetChangeRisksResponse], error) // Gets the all data of an existing change for archival GetChangeArchive(context.Context, *connect.Request[sdp_go.GetChangeArchiveRequest]) (*connect.Response[sdp_go.GetChangeArchiveResponse], error) // Updates an existing change UpdateChange(context.Context, *connect.Request[sdp_go.UpdateChangeRequest]) (*connect.Response[sdp_go.UpdateChangeResponse], error) // Deletes a change DeleteChange(context.Context, *connect.Request[sdp_go.DeleteChangeRequest]) (*connect.Response[sdp_go.DeleteChangeResponse], error) // Get the timeline of changes for a given change GetChangeTimeline(context.Context, *connect.Request[sdp_go.GetChangeTimelineRequest]) (*connect.Response[sdp_go.GetChangeTimelineResponse], error) // Ask the gateway to refresh all internal caches and status slots // The RPC will return immediately doing all processing in the background RefreshState(context.Context, *connect.Request[sdp_go.RefreshStateRequest]) (*connect.Response[sdp_go.RefreshStateResponse], error) // Calculates the blast radius of a change using the // `changingItemsBookmarkUUID` as the starting point. If the // `changingItemsBookmarkUUID` is blank, this will return an error. // Returns a stream of status updates. The response stream closes when all calculating has been done. // Executing this RPC will move the Change to the `STATUS_DEFINING` state or return an error. CalculateBlastRadius(context.Context, *connect.Request[sdp_go.CalculateBlastRadiusRequest]) (*connect.ServerStreamForClient[sdp_go.CalculateBlastRadiusResponse], error) // Executing this RPC take a snapshot of the current blast radius and store it // in `systemBeforeSnapshotUUID` and then advance the status to // `STATUS_HAPPENING`. It can only be called once per change. StartChange(context.Context, *connect.Request[sdp_go.StartChangeRequest]) (*connect.ServerStreamForClient[sdp_go.StartChangeResponse], error) // Takes the "after" snapshot, stores it in `systemAfterSnapshotUUID`, calculates // the change diff and stores it as a list of DiffedItems and // advances the change status to `STATUS_DONE` EndChange(context.Context, *connect.Request[sdp_go.EndChangeRequest]) (*connect.ServerStreamForClient[sdp_go.EndChangeResponse], error) // Simulates a change without the user actually having to do anything. The // change specified in the request should be in the `STATUS_DEFINING` state. // It will be moved to the `STATUS_DONE` state after the simulation is // complete. SimulateChange(context.Context, *connect.Request[sdp_go.SimulateChangeRequest]) (*connect.ServerStreamForClient[sdp_go.SimulateChangeResponse], error) GetOnboarding(context.Context, *connect.Request[sdp_go.GetOnboardingRequest]) (*connect.Response[sdp_go.GetOnboardingResponse], error) UpdateOnboarding(context.Context, *connect.Request[sdp_go.UpdateOnboardingRequest]) (*connect.Response[sdp_go.UpdateOnboardingResponse], error) // Lists all apps, designed for use in the apps home page ListHomeApps(context.Context, *connect.Request[sdp_go.ListHomeAppsRequest]) (*connect.Response[sdp_go.ListHomeAppsResponse], error) // Lists all changes, designed for use in the changes home page ListHomeChanges(context.Context, *connect.Request[sdp_go.ListHomeChangesRequest]) (*connect.Response[sdp_go.ListHomeChangesResponse], error) // Gets a summary of an app, used when a user clicks on a given app GetAppSummary(context.Context, *connect.Request[sdp_go.GetAppSummaryRequest]) (*connect.Response[sdp_go.GetAppSummaryResponse], error) // Gets a summaries of a list of apps GetAppSummaries(context.Context, *connect.Request[sdp_go.GetAppSummariesRequest]) (*connect.Response[sdp_go.GetAppSummariesResponse], error) // Lists all changes affecting an app ListAppChanges(context.Context, *connect.Request[sdp_go.ListAppChangesRequest]) (*connect.Response[sdp_go.ListAppChangesResponse], error) // Lists all changes affecting an app, returning only a summary of each change // rather than the full details ListAppChangesSummary(context.Context, *connect.Request[sdp_go.ListAppChangesSummaryRequest]) (*connect.Response[sdp_go.ListAppChangesSummaryResponse], error) // This sets the items that are changing in a given change, and updates the // blast radius. In the backend this will convert the references to GET // requests, save them to a bookmark, and set this as the // changingItemsBookmarkUUID in the change itself before triggering a blast // radius calculation UpdateChangingItems(context.Context, *connect.Request[sdp_go.UpdateChangingItemsRequest]) (*connect.ServerStreamForClient[sdp_go.CalculateBlastRadiusResponse], error) // This sets the item diffs that are changing in a given change, and updates // the blast radius. In the backend this will save the item diffs for later // display and use the item's references to fabricate a bookmark, and set this // as changingItemsBookmarkUUID in the change itself before triggering a blast // radius calculation. Note that not all of the changing items have to exist // in our current sources. UpdatePlannedChanges(context.Context, *connect.Request[sdp_go.UpdatePlannedChangesRequest]) (*connect.ServerStreamForClient[sdp_go.CalculateBlastRadiusResponse], error) // Returns a list of apps that are affected by this change. This is calculated // by looking at the blast radius snapshot and finding all apps that have // items in the snapshot. GetAffectedApps(context.Context, *connect.Request[sdp_go.GetAffectedAppsRequest]) (*connect.Response[sdp_go.GetAffectedAppsResponse], error) // Gets the diff summary for all items that were planned to change as part of // this change. This includes the high level details of the item, and the // status (e.g. changed, deleted) but not the diff itself ListChangingItemsSummary(context.Context, *connect.Request[sdp_go.ListChangingItemsSummaryRequest]) (*connect.Response[sdp_go.ListChangingItemsSummaryResponse], error) // Gets the full diff of everything that changed as part of this "change". // This includes all items and also edges between them GetDiff(context.Context, *connect.Request[sdp_go.GetDiffRequest]) (*connect.Response[sdp_go.GetDiffResponse], error) }
ChangesServiceClient is a client for the changes.ChangesService service.
func NewChangesServiceClient ¶ added in v0.23.0
func NewChangesServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ChangesServiceClient
NewChangesServiceClient constructs a client for the changes.ChangesService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.
The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).
type ChangesServiceHandler ¶ added in v0.23.0
type ChangesServiceHandler interface { // Lists all apps ListApps(context.Context, *connect.Request[sdp_go.ListAppsRequest]) (*connect.Response[sdp_go.ListAppsResponse], error) // Creates a new app CreateApp(context.Context, *connect.Request[sdp_go.CreateAppRequest]) (*connect.Response[sdp_go.CreateAppResponse], error) // Creates an app using just a URL as input. This automatically creates and // sets the bookmark UUID, along with the url for display in the GUI CreateSimpleApp(context.Context, *connect.Request[sdp_go.CreateSimpleAppRequest]) (*connect.Response[sdp_go.CreateSimpleAppResponse], error) // Gets the details of an existing app GetApp(context.Context, *connect.Request[sdp_go.GetAppRequest]) (*connect.Response[sdp_go.GetAppResponse], error) // Updates an existing app UpdateApp(context.Context, *connect.Request[sdp_go.UpdateAppRequest]) (*connect.Response[sdp_go.UpdateAppResponse], error) // Deletes an app DeleteApp(context.Context, *connect.Request[sdp_go.DeleteAppRequest]) (*connect.Response[sdp_go.DeleteAppResponse], error) // Lists all changes ListChanges(context.Context, *connect.Request[sdp_go.ListChangesRequest]) (*connect.Response[sdp_go.ListChangesResponse], error) // list all changes in a specific status ListChangesByStatus(context.Context, *connect.Request[sdp_go.ListChangesByStatusRequest]) (*connect.Response[sdp_go.ListChangesByStatusResponse], error) // Creates a new change CreateChange(context.Context, *connect.Request[sdp_go.CreateChangeRequest]) (*connect.Response[sdp_go.CreateChangeResponse], error) // Gets the details of an existing change GetChange(context.Context, *connect.Request[sdp_go.GetChangeRequest]) (*connect.Response[sdp_go.GetChangeResponse], error) // Gets the risks and risk calculation status of an existing change GetChangeRisks(context.Context, *connect.Request[sdp_go.GetChangeRisksRequest]) (*connect.Response[sdp_go.GetChangeRisksResponse], error) // Gets the all data of an existing change for archival GetChangeArchive(context.Context, *connect.Request[sdp_go.GetChangeArchiveRequest]) (*connect.Response[sdp_go.GetChangeArchiveResponse], error) // Updates an existing change UpdateChange(context.Context, *connect.Request[sdp_go.UpdateChangeRequest]) (*connect.Response[sdp_go.UpdateChangeResponse], error) // Deletes a change DeleteChange(context.Context, *connect.Request[sdp_go.DeleteChangeRequest]) (*connect.Response[sdp_go.DeleteChangeResponse], error) // Get the timeline of changes for a given change GetChangeTimeline(context.Context, *connect.Request[sdp_go.GetChangeTimelineRequest]) (*connect.Response[sdp_go.GetChangeTimelineResponse], error) // Ask the gateway to refresh all internal caches and status slots // The RPC will return immediately doing all processing in the background RefreshState(context.Context, *connect.Request[sdp_go.RefreshStateRequest]) (*connect.Response[sdp_go.RefreshStateResponse], error) // Calculates the blast radius of a change using the // `changingItemsBookmarkUUID` as the starting point. If the // `changingItemsBookmarkUUID` is blank, this will return an error. // Returns a stream of status updates. The response stream closes when all calculating has been done. // Executing this RPC will move the Change to the `STATUS_DEFINING` state or return an error. CalculateBlastRadius(context.Context, *connect.Request[sdp_go.CalculateBlastRadiusRequest], *connect.ServerStream[sdp_go.CalculateBlastRadiusResponse]) error // Executing this RPC take a snapshot of the current blast radius and store it // in `systemBeforeSnapshotUUID` and then advance the status to // `STATUS_HAPPENING`. It can only be called once per change. StartChange(context.Context, *connect.Request[sdp_go.StartChangeRequest], *connect.ServerStream[sdp_go.StartChangeResponse]) error // Takes the "after" snapshot, stores it in `systemAfterSnapshotUUID`, calculates // the change diff and stores it as a list of DiffedItems and // advances the change status to `STATUS_DONE` EndChange(context.Context, *connect.Request[sdp_go.EndChangeRequest], *connect.ServerStream[sdp_go.EndChangeResponse]) error // Simulates a change without the user actually having to do anything. The // change specified in the request should be in the `STATUS_DEFINING` state. // It will be moved to the `STATUS_DONE` state after the simulation is // complete. SimulateChange(context.Context, *connect.Request[sdp_go.SimulateChangeRequest], *connect.ServerStream[sdp_go.SimulateChangeResponse]) error GetOnboarding(context.Context, *connect.Request[sdp_go.GetOnboardingRequest]) (*connect.Response[sdp_go.GetOnboardingResponse], error) UpdateOnboarding(context.Context, *connect.Request[sdp_go.UpdateOnboardingRequest]) (*connect.Response[sdp_go.UpdateOnboardingResponse], error) // Lists all apps, designed for use in the apps home page ListHomeApps(context.Context, *connect.Request[sdp_go.ListHomeAppsRequest]) (*connect.Response[sdp_go.ListHomeAppsResponse], error) // Lists all changes, designed for use in the changes home page ListHomeChanges(context.Context, *connect.Request[sdp_go.ListHomeChangesRequest]) (*connect.Response[sdp_go.ListHomeChangesResponse], error) // Gets a summary of an app, used when a user clicks on a given app GetAppSummary(context.Context, *connect.Request[sdp_go.GetAppSummaryRequest]) (*connect.Response[sdp_go.GetAppSummaryResponse], error) // Gets a summaries of a list of apps GetAppSummaries(context.Context, *connect.Request[sdp_go.GetAppSummariesRequest]) (*connect.Response[sdp_go.GetAppSummariesResponse], error) // Lists all changes affecting an app ListAppChanges(context.Context, *connect.Request[sdp_go.ListAppChangesRequest]) (*connect.Response[sdp_go.ListAppChangesResponse], error) // Lists all changes affecting an app, returning only a summary of each change // rather than the full details ListAppChangesSummary(context.Context, *connect.Request[sdp_go.ListAppChangesSummaryRequest]) (*connect.Response[sdp_go.ListAppChangesSummaryResponse], error) // This sets the items that are changing in a given change, and updates the // blast radius. In the backend this will convert the references to GET // requests, save them to a bookmark, and set this as the // changingItemsBookmarkUUID in the change itself before triggering a blast // radius calculation UpdateChangingItems(context.Context, *connect.Request[sdp_go.UpdateChangingItemsRequest], *connect.ServerStream[sdp_go.CalculateBlastRadiusResponse]) error // This sets the item diffs that are changing in a given change, and updates // the blast radius. In the backend this will save the item diffs for later // display and use the item's references to fabricate a bookmark, and set this // as changingItemsBookmarkUUID in the change itself before triggering a blast // radius calculation. Note that not all of the changing items have to exist // in our current sources. UpdatePlannedChanges(context.Context, *connect.Request[sdp_go.UpdatePlannedChangesRequest], *connect.ServerStream[sdp_go.CalculateBlastRadiusResponse]) error // Returns a list of apps that are affected by this change. This is calculated // by looking at the blast radius snapshot and finding all apps that have // items in the snapshot. GetAffectedApps(context.Context, *connect.Request[sdp_go.GetAffectedAppsRequest]) (*connect.Response[sdp_go.GetAffectedAppsResponse], error) // Gets the diff summary for all items that were planned to change as part of // this change. This includes the high level details of the item, and the // status (e.g. changed, deleted) but not the diff itself ListChangingItemsSummary(context.Context, *connect.Request[sdp_go.ListChangingItemsSummaryRequest]) (*connect.Response[sdp_go.ListChangingItemsSummaryResponse], error) // Gets the full diff of everything that changed as part of this "change". // This includes all items and also edges between them GetDiff(context.Context, *connect.Request[sdp_go.GetDiffRequest]) (*connect.Response[sdp_go.GetDiffResponse], error) }
ChangesServiceHandler is an implementation of the changes.ChangesService service.
type ConfigServiceClient ¶ added in v0.68.1
type ConfigServiceClient interface { GetConfig(context.Context, *connect.Request[sdp_go.GetConfigRequest]) (*connect.Response[sdp_go.GetConfigResponse], error) SetConfig(context.Context, *connect.Request[sdp_go.SetConfigRequest]) (*connect.Response[sdp_go.SetConfigResponse], error) }
ConfigServiceClient is a client for the cli.ConfigService service.
func NewConfigServiceClient ¶ added in v0.68.1
func NewConfigServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ConfigServiceClient
NewConfigServiceClient constructs a client for the cli.ConfigService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.
The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).
type ConfigServiceHandler ¶ added in v0.68.1
type ConfigServiceHandler interface { GetConfig(context.Context, *connect.Request[sdp_go.GetConfigRequest]) (*connect.Response[sdp_go.GetConfigResponse], error) SetConfig(context.Context, *connect.Request[sdp_go.SetConfigRequest]) (*connect.Response[sdp_go.SetConfigResponse], error) }
ConfigServiceHandler is an implementation of the cli.ConfigService service.
type InviteServiceClient ¶ added in v0.50.0
type InviteServiceClient interface { CreateInvite(context.Context, *connect.Request[sdp_go.CreateInviteRequest]) (*connect.Response[sdp_go.CreateInviteResponse], error) ListInvites(context.Context, *connect.Request[sdp_go.ListInvitesRequest]) (*connect.Response[sdp_go.ListInvitesResponse], error) RevokeInvite(context.Context, *connect.Request[sdp_go.RevokeInviteRequest]) (*connect.Response[sdp_go.RevokeInviteResponse], error) ResendInvite(context.Context, *connect.Request[sdp_go.ResendInviteRequest]) (*connect.Response[sdp_go.ResendInviteResponse], error) }
InviteServiceClient is a client for the invites.InviteService service.
func NewInviteServiceClient ¶ added in v0.50.0
func NewInviteServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) InviteServiceClient
NewInviteServiceClient constructs a client for the invites.InviteService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.
The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).
type InviteServiceHandler ¶ added in v0.50.0
type InviteServiceHandler interface { CreateInvite(context.Context, *connect.Request[sdp_go.CreateInviteRequest]) (*connect.Response[sdp_go.CreateInviteResponse], error) ListInvites(context.Context, *connect.Request[sdp_go.ListInvitesRequest]) (*connect.Response[sdp_go.ListInvitesResponse], error) RevokeInvite(context.Context, *connect.Request[sdp_go.RevokeInviteRequest]) (*connect.Response[sdp_go.RevokeInviteResponse], error) ResendInvite(context.Context, *connect.Request[sdp_go.ResendInviteRequest]) (*connect.Response[sdp_go.ResendInviteResponse], error) }
InviteServiceHandler is an implementation of the invites.InviteService service.
type KeepaliveSourcesInterceptor ¶ added in v0.61.0
type KeepaliveSourcesInterceptor struct {
// contains filtered or unexported fields
}
func (*KeepaliveSourcesInterceptor) WrapStreamingClient ¶ added in v0.61.0
func (i *KeepaliveSourcesInterceptor) WrapStreamingClient(next connect.StreamingClientFunc) connect.StreamingClientFunc
func (*KeepaliveSourcesInterceptor) WrapStreamingHandler ¶ added in v0.61.0
func (i *KeepaliveSourcesInterceptor) WrapStreamingHandler(next connect.StreamingHandlerFunc) connect.StreamingHandlerFunc
type ManagementServiceClient ¶ added in v0.29.0
type ManagementServiceClient interface { // Get the details of the account that this user belongs to GetAccount(context.Context, *connect.Request[sdp_go.GetAccountRequest]) (*connect.Response[sdp_go.GetAccountResponse], error) // Lists all sources within the user's account ListSources(context.Context, *connect.Request[sdp_go.ListSourcesRequest]) (*connect.Response[sdp_go.ListSourcesResponse], error) // Creates a new source within the user's account CreateSource(context.Context, *connect.Request[sdp_go.CreateSourceRequest]) (*connect.Response[sdp_go.CreateSourceResponse], error) // Get the details of a source GetSource(context.Context, *connect.Request[sdp_go.GetSourceRequest]) (*connect.Response[sdp_go.GetSourceResponse], error) // Update the details of a source UpdateSource(context.Context, *connect.Request[sdp_go.UpdateSourceRequest]) (*connect.Response[sdp_go.UpdateSourceResponse], error) // Deletes a source from a user's account DeleteSource(context.Context, *connect.Request[sdp_go.DeleteSourceRequest]) (*connect.Response[sdp_go.DeleteSourceResponse], error) // Updates sources to keep them running in the background. This can be used // to add explicit action, when the built-in keepalives are not sufficient. KeepaliveSources(context.Context, *connect.Request[sdp_go.KeepaliveSourcesRequest]) (*connect.Response[sdp_go.KeepaliveSourcesResponse], error) // Create a new NATS token for a given public NKey. The user requesting must // control the associated private key also in order to connect to NATS as // the token is not enough on its own CreateToken(context.Context, *connect.Request[sdp_go.CreateTokenRequest]) (*connect.Response[sdp_go.CreateTokenResponse], error) }
ManagementServiceClient is a client for the account.ManagementService service.
func NewManagementServiceClient ¶ added in v0.29.0
func NewManagementServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ManagementServiceClient
NewManagementServiceClient constructs a client for the account.ManagementService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.
The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).
type ManagementServiceHandler ¶ added in v0.29.0
type ManagementServiceHandler interface { // Get the details of the account that this user belongs to GetAccount(context.Context, *connect.Request[sdp_go.GetAccountRequest]) (*connect.Response[sdp_go.GetAccountResponse], error) // Lists all sources within the user's account ListSources(context.Context, *connect.Request[sdp_go.ListSourcesRequest]) (*connect.Response[sdp_go.ListSourcesResponse], error) // Creates a new source within the user's account CreateSource(context.Context, *connect.Request[sdp_go.CreateSourceRequest]) (*connect.Response[sdp_go.CreateSourceResponse], error) // Get the details of a source GetSource(context.Context, *connect.Request[sdp_go.GetSourceRequest]) (*connect.Response[sdp_go.GetSourceResponse], error) // Update the details of a source UpdateSource(context.Context, *connect.Request[sdp_go.UpdateSourceRequest]) (*connect.Response[sdp_go.UpdateSourceResponse], error) // Deletes a source from a user's account DeleteSource(context.Context, *connect.Request[sdp_go.DeleteSourceRequest]) (*connect.Response[sdp_go.DeleteSourceResponse], error) // Updates sources to keep them running in the background. This can be used // to add explicit action, when the built-in keepalives are not sufficient. KeepaliveSources(context.Context, *connect.Request[sdp_go.KeepaliveSourcesRequest]) (*connect.Response[sdp_go.KeepaliveSourcesResponse], error) // Create a new NATS token for a given public NKey. The user requesting must // control the associated private key also in order to connect to NATS as // the token is not enough on its own CreateToken(context.Context, *connect.Request[sdp_go.CreateTokenRequest]) (*connect.Response[sdp_go.CreateTokenResponse], error) }
ManagementServiceHandler is an implementation of the account.ManagementService service.
type RevlinkServiceClient ¶ added in v0.52.0
type RevlinkServiceClient interface { // Gets reverse links for a given item GetReverseLinks(context.Context, *connect.Request[sdp_go.GetReverseLinksRequest]) (*connect.Response[sdp_go.GetReverseLinksResponse], error) // Ingests a stream of gateway responses IngestGatewayResponses(context.Context) *connect.ClientStreamForClient[sdp_go.IngestGatewayResponseRequest, sdp_go.IngestGatewayResponsesResponse] }
RevlinkServiceClient is a client for the revlink.RevlinkService service.
func NewRevlinkServiceClient ¶ added in v0.52.0
func NewRevlinkServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) RevlinkServiceClient
NewRevlinkServiceClient constructs a client for the revlink.RevlinkService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.
The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).
type RevlinkServiceHandler ¶ added in v0.52.0
type RevlinkServiceHandler interface { // Gets reverse links for a given item GetReverseLinks(context.Context, *connect.Request[sdp_go.GetReverseLinksRequest]) (*connect.Response[sdp_go.GetReverseLinksResponse], error) // Ingests a stream of gateway responses IngestGatewayResponses(context.Context, *connect.ClientStream[sdp_go.IngestGatewayResponseRequest]) (*connect.Response[sdp_go.IngestGatewayResponsesResponse], error) }
RevlinkServiceHandler is an implementation of the revlink.RevlinkService service.
type SnapshotsServiceClient ¶ added in v0.24.0
type SnapshotsServiceClient interface { ListSnapshots(context.Context, *connect.Request[sdp_go.ListSnapshotsRequest]) (*connect.Response[sdp_go.ListSnapshotResponse], error) CreateSnapshot(context.Context, *connect.Request[sdp_go.CreateSnapshotRequest]) (*connect.Response[sdp_go.CreateSnapshotResponse], error) GetSnapshot(context.Context, *connect.Request[sdp_go.GetSnapshotRequest]) (*connect.Response[sdp_go.GetSnapshotResponse], error) UpdateSnapshot(context.Context, *connect.Request[sdp_go.UpdateSnapshotRequest]) (*connect.Response[sdp_go.UpdateSnapshotResponse], error) DeleteSnapshot(context.Context, *connect.Request[sdp_go.DeleteSnapshotRequest]) (*connect.Response[sdp_go.DeleteSnapshotResponse], error) // retrieve the initial data for the example change GetInitialData(context.Context, *connect.Request[sdp_go.GetInitialDataRequest]) (*connect.Response[sdp_go.GetInitialDataResponse], error) }
SnapshotsServiceClient is a client for the snapshots.SnapshotsService service.
func NewSnapshotsServiceClient ¶ added in v0.24.0
func NewSnapshotsServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) SnapshotsServiceClient
NewSnapshotsServiceClient constructs a client for the snapshots.SnapshotsService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.
The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).
type SnapshotsServiceHandler ¶ added in v0.24.0
type SnapshotsServiceHandler interface { ListSnapshots(context.Context, *connect.Request[sdp_go.ListSnapshotsRequest]) (*connect.Response[sdp_go.ListSnapshotResponse], error) CreateSnapshot(context.Context, *connect.Request[sdp_go.CreateSnapshotRequest]) (*connect.Response[sdp_go.CreateSnapshotResponse], error) GetSnapshot(context.Context, *connect.Request[sdp_go.GetSnapshotRequest]) (*connect.Response[sdp_go.GetSnapshotResponse], error) UpdateSnapshot(context.Context, *connect.Request[sdp_go.UpdateSnapshotRequest]) (*connect.Response[sdp_go.UpdateSnapshotResponse], error) DeleteSnapshot(context.Context, *connect.Request[sdp_go.DeleteSnapshotRequest]) (*connect.Response[sdp_go.DeleteSnapshotResponse], error) // retrieve the initial data for the example change GetInitialData(context.Context, *connect.Request[sdp_go.GetInitialDataRequest]) (*connect.Response[sdp_go.GetInitialDataResponse], error) }
SnapshotsServiceHandler is an implementation of the snapshots.SnapshotsService service.
type UnimplementedAdminServiceHandler ¶ added in v0.29.0
type UnimplementedAdminServiceHandler struct{}
UnimplementedAdminServiceHandler returns CodeUnimplemented from all methods.
func (UnimplementedAdminServiceHandler) CreateAccount ¶ added in v0.29.0
func (UnimplementedAdminServiceHandler) CreateAccount(context.Context, *connect.Request[sdp_go.CreateAccountRequest]) (*connect.Response[sdp_go.CreateAccountResponse], error)
func (UnimplementedAdminServiceHandler) CreateSource ¶ added in v0.29.0
func (UnimplementedAdminServiceHandler) CreateSource(context.Context, *connect.Request[sdp_go.AdminCreateSourceRequest]) (*connect.Response[sdp_go.CreateSourceResponse], error)
func (UnimplementedAdminServiceHandler) CreateToken ¶ added in v0.29.0
func (UnimplementedAdminServiceHandler) CreateToken(context.Context, *connect.Request[sdp_go.AdminCreateTokenRequest]) (*connect.Response[sdp_go.CreateTokenResponse], error)
func (UnimplementedAdminServiceHandler) DeleteAccount ¶ added in v0.29.0
func (UnimplementedAdminServiceHandler) DeleteAccount(context.Context, *connect.Request[sdp_go.DeleteAccountRequest]) (*connect.Response[sdp_go.DeleteAccountResponse], error)
func (UnimplementedAdminServiceHandler) DeleteSource ¶ added in v0.29.0
func (UnimplementedAdminServiceHandler) DeleteSource(context.Context, *connect.Request[sdp_go.AdminDeleteSourceRequest]) (*connect.Response[sdp_go.DeleteSourceResponse], error)
func (UnimplementedAdminServiceHandler) GetAccount ¶ added in v0.29.0
func (UnimplementedAdminServiceHandler) GetAccount(context.Context, *connect.Request[sdp_go.AdminGetAccountRequest]) (*connect.Response[sdp_go.GetAccountResponse], error)
func (UnimplementedAdminServiceHandler) GetSource ¶ added in v0.29.0
func (UnimplementedAdminServiceHandler) GetSource(context.Context, *connect.Request[sdp_go.AdminGetSourceRequest]) (*connect.Response[sdp_go.GetSourceResponse], error)
func (UnimplementedAdminServiceHandler) KeepaliveSources ¶ added in v0.29.0
func (UnimplementedAdminServiceHandler) KeepaliveSources(context.Context, *connect.Request[sdp_go.AdminKeepaliveSourcesRequest]) (*connect.Response[sdp_go.KeepaliveSourcesResponse], error)
func (UnimplementedAdminServiceHandler) ListAccounts ¶ added in v0.29.0
func (UnimplementedAdminServiceHandler) ListAccounts(context.Context, *connect.Request[sdp_go.ListAccountsRequest]) (*connect.Response[sdp_go.ListAccountsResponse], error)
func (UnimplementedAdminServiceHandler) ListSources ¶ added in v0.29.0
func (UnimplementedAdminServiceHandler) ListSources(context.Context, *connect.Request[sdp_go.AdminListSourcesRequest]) (*connect.Response[sdp_go.ListSourcesResponse], error)
func (UnimplementedAdminServiceHandler) UpdateSource ¶ added in v0.29.0
func (UnimplementedAdminServiceHandler) UpdateSource(context.Context, *connect.Request[sdp_go.AdminUpdateSourceRequest]) (*connect.Response[sdp_go.UpdateSourceResponse], error)
type UnimplementedApiKeyServiceHandler ¶ added in v0.34.3
type UnimplementedApiKeyServiceHandler struct{}
UnimplementedApiKeyServiceHandler returns CodeUnimplemented from all methods.
func (UnimplementedApiKeyServiceHandler) CreateAPIKey ¶ added in v0.34.3
func (UnimplementedApiKeyServiceHandler) CreateAPIKey(context.Context, *connect.Request[sdp_go.CreateAPIKeyRequest]) (*connect.Response[sdp_go.CreateAPIKeyResponse], error)
func (UnimplementedApiKeyServiceHandler) DeleteAPIKey ¶ added in v0.34.3
func (UnimplementedApiKeyServiceHandler) DeleteAPIKey(context.Context, *connect.Request[sdp_go.DeleteAPIKeyRequest]) (*connect.Response[sdp_go.DeleteAPIKeyResponse], error)
func (UnimplementedApiKeyServiceHandler) ExchangeKeyForToken ¶ added in v0.34.3
func (UnimplementedApiKeyServiceHandler) ExchangeKeyForToken(context.Context, *connect.Request[sdp_go.ExchangeKeyForTokenRequest]) (*connect.Response[sdp_go.ExchangeKeyForTokenResponse], error)
func (UnimplementedApiKeyServiceHandler) GetAPIKey ¶ added in v0.34.3
func (UnimplementedApiKeyServiceHandler) GetAPIKey(context.Context, *connect.Request[sdp_go.GetAPIKeyRequest]) (*connect.Response[sdp_go.GetAPIKeyResponse], error)
func (UnimplementedApiKeyServiceHandler) ListAPIKeys ¶ added in v0.34.3
func (UnimplementedApiKeyServiceHandler) ListAPIKeys(context.Context, *connect.Request[sdp_go.ListAPIKeysRequest]) (*connect.Response[sdp_go.ListAPIKeysResponse], error)
func (UnimplementedApiKeyServiceHandler) UpdateAPIKey ¶ added in v0.34.5
func (UnimplementedApiKeyServiceHandler) UpdateAPIKey(context.Context, *connect.Request[sdp_go.UpdateAPIKeyRequest]) (*connect.Response[sdp_go.UpdateAPIKeyResponse], error)
type UnimplementedAuth0SupportHandler ¶ added in v0.50.0
type UnimplementedAuth0SupportHandler struct{}
UnimplementedAuth0SupportHandler returns CodeUnimplemented from all methods.
func (UnimplementedAuth0SupportHandler) CreateUser ¶ added in v0.50.0
func (UnimplementedAuth0SupportHandler) CreateUser(context.Context, *connect.Request[sdp_go.Auth0CreateUserRequest]) (*connect.Response[sdp_go.Auth0CreateUserResponse], error)
func (UnimplementedAuth0SupportHandler) KeepaliveSources ¶ added in v0.50.0
func (UnimplementedAuth0SupportHandler) KeepaliveSources(context.Context, *connect.Request[sdp_go.AdminKeepaliveSourcesRequest]) (*connect.Response[sdp_go.KeepaliveSourcesResponse], error)
type UnimplementedBookmarksServiceHandler ¶ added in v0.24.0
type UnimplementedBookmarksServiceHandler struct{}
UnimplementedBookmarksServiceHandler returns CodeUnimplemented from all methods.
func (UnimplementedBookmarksServiceHandler) CreateBookmark ¶ added in v0.24.0
func (UnimplementedBookmarksServiceHandler) CreateBookmark(context.Context, *connect.Request[sdp_go.CreateBookmarkRequest]) (*connect.Response[sdp_go.CreateBookmarkResponse], error)
func (UnimplementedBookmarksServiceHandler) DeleteBookmark ¶ added in v0.24.0
func (UnimplementedBookmarksServiceHandler) DeleteBookmark(context.Context, *connect.Request[sdp_go.DeleteBookmarkRequest]) (*connect.Response[sdp_go.DeleteBookmarkResponse], error)
func (UnimplementedBookmarksServiceHandler) GetAffectedBookmarks ¶ added in v0.32.2
func (UnimplementedBookmarksServiceHandler) GetAffectedBookmarks(context.Context, *connect.Request[sdp_go.GetAffectedBookmarksRequest]) (*connect.Response[sdp_go.GetAffectedBookmarksResponse], error)
func (UnimplementedBookmarksServiceHandler) GetBookmark ¶ added in v0.24.0
func (UnimplementedBookmarksServiceHandler) GetBookmark(context.Context, *connect.Request[sdp_go.GetBookmarkRequest]) (*connect.Response[sdp_go.GetBookmarkResponse], error)
func (UnimplementedBookmarksServiceHandler) ListBookmarks ¶ added in v0.24.0
func (UnimplementedBookmarksServiceHandler) ListBookmarks(context.Context, *connect.Request[sdp_go.ListBookmarksRequest]) (*connect.Response[sdp_go.ListBookmarkResponse], error)
func (UnimplementedBookmarksServiceHandler) UpdateBookmark ¶ added in v0.24.0
func (UnimplementedBookmarksServiceHandler) UpdateBookmark(context.Context, *connect.Request[sdp_go.UpdateBookmarkRequest]) (*connect.Response[sdp_go.UpdateBookmarkResponse], error)
type UnimplementedChangesServiceHandler ¶ added in v0.23.0
type UnimplementedChangesServiceHandler struct{}
UnimplementedChangesServiceHandler returns CodeUnimplemented from all methods.
func (UnimplementedChangesServiceHandler) CalculateBlastRadius ¶ added in v0.27.0
func (UnimplementedChangesServiceHandler) CalculateBlastRadius(context.Context, *connect.Request[sdp_go.CalculateBlastRadiusRequest], *connect.ServerStream[sdp_go.CalculateBlastRadiusResponse]) error
func (UnimplementedChangesServiceHandler) CreateApp ¶ added in v0.23.0
func (UnimplementedChangesServiceHandler) CreateApp(context.Context, *connect.Request[sdp_go.CreateAppRequest]) (*connect.Response[sdp_go.CreateAppResponse], error)
func (UnimplementedChangesServiceHandler) CreateChange ¶ added in v0.23.0
func (UnimplementedChangesServiceHandler) CreateChange(context.Context, *connect.Request[sdp_go.CreateChangeRequest]) (*connect.Response[sdp_go.CreateChangeResponse], error)
func (UnimplementedChangesServiceHandler) CreateSimpleApp ¶ added in v0.31.0
func (UnimplementedChangesServiceHandler) CreateSimpleApp(context.Context, *connect.Request[sdp_go.CreateSimpleAppRequest]) (*connect.Response[sdp_go.CreateSimpleAppResponse], error)
func (UnimplementedChangesServiceHandler) DeleteApp ¶ added in v0.23.0
func (UnimplementedChangesServiceHandler) DeleteApp(context.Context, *connect.Request[sdp_go.DeleteAppRequest]) (*connect.Response[sdp_go.DeleteAppResponse], error)
func (UnimplementedChangesServiceHandler) DeleteChange ¶ added in v0.23.0
func (UnimplementedChangesServiceHandler) DeleteChange(context.Context, *connect.Request[sdp_go.DeleteChangeRequest]) (*connect.Response[sdp_go.DeleteChangeResponse], error)
func (UnimplementedChangesServiceHandler) EndChange ¶ added in v0.27.0
func (UnimplementedChangesServiceHandler) EndChange(context.Context, *connect.Request[sdp_go.EndChangeRequest], *connect.ServerStream[sdp_go.EndChangeResponse]) error
func (UnimplementedChangesServiceHandler) GetAffectedApps ¶ added in v0.31.0
func (UnimplementedChangesServiceHandler) GetAffectedApps(context.Context, *connect.Request[sdp_go.GetAffectedAppsRequest]) (*connect.Response[sdp_go.GetAffectedAppsResponse], error)
func (UnimplementedChangesServiceHandler) GetApp ¶ added in v0.23.0
func (UnimplementedChangesServiceHandler) GetApp(context.Context, *connect.Request[sdp_go.GetAppRequest]) (*connect.Response[sdp_go.GetAppResponse], error)
func (UnimplementedChangesServiceHandler) GetAppSummaries ¶ added in v0.36.0
func (UnimplementedChangesServiceHandler) GetAppSummaries(context.Context, *connect.Request[sdp_go.GetAppSummariesRequest]) (*connect.Response[sdp_go.GetAppSummariesResponse], error)
func (UnimplementedChangesServiceHandler) GetAppSummary ¶ added in v0.31.0
func (UnimplementedChangesServiceHandler) GetAppSummary(context.Context, *connect.Request[sdp_go.GetAppSummaryRequest]) (*connect.Response[sdp_go.GetAppSummaryResponse], error)
func (UnimplementedChangesServiceHandler) GetChange ¶ added in v0.23.0
func (UnimplementedChangesServiceHandler) GetChange(context.Context, *connect.Request[sdp_go.GetChangeRequest]) (*connect.Response[sdp_go.GetChangeResponse], error)
func (UnimplementedChangesServiceHandler) GetChangeArchive ¶ added in v0.58.2
func (UnimplementedChangesServiceHandler) GetChangeArchive(context.Context, *connect.Request[sdp_go.GetChangeArchiveRequest]) (*connect.Response[sdp_go.GetChangeArchiveResponse], error)
func (UnimplementedChangesServiceHandler) GetChangeRisks ¶ added in v0.64.0
func (UnimplementedChangesServiceHandler) GetChangeRisks(context.Context, *connect.Request[sdp_go.GetChangeRisksRequest]) (*connect.Response[sdp_go.GetChangeRisksResponse], error)
func (UnimplementedChangesServiceHandler) GetChangeTimeline ¶ added in v0.40.0
func (UnimplementedChangesServiceHandler) GetChangeTimeline(context.Context, *connect.Request[sdp_go.GetChangeTimelineRequest]) (*connect.Response[sdp_go.GetChangeTimelineResponse], error)
func (UnimplementedChangesServiceHandler) GetDiff ¶ added in v0.31.0
func (UnimplementedChangesServiceHandler) GetDiff(context.Context, *connect.Request[sdp_go.GetDiffRequest]) (*connect.Response[sdp_go.GetDiffResponse], error)
func (UnimplementedChangesServiceHandler) GetOnboarding ¶ added in v0.23.0
func (UnimplementedChangesServiceHandler) GetOnboarding(context.Context, *connect.Request[sdp_go.GetOnboardingRequest]) (*connect.Response[sdp_go.GetOnboardingResponse], error)
func (UnimplementedChangesServiceHandler) ListAppChanges ¶ added in v0.27.0
func (UnimplementedChangesServiceHandler) ListAppChanges(context.Context, *connect.Request[sdp_go.ListAppChangesRequest]) (*connect.Response[sdp_go.ListAppChangesResponse], error)
func (UnimplementedChangesServiceHandler) ListAppChangesSummary ¶ added in v0.31.0
func (UnimplementedChangesServiceHandler) ListAppChangesSummary(context.Context, *connect.Request[sdp_go.ListAppChangesSummaryRequest]) (*connect.Response[sdp_go.ListAppChangesSummaryResponse], error)
func (UnimplementedChangesServiceHandler) ListApps ¶ added in v0.24.0
func (UnimplementedChangesServiceHandler) ListApps(context.Context, *connect.Request[sdp_go.ListAppsRequest]) (*connect.Response[sdp_go.ListAppsResponse], error)
func (UnimplementedChangesServiceHandler) ListChanges ¶ added in v0.24.0
func (UnimplementedChangesServiceHandler) ListChanges(context.Context, *connect.Request[sdp_go.ListChangesRequest]) (*connect.Response[sdp_go.ListChangesResponse], error)
func (UnimplementedChangesServiceHandler) ListChangesByStatus ¶ added in v0.43.0
func (UnimplementedChangesServiceHandler) ListChangesByStatus(context.Context, *connect.Request[sdp_go.ListChangesByStatusRequest]) (*connect.Response[sdp_go.ListChangesByStatusResponse], error)
func (UnimplementedChangesServiceHandler) ListChangingItemsSummary ¶ added in v0.31.0
func (UnimplementedChangesServiceHandler) ListChangingItemsSummary(context.Context, *connect.Request[sdp_go.ListChangingItemsSummaryRequest]) (*connect.Response[sdp_go.ListChangingItemsSummaryResponse], error)
func (UnimplementedChangesServiceHandler) ListHomeApps ¶ added in v0.31.0
func (UnimplementedChangesServiceHandler) ListHomeApps(context.Context, *connect.Request[sdp_go.ListHomeAppsRequest]) (*connect.Response[sdp_go.ListHomeAppsResponse], error)
func (UnimplementedChangesServiceHandler) ListHomeChanges ¶ added in v0.31.0
func (UnimplementedChangesServiceHandler) ListHomeChanges(context.Context, *connect.Request[sdp_go.ListHomeChangesRequest]) (*connect.Response[sdp_go.ListHomeChangesResponse], error)
func (UnimplementedChangesServiceHandler) RefreshState ¶ added in v0.34.3
func (UnimplementedChangesServiceHandler) RefreshState(context.Context, *connect.Request[sdp_go.RefreshStateRequest]) (*connect.Response[sdp_go.RefreshStateResponse], error)
func (UnimplementedChangesServiceHandler) SimulateChange ¶ added in v0.28.1
func (UnimplementedChangesServiceHandler) SimulateChange(context.Context, *connect.Request[sdp_go.SimulateChangeRequest], *connect.ServerStream[sdp_go.SimulateChangeResponse]) error
func (UnimplementedChangesServiceHandler) StartChange ¶ added in v0.27.0
func (UnimplementedChangesServiceHandler) StartChange(context.Context, *connect.Request[sdp_go.StartChangeRequest], *connect.ServerStream[sdp_go.StartChangeResponse]) error
func (UnimplementedChangesServiceHandler) UpdateApp ¶ added in v0.23.0
func (UnimplementedChangesServiceHandler) UpdateApp(context.Context, *connect.Request[sdp_go.UpdateAppRequest]) (*connect.Response[sdp_go.UpdateAppResponse], error)
func (UnimplementedChangesServiceHandler) UpdateChange ¶ added in v0.23.0
func (UnimplementedChangesServiceHandler) UpdateChange(context.Context, *connect.Request[sdp_go.UpdateChangeRequest]) (*connect.Response[sdp_go.UpdateChangeResponse], error)
func (UnimplementedChangesServiceHandler) UpdateChangingItems ¶ added in v0.31.0
func (UnimplementedChangesServiceHandler) UpdateChangingItems(context.Context, *connect.Request[sdp_go.UpdateChangingItemsRequest], *connect.ServerStream[sdp_go.CalculateBlastRadiusResponse]) error
func (UnimplementedChangesServiceHandler) UpdateOnboarding ¶ added in v0.23.0
func (UnimplementedChangesServiceHandler) UpdateOnboarding(context.Context, *connect.Request[sdp_go.UpdateOnboardingRequest]) (*connect.Response[sdp_go.UpdateOnboardingResponse], error)
func (UnimplementedChangesServiceHandler) UpdatePlannedChanges ¶ added in v0.55.0
func (UnimplementedChangesServiceHandler) UpdatePlannedChanges(context.Context, *connect.Request[sdp_go.UpdatePlannedChangesRequest], *connect.ServerStream[sdp_go.CalculateBlastRadiusResponse]) error
type UnimplementedConfigServiceHandler ¶ added in v0.68.1
type UnimplementedConfigServiceHandler struct{}
UnimplementedConfigServiceHandler returns CodeUnimplemented from all methods.
func (UnimplementedConfigServiceHandler) GetConfig ¶ added in v0.68.1
func (UnimplementedConfigServiceHandler) GetConfig(context.Context, *connect.Request[sdp_go.GetConfigRequest]) (*connect.Response[sdp_go.GetConfigResponse], error)
func (UnimplementedConfigServiceHandler) SetConfig ¶ added in v0.68.1
func (UnimplementedConfigServiceHandler) SetConfig(context.Context, *connect.Request[sdp_go.SetConfigRequest]) (*connect.Response[sdp_go.SetConfigResponse], error)
type UnimplementedInviteServiceHandler ¶ added in v0.50.0
type UnimplementedInviteServiceHandler struct{}
UnimplementedInviteServiceHandler returns CodeUnimplemented from all methods.
func (UnimplementedInviteServiceHandler) CreateInvite ¶ added in v0.50.0
func (UnimplementedInviteServiceHandler) CreateInvite(context.Context, *connect.Request[sdp_go.CreateInviteRequest]) (*connect.Response[sdp_go.CreateInviteResponse], error)
func (UnimplementedInviteServiceHandler) ListInvites ¶ added in v0.50.0
func (UnimplementedInviteServiceHandler) ListInvites(context.Context, *connect.Request[sdp_go.ListInvitesRequest]) (*connect.Response[sdp_go.ListInvitesResponse], error)
func (UnimplementedInviteServiceHandler) ResendInvite ¶ added in v0.68.0
func (UnimplementedInviteServiceHandler) ResendInvite(context.Context, *connect.Request[sdp_go.ResendInviteRequest]) (*connect.Response[sdp_go.ResendInviteResponse], error)
func (UnimplementedInviteServiceHandler) RevokeInvite ¶ added in v0.50.0
func (UnimplementedInviteServiceHandler) RevokeInvite(context.Context, *connect.Request[sdp_go.RevokeInviteRequest]) (*connect.Response[sdp_go.RevokeInviteResponse], error)
type UnimplementedManagementServiceHandler ¶ added in v0.29.0
type UnimplementedManagementServiceHandler struct{}
UnimplementedManagementServiceHandler returns CodeUnimplemented from all methods.
func (UnimplementedManagementServiceHandler) CreateSource ¶ added in v0.29.0
func (UnimplementedManagementServiceHandler) CreateSource(context.Context, *connect.Request[sdp_go.CreateSourceRequest]) (*connect.Response[sdp_go.CreateSourceResponse], error)
func (UnimplementedManagementServiceHandler) CreateToken ¶ added in v0.29.0
func (UnimplementedManagementServiceHandler) CreateToken(context.Context, *connect.Request[sdp_go.CreateTokenRequest]) (*connect.Response[sdp_go.CreateTokenResponse], error)
func (UnimplementedManagementServiceHandler) DeleteSource ¶ added in v0.29.0
func (UnimplementedManagementServiceHandler) DeleteSource(context.Context, *connect.Request[sdp_go.DeleteSourceRequest]) (*connect.Response[sdp_go.DeleteSourceResponse], error)
func (UnimplementedManagementServiceHandler) GetAccount ¶ added in v0.29.0
func (UnimplementedManagementServiceHandler) GetAccount(context.Context, *connect.Request[sdp_go.GetAccountRequest]) (*connect.Response[sdp_go.GetAccountResponse], error)
func (UnimplementedManagementServiceHandler) GetSource ¶ added in v0.29.0
func (UnimplementedManagementServiceHandler) GetSource(context.Context, *connect.Request[sdp_go.GetSourceRequest]) (*connect.Response[sdp_go.GetSourceResponse], error)
func (UnimplementedManagementServiceHandler) KeepaliveSources ¶ added in v0.29.0
func (UnimplementedManagementServiceHandler) KeepaliveSources(context.Context, *connect.Request[sdp_go.KeepaliveSourcesRequest]) (*connect.Response[sdp_go.KeepaliveSourcesResponse], error)
func (UnimplementedManagementServiceHandler) ListSources ¶ added in v0.29.0
func (UnimplementedManagementServiceHandler) ListSources(context.Context, *connect.Request[sdp_go.ListSourcesRequest]) (*connect.Response[sdp_go.ListSourcesResponse], error)
func (UnimplementedManagementServiceHandler) UpdateSource ¶ added in v0.29.0
func (UnimplementedManagementServiceHandler) UpdateSource(context.Context, *connect.Request[sdp_go.UpdateSourceRequest]) (*connect.Response[sdp_go.UpdateSourceResponse], error)
type UnimplementedRevlinkServiceHandler ¶ added in v0.52.0
type UnimplementedRevlinkServiceHandler struct{}
UnimplementedRevlinkServiceHandler returns CodeUnimplemented from all methods.
func (UnimplementedRevlinkServiceHandler) GetReverseLinks ¶ added in v0.52.0
func (UnimplementedRevlinkServiceHandler) GetReverseLinks(context.Context, *connect.Request[sdp_go.GetReverseLinksRequest]) (*connect.Response[sdp_go.GetReverseLinksResponse], error)
func (UnimplementedRevlinkServiceHandler) IngestGatewayResponses ¶ added in v0.52.0
func (UnimplementedRevlinkServiceHandler) IngestGatewayResponses(context.Context, *connect.ClientStream[sdp_go.IngestGatewayResponseRequest]) (*connect.Response[sdp_go.IngestGatewayResponsesResponse], error)
type UnimplementedSnapshotsServiceHandler ¶ added in v0.24.0
type UnimplementedSnapshotsServiceHandler struct{}
UnimplementedSnapshotsServiceHandler returns CodeUnimplemented from all methods.
func (UnimplementedSnapshotsServiceHandler) CreateSnapshot ¶ added in v0.24.0
func (UnimplementedSnapshotsServiceHandler) CreateSnapshot(context.Context, *connect.Request[sdp_go.CreateSnapshotRequest]) (*connect.Response[sdp_go.CreateSnapshotResponse], error)
func (UnimplementedSnapshotsServiceHandler) DeleteSnapshot ¶ added in v0.24.0
func (UnimplementedSnapshotsServiceHandler) DeleteSnapshot(context.Context, *connect.Request[sdp_go.DeleteSnapshotRequest]) (*connect.Response[sdp_go.DeleteSnapshotResponse], error)
func (UnimplementedSnapshotsServiceHandler) GetInitialData ¶ added in v0.39.3
func (UnimplementedSnapshotsServiceHandler) GetInitialData(context.Context, *connect.Request[sdp_go.GetInitialDataRequest]) (*connect.Response[sdp_go.GetInitialDataResponse], error)
func (UnimplementedSnapshotsServiceHandler) GetSnapshot ¶ added in v0.24.0
func (UnimplementedSnapshotsServiceHandler) GetSnapshot(context.Context, *connect.Request[sdp_go.GetSnapshotRequest]) (*connect.Response[sdp_go.GetSnapshotResponse], error)
func (UnimplementedSnapshotsServiceHandler) ListSnapshots ¶ added in v0.24.0
func (UnimplementedSnapshotsServiceHandler) ListSnapshots(context.Context, *connect.Request[sdp_go.ListSnapshotsRequest]) (*connect.Response[sdp_go.ListSnapshotResponse], error)
func (UnimplementedSnapshotsServiceHandler) UpdateSnapshot ¶ added in v0.24.0
func (UnimplementedSnapshotsServiceHandler) UpdateSnapshot(context.Context, *connect.Request[sdp_go.UpdateSnapshotRequest]) (*connect.Response[sdp_go.UpdateSnapshotResponse], error)