connector

type Config struct {
	ApplicationID     string `json:"application_id"`
	ApplicationSecret string `json:"application_secret"`
}

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

type MockApiClient struct{}

type MockOauthClient struct{}

type MockWebhookClient struct{}

type PropelApiClient interface {
	CreateDataSource(ctx context.Context, opts client.CreateDataSourceOpts) (*models.DataSource, error)
	FetchDataSource(ctx context.Context, uniqueName string) (*models.DataSource, error)
	FetchDataPool(ctx context.Context, uniqueName string) (*models.DataPool, error)
	CreateDeletionJob(ctx context.Context, dataPoolId string, filters []models.FilterInput) (*models.Job, error)
	FetchDeletionJob(ctx context.Context, id string) (*models.Job, error)
	DeleteDataPool(ctx context.Context, uniqueName string) (string, error)
	DeleteDataSource(ctx context.Context, uniqueName string) (string, error)
}

type PropelOAuthClient interface {
	OAuthToken(ctx context.Context, applicationID, applicationSecret string) (*client.OAuthToken, error)
}

type PropelWebhookClient interface {
	PostEvents(ctx context.Context, input *client.PostEventsInput) ([]error, error)
}