bus

Documentation

Index

• type Convention
  • func FromServices(c config.Config, r RegistryService, e EventService) Convention
  • func (c Convention) Converge(ctx context.Context, d deployment.Deployment) error
  • func (c Convention) Disable(ctx context.Context, d deployment.Deployment, s Subscription) error
  • func (c Convention) DisableAll(ctx context.Context, d deployment.Deployment) error
  • func (c Convention) Emit(ctx context.Context, detail config.EventDetail) error
  • func (c Convention) Enable(ctx context.Context, d deployment.Deployment, s Subscription) error
  • func (c Convention) EnableAll(ctx context.Context, d deployment.Deployment) error
  • func (c Convention) Find(ctx context.Context, d deployment.Deployment, bus, rule string) (Subscription, error)
  • func (c Convention) List(ctx context.Context, d deployment.Deployment) ([]Subscription, error)
• type EventService
• type Meta
• type RegistryService
• type Services
• type Subscription

Types

type Convention

type Convention struct {
	Config  config.Config
	Service Services
}

func FromServices

func FromServices(c config.Config, r RegistryService, e EventService) Convention

func (Convention) Converge

func (c Convention) Converge(ctx context.Context, d deployment.Deployment) error

func (Convention) Disable

func (c Convention) Disable(ctx context.Context, d deployment.Deployment, s Subscription) error

func (Convention) DisableAll

func (c Convention) DisableAll(ctx context.Context, d deployment.Deployment) error

func (Convention) Emit

func (c Convention) Emit(ctx context.Context, detail config.EventDetail) error

func (Convention) Enable

func (c Convention) Enable(ctx context.Context, d deployment.Deployment, s Subscription) error

func (Convention) EnableAll

func (c Convention) EnableAll(ctx context.Context, d deployment.Deployment) error

func (Convention) Find

func (c Convention) Find(ctx context.Context, d deployment.Deployment, bus, rule string) (Subscription, error)

func (Convention) List

func (c Convention) List(ctx context.Context, d deployment.Deployment) ([]Subscription, error)

type EventService

type EventService interface {
	List(ctx context.Context) ([]event.JoinedRule, error)
	Put(ctx context.Context, bus, rule, expression, function, arn string) error
	Delete(ctx context.Context, bus, rule, function, arn string) error
	Emit(ctx context.Context, accountId, busName, detailType string, detail any) error
}

type Meta

type Meta struct {
	Bus         string
	Rule        string
	Destroy     bool
	Update      bool
	Reason      string
	Convergence string
	Expression  string
}

type RegistryService

type RegistryService interface {
	InspectByDigest(ctx context.Context, registryId, repository, digest string) (dockerTypes.ImageInspect, error)
}

type Services

type Services struct {
	Registry RegistryService
	Event    EventService
}

type Subscription

type Subscription struct {
	event.JoinedRule
	Meta Meta
}