activities

Documentation

Index

• func RegisterAwsActivities(worker worker.Worker, sess *session.Session, config ...*aws.Config)
• func RegisterAwsActivitiesWithSessionFactory(worker worker.Worker, sessionFactory SessionFactory)
• type SessionFactory

Functions

func RegisterAwsActivities

func RegisterAwsActivities(worker worker.Worker, sess *session.Session, config ...*aws.Config)

RegisterAwsActivities registers AWS activities with a single session. Use this registration method if your worker will only use a single set of credentials for authentication.

func RegisterAwsActivitiesWithSessionFactory

func RegisterAwsActivitiesWithSessionFactory(worker worker.Worker, sessionFactory SessionFactory)

RegisterAwsActivitiesWithSessionFactory registers AWS activities with a session factory that creates a session for every activity execution. Use this registration method if your activities will receive credentials in the context for each activity execution.

Types

type SessionFactory

type SessionFactory interface {
	Session(ctx context.Context) (*session.Session, error)
}

SessionFactory returns an aws.Session based on the activity context.