retry

type AcquireRes struct {
	Err error
}

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

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

type CloseRes struct {
	Err error
}

type Config struct {
	GitHub githubclient.Config

	GitHubDomain      string
	BigQueryProjectID string
	BucketName        string
	CheckpointTableID string
	EventsTableID     string
	DatasetID         string
	LockTTLClockSkew  time.Duration
	LockTTL           time.Duration
	ProjectID         string
	Port              string
	JobTimeout        time.Duration
}

type Datastore interface {
	RetrieveCheckpointID(ctx context.Context, checkpointTableID, githubDomain string) (string, error)
	WriteCheckpointID(ctx context.Context, checkpointTableID, deliveryID, createdAt, githubDomain string) error
	DeliveryEventExists(ctx context.Context, eventsTableID, deliveryID string) (bool, error)
	Close() error
}

type GitHubSource interface {
	ListDeliveries(ctx context.Context, opts *github.ListCursorOptions) ([]*github.HookDelivery, *github.Response, error)
	RedeliverEvent(ctx context.Context, deliveryID int64) error
}

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

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

type MockLock struct {
	AcquireFn func(context.Context, time.Duration) error
	CloseFn   func(context.Context) error
}

type RetryClientOptions struct {
	BigQueryClientOpts      []option.ClientOption
	GCSLockClientOpts       []option.ClientOption
	DatastoreClientOverride Datastore        // used for unit testing
	GCSLockClientOverride   gcslock.Lockable // used for unit testing
	GitHubOverride          GitHubSource     // used for unit testing
	// GitHubClientCreator is used to create a new GitHub client.
	// If nil, githubclient.New is used.
	GitHubClientCreator func(context.Context, *githubclient.Config) (GitHubSource, error)
}