Documentation
¶
Index ¶
- type Connector
- func (d *Connector) Asset(_ context.Context, _ *v2.AssetRef) (string, io.ReadCloser, error)
- func (d *Connector) Metadata(_ context.Context) (*v2.ConnectorMetadata, error)
- func (d *Connector) ResourceSyncers(_ context.Context) []connectorbuilder.ResourceSyncer
- func (d *Connector) Validate(_ context.Context) (annotations.Annotations, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Connector ¶
type Connector struct {
// contains filtered or unexported fields
}
func New ¶
func New(ctx context.Context, baseUrl string, clientId string, clientSecret string, syncPermissions bool) (*Connector, error)
New returns a new instance of the connector.
func (*Connector) Asset ¶
Asset takes an input AssetRef and attempts to fetch it using the connector's authenticated http client It streams a response, always starting with a metadata object, following by chunked payloads for the asset.
func (*Connector) ResourceSyncers ¶
func (d *Connector) ResourceSyncers(_ context.Context) []connectorbuilder.ResourceSyncer
ResourceSyncers returns a ResourceSyncer for each resource type that should be synced from the upstream service.
func (*Connector) Validate ¶
func (d *Connector) Validate(_ context.Context) (annotations.Annotations, error)
Validate is called to ensure that the connector is properly configured. It should exercise any API credentials to be sure that they are valid.
Source Files
Click to show internal directories.
Click to hide internal directories.