awsraw

Documentation

Index

• type InfraEvent
  • func (ie *InfraEvent) Valid() bool
• type RawMessageWorker
  • func NewRawMessageWorker(cfHandler RawWorkerCFHandler, ecsHandler RawWorkerECSHandler) *RawMessageWorker
  • func (worker *RawMessageWorker) HandleEventBridgeEvent(ctx context.Context, payload []byte) error
  • func (worker *RawMessageWorker) Raw(ctx context.Context, msg *messaging_tpb.RawMessage) (*emptypb.Empty, error)
• type RawWorkerCFHandler
• type RawWorkerECSHandler

Types

type InfraEvent

type InfraEvent struct {
	Source     string          `json:"source"`
	DetailType string          `json:"detail-type"`
	Detail     json.RawMessage `json:"detail"`
	ID         string          `json:"id"`
}

func (*InfraEvent) Valid

func (ie *InfraEvent) Valid() bool

type RawMessageWorker

type RawMessageWorker struct {
	messaging_tpb.UnimplementedRawMessageTopicServer
	// contains filtered or unexported fields
}

func NewRawMessageWorker

func NewRawMessageWorker(cfHandler RawWorkerCFHandler, ecsHandler RawWorkerECSHandler) *RawMessageWorker

func (*RawMessageWorker) HandleEventBridgeEvent

func (worker *RawMessageWorker) HandleEventBridgeEvent(ctx context.Context, payload []byte) error

func (*RawMessageWorker) Raw

func (worker *RawMessageWorker) Raw(ctx context.Context, msg *messaging_tpb.RawMessage) (*emptypb.Empty, error)

type RawWorkerCFHandler

type RawWorkerCFHandler interface {
	HandleStackStatusChangeEvent(ctx context.Context, eventID string, event *aws_cf.StackStatusChangeEvent) error
}

type RawWorkerECSHandler

type RawWorkerECSHandler interface {
	HandleECSTaskEvent(ctx context.Context, eventID string, event *aws_ecs.ECSTaskStateChangeEvent) error
}