memoryjobs

package

v0.13.21 Latest Latest Go to latest Published: Oct 26, 2026 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Package memoryjobs owns durable background learning jobs. Hosts provide evidence/model callbacks and short-lived permission to use idle capacity.

This section is empty.

This section is empty.

This section is empty.

type Callback struct{ URL, Token string }

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

func Open(ctx context.Context, path string, callbacks map[string]Callback) (*Service, error)

func (s *Service) Close() error

func (s *Service) Jobs(ctx context.Context, app, bank string) ([]sdk.MemoryLearningJob, error)

func (s *Service) Retry(ctx context.Context, app, id string) error

func (s *Service) Run(ctx context.Context)

func (s *Service) SetPolicy(p sdk.MemoryLearningPolicy) error

func (s *Service) Submit(ctx context.Context, j sdk.MemoryLearningJob) (sdk.MemoryLearningJob, error)

Submit is idempotent for a source revision. A changed revision supersedes queued/running work without allowing the previous writer to finish it.