event

Documentation

Index

• type Client
• type EventBridgeClient
• type JoinedRule
• type LambdaClient
• type Service
  • func FromClients(eventBridge EventBridgeClient, lambdaClient LambdaClient) Service
  • func (s Service) Delete(ctx context.Context, busName, ruleName, functionName, functionArn string) error
  • func (s Service) Emit(ctx context.Context, accountId, busName, detailType string, detail any) error
  • func (s Service) List(ctx context.Context) ([]JoinedRule, error)
  • func (s Service) Put(ctx context.Context, ...) error

Types

type Client

type Client struct {
	EventBridge EventBridgeClient
	Lambda      LambdaClient
}

type EventBridgeClient

type EventBridgeClient interface {
	ListEventBuses(ctx context.Context, params *eventbridge.ListEventBusesInput, optFns ...func(*eventbridge.Options)) (*eventbridge.ListEventBusesOutput, error)
	ListRules(ctx context.Context, params *eventbridge.ListRulesInput, optFns ...func(*eventbridge.Options)) (*eventbridge.ListRulesOutput, error)
	ListTargetsByRule(ctx context.Context, params *eventbridge.ListTargetsByRuleInput, optFns ...func(*eventbridge.Options)) (*eventbridge.ListTargetsByRuleOutput, error)
	PutRule(ctx context.Context, params *eventbridge.PutRuleInput, optFns ...func(*eventbridge.Options)) (*eventbridge.PutRuleOutput, error)
	PutTargets(ctx context.Context, params *eventbridge.PutTargetsInput, optFns ...func(*eventbridge.Options)) (*eventbridge.PutTargetsOutput, error)
	RemoveTargets(ctx context.Context, params *eventbridge.RemoveTargetsInput, optFns ...func(*eventbridge.Options)) (*eventbridge.RemoveTargetsOutput, error)
	DeleteRule(ctx context.Context, params *eventbridge.DeleteRuleInput, optFns ...func(*eventbridge.Options)) (*eventbridge.DeleteRuleOutput, error)
	PutEvents(ctx context.Context, params *eventbridge.PutEventsInput, optFns ...func(*eventbridge.Options)) (*eventbridge.PutEventsOutput, error)
}

type JoinedRule

type JoinedRule struct {
	Bus    types.EventBus
	Rule   types.Rule
	Target types.Target
}

type LambdaClient

type LambdaClient interface {
	AddPermission(ctx context.Context, params *lambda.AddPermissionInput, optFns ...func(*lambda.Options)) (*lambda.AddPermissionOutput, error)
	RemovePermission(ctx context.Context, params *lambda.RemovePermissionInput, optFns ...func(*lambda.Options)) (*lambda.RemovePermissionOutput, error)
}

type Service

type Service struct {
	Client Client
}

func FromClients

func FromClients(eventBridge EventBridgeClient, lambdaClient LambdaClient) Service

func (Service) Delete

func (s Service) Delete(ctx context.Context, busName, ruleName, functionName, functionArn string) error

func (Service) Emit

func (s Service) Emit(ctx context.Context, accountId, busName, detailType string, detail any) error

func (Service) List

func (s Service) List(ctx context.Context) ([]JoinedRule, error)

func (Service) Put

func (s Service) Put(ctx context.Context, busName, ruleName, ruleContent, functionName, functionArn string) error