Documentation
¶
Index ¶
- func NewLambdaConnector(ctx context.Context, ac *cfg.Redis, _ *cli.ConnectorOpts) (connectorbuilder.ConnectorBuilderV2, []connectorbuilder.Opt, error)
- type Connector
- func (d *Connector) Asset(ctx context.Context, asset *v2.AssetRef) (string, io.ReadCloser, error)
- func (d *Connector) Metadata(ctx context.Context) (*v2.ConnectorMetadata, error)
- func (d *Connector) ResourceSyncers(ctx context.Context) []connectorbuilder.ResourceSyncerV2
- func (d *Connector) Validate(ctx context.Context) (annotations.Annotations, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewLambdaConnector ¶ added in v0.0.3
func NewLambdaConnector(ctx context.Context, ac *cfg.Redis, _ *cli.ConnectorOpts) (connectorbuilder.ConnectorBuilderV2, []connectorbuilder.Opt, error)
NewLambdaConnector satisfies cli.NewConnector for use with config.RunConnector.
Types ¶
type Connector ¶
type Connector struct {
// contains filtered or unexported fields
}
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(ctx context.Context) []connectorbuilder.ResourceSyncerV2
ResourceSyncers returns a ResourceSyncerV2 for each resource type that should be synced from the upstream service.
func (*Connector) Validate ¶
func (d *Connector) Validate(ctx 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.