retry

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

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

type Config struct {
	GitHubAppID       string        `env:"GITHUB_APP_ID,required"`
	GitHubPrivateKey  string        `env:"GITHUB_PRIVATE_KEY,required"`
	BigQueryProjectID string        `env:"BIG_QUERY_PROJECT_ID,default=$PROJECT_ID"`
	BucketName        string        `env:"BUCKET_NAME,required"`
	CheckpointTableID string        `env:"CHECKPOINT_TABLE_ID,required"`
	EventsTableID     string        `env:"EVENTS_TABLE_ID,required"`
	DatasetID         string        `env:"DATASET_ID,required"`
	LockTTLClockSkew  time.Duration `env:"LOCK_TTL_CLOCK_SKEW,default=10s"`
	LockTTL           time.Duration `env:"LOCK_TTL,default=5m"`
	ProjectID         string        `env:"PROJECT_ID,required"`
	Port              string        `env:"PORT,default=8080"`
}

type Datastore interface {
	RetrieveCheckpointID(ctx context.Context, checkpointTableID string) (string, error)
	WriteCheckpointID(ctx context.Context, checkpointTableID, deliveryID, createdAt 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 {
	// contains filtered or unexported fields
}

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
}

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