Documentation ¶
Index ¶
- func ConvertAirbyteTypeToPropelType(airbyteProperty airbyte.PropertyType) (models.PropelType, error)
- func UnmarshalFromPath(path string, v any) error
- type Config
- type Destination
- type MockApiClient
- func (ac *MockApiClient) CreateDataSource(_ context.Context, opts client.CreateDataSourceOpts) (*models.DataSource, error)
- func (ac *MockApiClient) CreateDeletionJob(_ context.Context, _ string, _ []models.FilterInput) (*models.Job, error)
- func (ac *MockApiClient) DeleteDataPool(_ context.Context, _ string) (string, error)
- func (ac *MockApiClient) DeleteDataSource(_ context.Context, _ string) (string, error)
- func (ac *MockApiClient) FetchDataPool(_ context.Context, _ string) (*models.DataPool, error)
- func (ac *MockApiClient) FetchDataSource(_ context.Context, uniqueName string) (*models.DataSource, error)
- func (ac *MockApiClient) FetchDeletionJob(_ context.Context, id string) (*models.Job, error)
- type MockOauthClient
- type MockWebhookClient
- type PropelApiClient
- type PropelOAuthClient
- type PropelWebhookClient
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConvertAirbyteTypeToPropelType ¶
func ConvertAirbyteTypeToPropelType(airbyteProperty airbyte.PropertyType) (models.PropelType, error)
func UnmarshalFromPath ¶
Types ¶
type Destination ¶
type Destination struct {
// contains filtered or unexported fields
}
func NewDestination ¶
func NewDestination(logger airbyte.Logger) *Destination
func NewMockDestination ¶
func NewMockDestination(logger airbyte.Logger) *Destination
func (*Destination) Check ¶
func (d *Destination) Check(dstCfgPath string) *airbyte.ConnectionStatus
func (*Destination) Spec ¶
func (d *Destination) Spec() *airbyte.ConnectorSpecification
type MockApiClient ¶
type MockApiClient struct{}
func NewMockApiClient ¶
func NewMockApiClient(_ string) *MockApiClient
func (*MockApiClient) CreateDataSource ¶
func (ac *MockApiClient) CreateDataSource(_ context.Context, opts client.CreateDataSourceOpts) (*models.DataSource, error)
func (*MockApiClient) CreateDeletionJob ¶
func (ac *MockApiClient) CreateDeletionJob(_ context.Context, _ string, _ []models.FilterInput) (*models.Job, error)
func (*MockApiClient) DeleteDataPool ¶
func (*MockApiClient) DeleteDataSource ¶
func (*MockApiClient) FetchDataPool ¶
func (*MockApiClient) FetchDataSource ¶
func (ac *MockApiClient) FetchDataSource(_ context.Context, uniqueName string) (*models.DataSource, error)
func (*MockApiClient) FetchDeletionJob ¶
type MockOauthClient ¶
type MockOauthClient struct{}
func NewMockOAuthClient ¶
func NewMockOAuthClient() *MockOauthClient
func (*MockOauthClient) OAuthToken ¶
type MockWebhookClient ¶
type MockWebhookClient struct{}
func NewMockWebhookClient ¶
func NewMockWebhookClient() *MockWebhookClient
func (*MockWebhookClient) PostEvents ¶
func (wc *MockWebhookClient) PostEvents(_ context.Context, _ *client.PostEventsInput) ([]error, error)
type PropelApiClient ¶
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 ¶
Click to show internal directories.
Click to hide internal directories.