tracts_api

func (*TractsImpl) CreateTract ¶

func (t *TractsImpl) CreateTract(ctx context.Context, req *pb.CreateTract_Request) (*pb.CreateTract_Response, error)

func (*TractsImpl) CreateTrigger ¶

func (t *TractsImpl) CreateTrigger(
	ctx context.Context,
	req *pb.CreateTrigger_Request,
) (*pb.CreateTrigger_Response, error)

func (*TractsImpl) DeleteTract ¶

func (t *TractsImpl) DeleteTract(ctx context.Context, req *pb.DeleteTract_Request) (*pb.DeleteTract_Response, error)

func (*TractsImpl) DeleteTrigger ¶

func (t *TractsImpl) DeleteTrigger(
	ctx context.Context,
	req *pb.DeleteTrigger_Request,
) (*pb.DeleteTrigger_Response, error)

func (*TractsImpl) Gateway ¶

func (t *TractsImpl) Gateway(ctx context.Context, endpoint string, opts ...grpc.DialOption) (string, http.Handler)

func (*TractsImpl) GetRun ¶

func (t *TractsImpl) GetRun(ctx context.Context, req *pb.GetRun_Request) (*pb.GetRun_Response, error)

func (*TractsImpl) GetTract ¶

func (t *TractsImpl) GetTract(ctx context.Context, req *pb.GetTract_Request) (*pb.GetTract_Response, error)

func (*TractsImpl) GetTractTemplate ¶

func (t *TractsImpl) GetTractTemplate(
	ctx context.Context,
	req *pb.GetTractTemplate_Request,
) (*pb.GetTractTemplate_Response, error)

func (*TractsImpl) InstantiateTractTemplate ¶

func (t *TractsImpl) InstantiateTractTemplate(
	ctx context.Context,
	req *pb.InstantiateTractTemplate_Request,
) (*pb.InstantiateTractTemplate_Response, error)

func (*TractsImpl) LinkTrigger ¶

func (t *TractsImpl) LinkTrigger(ctx context.Context, req *pb.LinkTrigger_Request) (*pb.LinkTrigger_Response, error)

func (*TractsImpl) ListRuns ¶

func (t *TractsImpl) ListRuns(ctx context.Context, req *pb.ListRuns_Request) (*pb.ListRuns_Response, error)

func (*TractsImpl) ListTractTemplates ¶

func (t *TractsImpl) ListTractTemplates(
	ctx context.Context,
	req *pb.ListTractTemplates_Request,
) (*pb.ListTractTemplates_Response, error)

func (*TractsImpl) ListTractTools ¶

func (t *TractsImpl) ListTractTools(
	ctx context.Context,
	_ *pb.ListTractTools_Request,
) (*pb.ListTractTools_Response, error)

func (*TractsImpl) ListTracts ¶

func (t *TractsImpl) ListTracts(ctx context.Context, _ *pb.ListTracts_Request) (*pb.ListTracts_Response, error)

ListTracts assembles each card's linked-trigger summaries and last-run badge from the per-tract link/run listings service.TractService already exposes — no new aggregation method needed on the service.

func (*TractsImpl) ListTriggerSources ¶

func (t *TractsImpl) ListTriggerSources(
	ctx context.Context,
	_ *pb.ListTriggerSources_Request,
) (*pb.ListTriggerSources_Response, error)

func (*TractsImpl) ListTriggers ¶

func (t *TractsImpl) ListTriggers(ctx context.Context, _ *pb.ListTriggers_Request) (*pb.ListTriggers_Response, error)

func (*TractsImpl) PublishTractTemplate ¶

func (t *TractsImpl) PublishTractTemplate(
	ctx context.Context,
	req *pb.PublishTractTemplate_Request,
) (*pb.PublishTractTemplate_Response, error)

func (*TractsImpl) Register ¶

func (t *TractsImpl) Register(srv grpc.ServiceRegistrar)

func (*TractsImpl) RetryRun ¶

func (t *TractsImpl) RetryRun(ctx context.Context, req *pb.RetryRun_Request) (*pb.RetryRun_Response, error)

RetryRun fires a new run that replays runUuid's own trigger_uuid/trigger_payload/started_by verbatim — no new Trigger row is ever created, so the original and the retried run end up pointing at the same trigger (or both uuid.Nil, for a retried manual run). Same fire-and- forget shape as RunTract: the run's outcome is visible via ListRuns/GetRun.

func (*TractsImpl) RotateTriggerToken ¶

func (t *TractsImpl) RotateTriggerToken(
	ctx context.Context,
	req *pb.RotateTriggerToken_Request,
) (*pb.RotateTriggerToken_Response, error)

func (*TractsImpl) RunTract ¶

func (t *TractsImpl) RunTract(ctx context.Context, req *pb.RunTract_Request) (*pb.RunTract_Response, error)

RunTract fires a manual run and returns immediately — the same fire-and-forget shape as the tract webhook: the run's outcome is visible via ListRuns/GetRun. The engine is spawned against t.baseCtx (the server-lifecycle context), not ctx, which is cancelled the moment this RPC returns.

func (*TractsImpl) SetTractEnabled ¶

func (t *TractsImpl) SetTractEnabled(
	ctx context.Context,
	req *pb.SetTractEnabled_Request,
) (*pb.SetTractEnabled_Response, error)

func (*TractsImpl) SetTriggerEnabled ¶

func (t *TractsImpl) SetTriggerEnabled(
	ctx context.Context,
	req *pb.SetTriggerEnabled_Request,
) (*pb.SetTriggerEnabled_Response, error)

func (*TractsImpl) UnlinkTrigger ¶

func (t *TractsImpl) UnlinkTrigger(
	ctx context.Context,
	req *pb.UnlinkTrigger_Request,
) (*pb.UnlinkTrigger_Response, error)

func (*TractsImpl) UnpublishTractTemplate ¶

func (t *TractsImpl) UnpublishTractTemplate(
	ctx context.Context,
	req *pb.UnpublishTractTemplate_Request,
) (*pb.UnpublishTractTemplate_Response, error)

func (*TractsImpl) UpdateTract ¶

func (t *TractsImpl) UpdateTract(ctx context.Context, req *pb.UpdateTract_Request) (*pb.UpdateTract_Response, error)

func (*TractsImpl) WatchRun ¶

func (t *TractsImpl) WatchRun(req *pb.WatchRun_Request, stream pb.TractsAPI_WatchRunServer) error

WatchRun streams periodic snapshots of a run's status and steps until the run reaches a terminal state (done/failed) or the client disconnects. It is a thin polling wrapper around GetRun — no pubsub/event hook exists in the engine, and this is a transport-layer concern only.