awscredssink

Documentation

Index

• Variables
• type AwsCredentialsSinkController
  • 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
• type AwsCredentialsSink_NewInstanceCommandInput
• type ProfileCreds

Variables

var (
	ErrInvalidAwsProfileName     = app.NewValidationError("INVALID_AWS_PROFILE_NAME")
	ErrInvalidLabel              = app.NewValidationError("INVALID_LABEL")
	ErrInvalidProviderCode       = app.NewValidationError("INVALID_PROVIDER_CODE")
	ErrInvalidProviderId         = app.NewValidationError("INVALID_PROVIDER_ID")
	ErrInstanceWasNotFound       = app.NewValidationError("INSTANCE_WAS_NOT_FOUND")
	ErrInstanceAlreadyRegistered = app.NewValidationError("INSTANCE_ALREADY_REGISTERED")
)

var SinkCode = "aws-credentials-file"

Types

type AwsCredentialsSinkController

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

func NewAwsCredentialsSinkController

func NewAwsCredentialsSinkController(db *sql.DB, bus *eventing.Eventbus, encryptionService encryption.EncryptionService, clock utils.Clock) *AwsCredentialsSinkController

func (*AwsCredentialsSinkController) DisconnectSink

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

func (*AwsCredentialsSinkController) FlowData

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

func (*AwsCredentialsSinkController) GetInstanceData

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

func (*AwsCredentialsSinkController) ListConnectedSinks

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

func (*AwsCredentialsSinkController) NewInstance

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

func (*AwsCredentialsSinkController) SinkCode

func (c *AwsCredentialsSinkController) SinkCode() string

type AwsCredentialsSinkInstance

type AwsCredentialsSinkInstance struct {
	InstanceId     string `json:"instanceId"`
	Version        int    `json:"version"`
	FilePath       string `json:"filePath"`
	AwsProfileName string `json:"awsProfileName"`
	Label          string `json:"label"`
	ProviderCode   string `json:"providerCode"`
	ProviderId     string `json:"providerId"`
	CreatedAt      int64  `json:"createdAt"`
	LastDrainedAt  *int64 `json:"lastDrainedAt"`
}

type AwsCredentialsSink_NewInstanceCommandInput

type AwsCredentialsSink_NewInstanceCommandInput struct {
	FilePath       string `json:"filePath"`
	AwsProfileName string `json:"awsProfileName"`
	Label          string `json:"label"`

	ProviderCode string `json:"providerCode"`
	ProviderId   string `json:"providerId"`
}

type ProfileCreds

type ProfileCreds struct {
	AwsAccessKeyId     string
	AwsSecretAccessKey string
	AwsSessionToken    *string
}