run

Documentation

Index

• func Execute(ctx context.Context, jobs []model.Job, cfg *model.RuntimeConfig) error
• type ClaudeMessage
• type TokenUsage
  • func (u *TokenUsage) Add(other TokenUsage)
  • func (u *TokenUsage) Total() int

Functions

func Execute

func Execute(ctx context.Context, jobs []model.Job, cfg *model.RuntimeConfig) error

Execute runs the prepared jobs and manages shutdown, retries, and summaries.

Types

type ClaudeMessage

type ClaudeMessage struct {
	Type    string `json:"type"`
	Message struct {
		Role    string `json:"role"`
		Content []struct {
			Type    string `json:"type"`
			Text    string `json:"text"`
			Content string `json:"content"`
		} `json:"content"`
		Usage struct {
			InputTokens         int `json:"input_tokens"`
			CacheCreationTokens int `json:"cache_creation_input_tokens"`
			CacheReadTokens     int `json:"cache_read_input_tokens"`
			OutputTokens        int `json:"output_tokens"`
			CacheCreation       struct {
				Ephemeral5mTokens int `json:"ephemeral_5m_input_tokens"`
				Ephemeral1hTokens int `json:"ephemeral_1h_input_tokens"`
			} `json:"cache_creation"`
		} `json:"usage"`
	} `json:"message"`
}

type TokenUsage

type TokenUsage struct {
	InputTokens         int
	CacheCreationTokens int
	CacheReadTokens     int
	OutputTokens        int
	Ephemeral5mTokens   int
	Ephemeral1hTokens   int
}

func (*TokenUsage) Add

func (u *TokenUsage) Add(other TokenUsage)

func (*TokenUsage) Total

func (u *TokenUsage) Total() int