triggerv1

type BudgetSummary struct {
	TokenCount  int64   `protobuf:"varint,1,opt,name=token_count,json=tokenCount,proto3" json:"token_count,omitempty"`
	CostUsd     float64 `protobuf:"fixed64,2,opt,name=cost_usd,json=costUsd,proto3" json:"cost_usd,omitempty"`
	WallClockMs int64   `protobuf:"varint,3,opt,name=wall_clock_ms,json=wallClockMs,proto3" json:"wall_clock_ms,omitempty"`
	Iterations  int64   `protobuf:"varint,4,opt,name=iterations,proto3" json:"iterations,omitempty"`
	// contains filtered or unexported fields
}

type CancelRunRequest struct {
	RunId  string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

type GetRunRequest struct {
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

type InvokeRequest struct {
	AgentName    string `protobuf:"bytes,1,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"`
	AgentVersion string `protobuf:"bytes,2,opt,name=agent_version,json=agentVersion,proto3" json:"agent_version,omitempty"`
	Payload      []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	ContentType  string `protobuf:"bytes,4,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// idempotency_key ensures exactly-once semantics when combined with payload
	// hash. See file-level idempotency documentation for details.
	IdempotencyKey string            `protobuf:"bytes,5,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	Metadata       map[string]string `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

type InvokeResponse struct {
	Run *Run `protobuf:"bytes,1,opt,name=run,proto3" json:"run,omitempty"`
	// contains filtered or unexported fields
}

type ListRunsRequest struct {

	// Optional: filter by agent name.
	AgentName string `protobuf:"bytes,1,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"`
	// Optional: filter by run status.
	Status RunStatus `protobuf:"varint,2,opt,name=status,proto3,enum=agentpaas.trigger.v1.RunStatus" json:"status,omitempty"`
	// Maximum number of runs to return. Server may cap this value.
	PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Token from a previous ListRunsResponse to request the next page.
	PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

type ListRunsResponse struct {
	Runs          []*Run `protobuf:"bytes,1,rep,name=runs,proto3" json:"runs,omitempty"`
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

type Run struct {
	RunId         string                 `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	AgentName     string                 `protobuf:"bytes,2,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"`
	AgentVersion  string                 `protobuf:"bytes,3,opt,name=agent_version,json=agentVersion,proto3" json:"agent_version,omitempty"`
	Status        RunStatus              `protobuf:"varint,4,opt,name=status,proto3,enum=agentpaas.trigger.v1.RunStatus" json:"status,omitempty"`
	CreatedAt     *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	StartedAt     *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	FinishedAt    *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	Error         string                 `protobuf:"bytes,8,opt,name=error,proto3" json:"error,omitempty"`
	BudgetSummary *BudgetSummary         `protobuf:"bytes,9,opt,name=budget_summary,json=budgetSummary,proto3" json:"budget_summary,omitempty"`
	PolicyDigest  string                 `protobuf:"bytes,10,opt,name=policy_digest,json=policyDigest,proto3" json:"policy_digest,omitempty"`
	ImageDigest   string                 `protobuf:"bytes,11,opt,name=image_digest,json=imageDigest,proto3" json:"image_digest,omitempty"`
	// contains filtered or unexported fields
}

type RunStatus int32

type TriggerServiceClient interface {
	// Invoke triggers a single agent run and returns the Run immediately.
	Invoke(ctx context.Context, in *InvokeRequest, opts ...grpc.CallOption) (*InvokeResponse, error)
	// InvokeStream triggers an agent run and returns a stream of Run updates
	// via server-sent events (SSE).
	InvokeStream(ctx context.Context, in *InvokeRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[InvokeResponse], error)
	// GetRun retrieves a run by its ID.
	GetRun(ctx context.Context, in *GetRunRequest, opts ...grpc.CallOption) (*Run, error)
	// CancelRun cancels a pending or running run.
	CancelRun(ctx context.Context, in *CancelRunRequest, opts ...grpc.CallOption) (*Run, error)
	// ListRuns lists runs with optional filters and pagination.
	ListRuns(ctx context.Context, in *ListRunsRequest, opts ...grpc.CallOption) (*ListRunsResponse, error)
}

type TriggerServiceServer interface {
	// Invoke triggers a single agent run and returns the Run immediately.
	Invoke(context.Context, *InvokeRequest) (*InvokeResponse, error)
	// InvokeStream triggers an agent run and returns a stream of Run updates
	// via server-sent events (SSE).
	InvokeStream(*InvokeRequest, grpc.ServerStreamingServer[InvokeResponse]) error
	// GetRun retrieves a run by its ID.
	GetRun(context.Context, *GetRunRequest) (*Run, error)
	// CancelRun cancels a pending or running run.
	CancelRun(context.Context, *CancelRunRequest) (*Run, error)
	// ListRuns lists runs with optional filters and pagination.
	ListRuns(context.Context, *ListRunsRequest) (*ListRunsResponse, error)
	// contains filtered or unexported methods
}

type TriggerService_InvokeStreamClient = grpc.ServerStreamingClient[InvokeResponse]

type TriggerService_InvokeStreamServer = grpc.ServerStreamingServer[InvokeResponse]

type UnimplementedTriggerServiceServer struct{}

type UnsafeTriggerServiceServer interface {
	// contains filtered or unexported methods
}