spanneradapters

type BCDConsumer struct {
	// contains filtered or unexported fields
}

type BCDWorkflowSpannerClient interface {
	InsertBrowserRelease(ctx context.Context, release gcpspanner.BrowserRelease) error
}

type Backend struct {
	// contains filtered or unexported fields
}

type BackendAdapterForEventProducerDiffer interface {
	GetFeature(
		ctx context.Context,
		featureID string,
		wptMetricView backend.WPTMetricView,
		browsers []backend.BrowserPathParam,
	) (*backendtypes.GetFeatureResult, error)
	FeaturesSearch(
		ctx context.Context,
		pageToken *string,
		pageSize int,
		searchNode *searchtypes.SearchNode,
		sortOrder *backend.ListFeaturesParamsSort,
		wptMetricView backend.WPTMetricView,
		browsers []backend.BrowserPathParam,
	) (*backend.FeaturePage, error)
}

type BackendSpannerClient interface {
	ListMetricsForFeatureIDBrowserAndChannel(
		ctx context.Context,
		featureID string,
		browser string,
		channel string,
		metric gcpspanner.WPTMetricView,
		startAt time.Time,
		endAt time.Time,
		pageSize int,
		pageToken *string,
	) ([]gcpspanner.WPTRunFeatureMetricWithTime, *string, error)
	ListMetricsOverTimeWithAggregatedTotals(
		ctx context.Context,
		featureIDs []string,
		browser string,
		channel string,
		metric gcpspanner.WPTMetricView,
		startAt, endAt time.Time,
		pageSize int,
		pageToken *string,
	) ([]gcpspanner.WPTRunAggregationMetricWithTime, *string, error)
	ListChromeDailyUsageStatsForFeatureID(
		ctx context.Context,
		featureID string,
		startAt, endAt time.Time,
		pageSize int,
		pageToken *string,
	) ([]gcpspanner.ChromeDailyUsageStatWithDate, *string, error)
	FeaturesSearch(
		ctx context.Context,
		pageToken *string,
		pageSize int,
		searchNode *searchtypes.SearchNode,
		sortOrder gcpspanner.Sortable,
		wptMetricView gcpspanner.WPTMetricView,
		browsers []string,
	) (*gcpspanner.FeatureResultPage, error)
	GetFeature(
		ctx context.Context,
		filter gcpspanner.Filterable,
		wptMetricView gcpspanner.WPTMetricView,
		browsers []string,
	) (*gcpspanner.FeatureResult, error)
	GetMovedWebFeatureDetailsByOriginalFeatureKey(
		ctx context.Context,
		featureKey string,
	) (*gcpspanner.MovedWebFeature, error)
	GetSplitWebFeatureByOriginalFeatureKey(
		ctx context.Context,
		featureKey string,
	) (*gcpspanner.SplitWebFeature, error)
	GetIDFromFeatureKey(
		ctx context.Context,
		filter *gcpspanner.FeatureIDFilter,
	) (*string, error)
	ListBrowserFeatureCountMetric(
		ctx context.Context,
		targetBrowser string,
		targetMobileBrowser *string,
		startAt time.Time,
		endAt time.Time,
		pageSize int,
		pageToken *string,
	) (*gcpspanner.BrowserFeatureCountResultPage, error)
	ListMissingOneImplCounts(
		ctx context.Context,
		targetBrowser string,
		targetMobileBrowser *string,
		otherBrowsers []string,
		startAt time.Time,
		endAt time.Time,
		pageSize int,
		pageToken *string,
	) (*gcpspanner.MissingOneImplCountPage, error)
	ListMissingOneImplementationFeatures(
		ctx context.Context,
		targetBrowser string,
		targetMobileBrowser *string,
		otherBrowsers []string,
		targetDate time.Time,
		pageSize int,
		pageToken *string,
	) (*gcpspanner.MissingOneImplFeatureListPage, error)
	ListBaselineStatusCounts(
		ctx context.Context,
		dateType gcpspanner.BaselineDateType,
		startAt time.Time,
		endAt time.Time,
		pageSize int,
		pageToken *string,
	) (*gcpspanner.BaselineStatusCountResultPage, error)
	CreateNewUserSavedSearch(
		ctx context.Context,
		newSearch gcpspanner.CreateUserSavedSearchRequest) (*string, error)
	GetUserSavedSearch(
		ctx context.Context,
		savedSearchID string,
		authenticatedUserID *string) (*gcpspanner.UserSavedSearch, error)
	DeleteUserSavedSearch(ctx context.Context, req gcpspanner.DeleteUserSavedSearchRequest) error
	ListUserSavedSearches(
		ctx context.Context,
		userID string,
		pageSize int,
		pageToken *string) (*gcpspanner.UserSavedSearchesPage, error)
	UpdateUserSavedSearch(ctx context.Context, req gcpspanner.UpdateSavedSearchRequest) error
	AddUserSearchBookmark(ctx context.Context, req gcpspanner.UserSavedSearchBookmark) error
	DeleteUserSearchBookmark(ctx context.Context, req gcpspanner.UserSavedSearchBookmark) error
	SyncUserProfileInfo(ctx context.Context, userProfile gcpspanner.UserProfile) error
	CreateSavedSearchSubscription(
		ctx context.Context, req gcpspanner.CreateSavedSearchSubscriptionRequest) (*string, error)
	GetSavedSearchSubscription(ctx context.Context, subscriptionID string, userID string) (
		*gcpspanner.SavedSearchSubscription, error)
	UpdateSavedSearchSubscription(ctx context.Context, req gcpspanner.UpdateSavedSearchSubscriptionRequest) error
	DeleteSavedSearchSubscription(ctx context.Context, subscriptionID string, userID string) error
	ListSavedSearchSubscriptions(ctx context.Context, req gcpspanner.ListSavedSearchSubscriptionsRequest) (
		[]gcpspanner.SavedSearchSubscription, *string, error)
	GetNotificationChannel(
		ctx context.Context, channelID string, userID string) (*gcpspanner.NotificationChannel, error)
	ListNotificationChannels(ctx context.Context, req gcpspanner.ListNotificationChannelsRequest) (
		[]gcpspanner.NotificationChannel, *string, error)
	DeleteNotificationChannel(ctx context.Context, channelID string, userID string) error
}

type BatchEventProducer struct {
	// contains filtered or unexported fields
}

type BatchEventProducerSpannerClient interface {
	ListAllSavedSearches(
		ctx context.Context) ([]gcpspanner.SavedSearchBriefDetails, error)
}

type BrowserList []backend.BrowserPathParam

type ChromiumHistogramEnumConsumer struct {
	// contains filtered or unexported fields
}

type ChromiumHistogramEnumsClient interface {
	UpsertChromiumHistogramEnum(context.Context, gcpspanner.ChromiumHistogramEnum) (*string, error)
	SyncChromiumHistogramEnumValues(context.Context, []gcpspanner.ChromiumHistogramEnumValue) error
	GetIDFromChromiumHistogramEnumValueKey(
		ctx context.Context, chromiumHistogramEnumID string, bucketID int64) (*string, error)
	SyncWebFeatureChromiumHistogramEnumValues(context.Context, []gcpspanner.WebFeatureChromiumHistogramEnumValue) error
	GetIDFromFeatureKey(context.Context, *gcpspanner.FeatureIDFilter) (*string, error)
	FetchAllFeatureKeys(context.Context) ([]string, error)
	GetAllMovedWebFeatures(ctx context.Context) ([]gcpspanner.MovedWebFeature, error)
}

type DeveloperSignalsClient interface {
	GetAllMovedWebFeatures(ctx context.Context) ([]gcpspanner.MovedWebFeature, error)
	SyncLatestFeatureDeveloperSignals(ctx context.Context, data []gcpspanner.FeatureDeveloperSignal) error
}

type DeveloperSignalsConsumer struct {
	// contains filtered or unexported fields
}

type EmailWorkerChannelStateManager struct {
	// contains filtered or unexported fields
}

type EmailWorkerSpannerClient interface {
	RecordNotificationChannelSuccess(ctx context.Context, channelID string, timestamp time.Time, eventID string) error
	RecordNotificationChannelFailure(ctx context.Context, channelID string, errorMsg string, timestamp time.Time,
		isPermanent bool, eventID string) error
}

type EventProducer struct {
	// contains filtered or unexported fields
}

type EventProducerDiffer struct {
	// contains filtered or unexported fields
}

type EventProducerDifferSpannerClient interface {
	BackendSpannerClient
}

type EventProducerSpannerClient interface {
	TryAcquireSavedSearchStateWorkerLock(
		ctx context.Context,
		savedSearchID string,
		snapshotType gcpspanner.SavedSearchSnapshotType,
		workerID string,
		ttl time.Duration) (bool, error)
	PublishSavedSearchNotificationEvent(ctx context.Context,
		event gcpspanner.SavedSearchNotificationCreateRequest, newStatePath, workerID string,
		opts ...gcpspanner.CreateOption) (*string, error)
	GetLatestSavedSearchNotificationEvent(
		ctx context.Context,
		savedSearchID string,
		snapshotType gcpspanner.SavedSearchSnapshotType,
	) (*gcpspanner.SavedSearchNotificationEvent, error)
	ReleaseSavedSearchStateWorkerLock(
		ctx context.Context,
		savedSearchID string,
		snapshotType gcpspanner.SavedSearchSnapshotType,
		workerID string) error
}

type Migrator[SetValueType, DataType any] struct {
	// AllFeaturesSet is a map representing the set of all feature keys present in the source data.
	// The key is the feature identifier (string). The value's type is generic and not used by the migrator logic.
	AllFeaturesSet map[string]SetValueType
	// MovedFeatures is a map where the key is the old (moved) feature key and the value
	// contains information about the new feature key.
	MovedFeatures map[string]webdxfeaturetypes.FeatureMovedData
	// DataToMigrate is the actual data structure that needs to be modified based on the feature key migrations.
	DataToMigrate DataType
	// contains filtered or unexported fields
}

type MigratorOption[SetValueType, DataType any] func(*Migrator[SetValueType, DataType])

type PushDeliverySpannerClient interface {
	FindAllActivePushSubscriptions(
		ctx context.Context,
		savedSearchID string,
		frequency gcpspanner.SavedSearchSnapshotType,
	) ([]gcpspanner.SubscriberDestination, error)
}

type PushDeliverySubscriberFinder struct {
	// contains filtered or unexported fields
}

type UMAMetricConsumer struct {
	// contains filtered or unexported fields
}

type UMAMetricsClient interface {
	HasDailyChromiumHistogramCapstone(context.Context, gcpspanner.DailyChromiumHistogramEnumCapstone) (*bool, error)
	UpsertDailyChromiumHistogramCapstone(context.Context, gcpspanner.DailyChromiumHistogramEnumCapstone) error
	StoreDailyChromiumHistogramMetrics(context.Context,
		metricdatatypes.HistogramName,
		map[int64]gcpspanner.DailyChromiumHistogramMetric) error
	SyncLatestDailyChromiumHistogramMetrics(context.Context) error
}

type WPTConsumer struct {
	// contains filtered or unexported fields
}

type WPTWorkflowSpannerClient interface {
	InsertWPTRun(ctx context.Context, run gcpspanner.WPTRun) error
	UpsertWPTRunFeatureMetrics(ctx context.Context, externalRunID int64,
		in map[string]gcpspanner.WPTRunFeatureMetric) error
	GetAllMovedWebFeatures(ctx context.Context) ([]gcpspanner.MovedWebFeature, error)
}

type WebFeatureGroupConsumer struct {
	// contains filtered or unexported fields
}

type WebFeatureGroupsClient interface {
	UpsertGroup(ctx context.Context, group gcpspanner.Group) (*string, error)
	UpsertFeatureGroupLookups(ctx context.Context,
		featureKeyToGroupsMapping map[string][]string, childGroupKeyToParentGroupKey map[string]string) error
}

type WebFeatureSnapshotConsumer struct {
	// contains filtered or unexported fields
}

type WebFeatureSnapshotsClient interface {
	UpsertSnapshot(ctx context.Context, snapshot gcpspanner.Snapshot) (*string, error)
	UpsertWebFeatureSnapshot(ctx context.Context, snapshot gcpspanner.WebFeatureSnapshot) error
}

type WebFeatureSpannerClient interface {
	SyncWebFeatures(ctx context.Context, features []gcpspanner.WebFeature,
		options ...gcpspanner.SyncWebFeaturesOption) error
	FetchAllWebFeatureIDsAndKeys(ctx context.Context) ([]gcpspanner.SpannerFeatureIDAndKey, error)
	UpsertFeatureBaselineStatus(ctx context.Context, featureID string, status gcpspanner.FeatureBaselineStatus) error
	SyncBrowserFeatureAvailabilities(
		ctx context.Context,
		availabilities map[string][]gcpspanner.BrowserFeatureAvailability) error
	UpsertFeatureSpec(ctx context.Context, webFeatureID string, input gcpspanner.FeatureSpec) error
	UpsertFeatureDiscouragedDetails(ctx context.Context, featureID string,
		in gcpspanner.FeatureDiscouragedDetails) error
	PrecalculateBrowserFeatureSupportEvents(ctx context.Context, startAt, endAt time.Time) error
	SyncMovedWebFeatures(ctx context.Context, features []gcpspanner.MovedWebFeature) error
	SyncSplitWebFeatures(ctx context.Context, features []gcpspanner.SplitWebFeature) error
}

type WebFeaturesConsumer struct {
	// contains filtered or unexported fields
}

type WebFeaturesMappingClient interface {
	SyncWebFeaturesMappingData(ctx context.Context, data []gcpspanner.WebFeaturesMappingData) error
}

type WebFeaturesMappingConsumer struct {
	// contains filtered or unexported fields
}