archetype

May 3, 2020

Changes in this version

+ func NewEventBridgeEventReactor(reactor EventBridge, eventPattern map[string]interface{}, ...) (*sparta.LambdaAWSInfo, error)

+ func NewEventBridgeScheduledReactor(reactor EventBridge, scheduleExpression string, ...) (*sparta.LambdaAWSInfo, error)

+ type EventBridge interface

+ OnEventBridgeBroadcast func(ctx context.Context, msg json.RawMessage) (interface{}, error)

+ type EventBridgeReactorFunc func(ctx context.Context, msg json.RawMessage) (interface{}, error)

+ func (reactorFunc EventBridgeReactorFunc) OnEventBridgeBroadcast(ctx context.Context, msg json.RawMessage) (interface{}, error)

+ func (reactorFunc EventBridgeReactorFunc) ReactorName() string

Oct 12, 2019

Changes in this version

+ const TemplateFileName

+ func ApplyTransformToKinesisFirehoseEvent(ctx context.Context, templateBytes []byte, ...) (*awsEvents.KinesisFirehoseResponse, error)

+ func NewKinesisFirehoseLambdaTransformer(reactor KinesisFirehoseReactor, timeout time.Duration) (*sparta.LambdaAWSInfo, error)

+ func NewKinesisFirehoseTransformer(xformFilePath string, timeout time.Duration, hooks *sparta.WorkflowHooks) (*sparta.LambdaAWSInfo, error)

+ type KinesisFirehoseReactor interface

+ OnKinesisFirehoseRecord func(ctx context.Context, record *awsEvents.KinesisFirehoseEventRecord) (*awsEvents.KinesisFirehoseResponseRecord, error)

+ type KinesisFirehoseReactorFunc func(ctx context.Context, kinesisRecord *awsEvents.KinesisFirehoseEventRecord) (*awsEvents.KinesisFirehoseResponseRecord, error)

+ func (reactorFunc KinesisFirehoseReactorFunc) OnKinesisFirehoseRecord(ctx context.Context, kinesisRecord *awsEvents.KinesisFirehoseEventRecord) (*awsEvents.KinesisFirehoseResponseRecord, error)

+ func (reactorFunc KinesisFirehoseReactorFunc) ReactorName() string

Feb 3, 2019

Changes in this version

+ func NewCodeCommitReactor(reactor CodeCommitReactor, repositoryName gocf.Stringable, branches []string, ...) (*sparta.LambdaAWSInfo, error)

+ type CodeCommitReactor interface

+ OnCodeCommitEvent func(ctx context.Context, codeCommitEvent awsLambdaEvents.CodeCommitEvent) (interface{}, error)

+ type CodeCommitReactorFunc func(ctx context.Context, codeCommitEvent awsLambdaEvents.CodeCommitEvent) (interface{}, error)

+ func (reactorFunc CodeCommitReactorFunc) OnCodeCommitEvent(ctx context.Context, codeCommitEvent awsLambdaEvents.CodeCommitEvent) (interface{}, error)

+ func (reactorFunc CodeCommitReactorFunc) ReactorName() string

Dec 16, 2018

Changes in this version

+ type CloudWatchReactor interface

+ OnCloudWatchMessage func(ctx context.Context, cwLogs awsLambdaEvents.CloudwatchLogsEvent) (interface{}, error)

+ type CloudWatchReactorFunc func(ctx context.Context, cwLogs awsLambdaEvents.CloudwatchLogsEvent) (interface{}, error)

+ func (reactorFunc CloudWatchReactorFunc) OnCloudWatchMessage(ctx context.Context, cwLogs awsLambdaEvents.CloudwatchLogsEvent) (interface{}, error)

+ func (reactorFunc CloudWatchReactorFunc) ReactorName() string

Dec 1, 2018

Changes in this version

+ func NewCloudWatchEventedReactor(reactor CloudWatchLogsReactor, eventPatterns map[string]map[string]interface{}, ...) (*sparta.LambdaAWSInfo, error)

+ func NewCloudWatchReactor(reactor CloudWatchLogsReactor, ...) (*sparta.LambdaAWSInfo, error)

+ func NewCloudWatchScheduledReactor(reactor CloudWatchLogsReactor, cronSchedules map[string]string, ...) (*sparta.LambdaAWSInfo, error)

Oct 23, 2018

Changes in this version

type CloudWatchLogsReactorFunc

+ func (reactorFunc CloudWatchLogsReactorFunc) ReactorName() string

type DynamoDBReactorFunc

+ func (reactorFunc DynamoDBReactorFunc) ReactorName() string

type KinesisReactorFunc

+ func (reactorFunc KinesisReactorFunc) ReactorName() string

+ type ReactorNameProvider interface

+ ReactorName func() string

type S3ReactorFunc

+ func (reactorFunc S3ReactorFunc) ReactorName() string

type SNSReactorFunc

+ func (reactorFunc SNSReactorFunc) ReactorName() string

Oct 8, 2018

Changes in this version

+ func NewCloudWatchLogsReactor(reactor CloudWatchLogsReactor, ...) (*sparta.LambdaAWSInfo, error)

+ func NewDynamoDBReactor(reactor DynamoDBReactor, dynamoDBARN gocf.Stringable, startingPosition string, ...) (*sparta.LambdaAWSInfo, error)

+ func NewKinesisReactor(reactor KinesisReactor, kinesisStream gocf.Stringable, startingPosition string, ...) (*sparta.LambdaAWSInfo, error)

+ func NewS3Reactor(reactor S3Reactor, s3Bucket gocf.Stringable, ...) (*sparta.LambdaAWSInfo, error)

+ func NewS3ScopedReactor(reactor S3Reactor, s3Bucket gocf.Stringable, keyPathPrefix string, ...) (*sparta.LambdaAWSInfo, error)

+ func NewSNSReactor(reactor SNSReactor, snsTopic gocf.Stringable, ...) (*sparta.LambdaAWSInfo, error)

+ type CloudWatchLogsReactor interface

+ OnLogMessage func(ctx context.Context, cwLogs awsLambdaEvents.CloudwatchLogsEvent) (interface{}, error)

+ type CloudWatchLogsReactorFunc func(ctx context.Context, cwLogs awsLambdaEvents.CloudwatchLogsEvent) (interface{}, error)

+ func (reactorFunc CloudWatchLogsReactorFunc) OnLogMessage(ctx context.Context, cwLogs awsLambdaEvents.CloudwatchLogsEvent) (interface{}, error)

+ type DynamoDBReactor interface

+ OnDynamoEvent func(ctx context.Context, dynamoEvent awsLambdaEvents.DynamoDBEvent) (interface{}, error)

+ type DynamoDBReactorFunc func(ctx context.Context, dynamoEvent awsLambdaEvents.DynamoDBEvent) (interface{}, error)

+ func (reactorFunc DynamoDBReactorFunc) OnDynamoEvent(ctx context.Context, dynamoEvent awsLambdaEvents.DynamoDBEvent) (interface{}, error)

+ type KinesisReactor interface

+ OnKinesisMessage func(ctx context.Context, kinesisEvent awsLambdaEvents.KinesisEvent) (interface{}, error)

+ type KinesisReactorFunc func(ctx context.Context, kinesisEvent awsLambdaEvents.KinesisEvent) (interface{}, error)

+ func (reactorFunc KinesisReactorFunc) OnKinesisMessage(ctx context.Context, kinesisEvent awsLambdaEvents.KinesisEvent) (interface{}, error)

+ type S3Reactor interface

+ OnS3Event func(ctx context.Context, event awsLambdaEvents.S3Event) (interface{}, error)

+ type S3ReactorFunc func(ctx context.Context, event awsLambdaEvents.S3Event) (interface{}, error)

+ func (reactorFunc S3ReactorFunc) OnS3Event(ctx context.Context, event awsLambdaEvents.S3Event) (interface{}, error)

+ type SNSReactor interface

+ OnSNSEvent func(ctx context.Context, snsEvent awsLambdaEvents.SNSEvent) (interface{}, error)

+ type SNSReactorFunc func(ctx context.Context, snsEvent awsLambdaEvents.SNSEvent) (interface{}, error)

+ func (reactorFunc SNSReactorFunc) OnSNSEvent(ctx context.Context, snsEvent awsLambdaEvents.SNSEvent) (interface{}, error)