awscredssink

Dec 24, 2023

Changes in this version

+ var ErrInstanceAlreadyRegistered = app.NewValidationError("INSTANCE_ALREADY_REGISTERED")

+ var ErrInstanceWasNotFound = app.NewValidationError("INSTANCE_WAS_NOT_FOUND")

+ var ErrInvalidAwsProfileName = app.NewValidationError("INVALID_AWS_PROFILE_NAME")

+ var ErrInvalidLabel = app.NewValidationError("INVALID_LABEL")

+ var ErrInvalidProviderCode = app.NewValidationError("INVALID_PROVIDER_CODE")

+ var ErrInvalidProviderId = app.NewValidationError("INVALID_PROVIDER_ID")

+ var SinkCode = "aws-credentials-file"

+ type AwsCredentialsSinkController struct

+ func NewAwsCredentialsSinkController(db *sql.DB, bus *eventing.Eventbus, ...) *AwsCredentialsSinkController

+ func (c *AwsCredentialsSinkController) DisconnectSink(ctx app.Context, input plumbing.DisconnectSinkCommandInput) error

+ func (c *AwsCredentialsSinkController) FlowData(ctx app.Context, creds awsidc.AwsCredentials, pipeId string) error

+ func (c *AwsCredentialsSinkController) GetInstanceData(ctx app.Context, instanceId string) (*AwsCredentialsSinkInstance, error)

+ func (c *AwsCredentialsSinkController) ListConnectedSinks(ctx app.Context, providerCode, providerId string) ([]plumbing.SinkInstance, error)

+ func (c *AwsCredentialsSinkController) NewInstance(ctx app.Context, input AwsCredentialsSink_NewInstanceCommandInput) (string, error)

+ func (c *AwsCredentialsSinkController) SinkCode() string

+ type AwsCredentialsSinkInstance struct

+ AwsProfileName string

+ CreatedAt int64

+ FilePath string

+ InstanceId string

+ Label string

+ LastDrainedAt *int64

+ ProviderCode string

+ ProviderId string

+ Version int

+ type AwsCredentialsSink_NewInstanceCommandInput struct

+ AwsProfileName string

+ FilePath string

+ Label string

+ ProviderCode string

+ ProviderId string

+ type ProfileCreds struct

+ AwsAccessKeyId string

+ AwsSecretAccessKey string

+ AwsSessionToken *string