eventbridge

type Bus struct {
	Name string            `json:"name"`
	Tags map[string]string `json:"tags,omitempty"`
}

type InputTransformer struct {
	PathsMap map[string]string `json:"paths_map,omitempty"`
	Template string            `json:"template"`
}

type Options struct {
	// DataDir holds the bbolt store (eventbridge.bolt). Required.
	DataDir string
	// Peers resolves SQS/Lambda targets. Nil disables delivery (logged).
	Peers peers.Directory
	// Logf receives log lines; nil discards.
	Logf func(format string, args ...any)
	// Clock overrides time.Now in tests.
	Clock func() time.Time
}

type Rule struct {
	Bus      string            `json:"bus"`
	Name     string            `json:"name"`
	Pattern  string            `json:"pattern,omitempty"`  // event pattern JSON
	Schedule string            `json:"schedule,omitempty"` // stored; ticker in Phase 8
	State    string            `json:"state"`              // ENABLED | DISABLED
	Desc     string            `json:"desc,omitempty"`
	Targets  []Target          `json:"targets,omitempty"`
	Tags     map[string]string `json:"tags,omitempty"`
}

type Server struct {
	// contains filtered or unexported fields
}

type Store struct {
	// contains filtered or unexported fields
}

type Target struct {
	ID               string            `json:"id"`
	ARN              string            `json:"arn"`
	Input            string            `json:"input,omitempty"`      // literal input override
	InputPath        string            `json:"input_path,omitempty"` // $.path extraction
	InputTransformer *InputTransformer `json:"input_transformer,omitempty"`
}