postgres

Feb 24, 2026

Changes in this version

+ type Postgres struct

+ func NewPostgres(conf *config.Postgres) (*Postgres, error)

+ func (db *Postgres) Close()

+ func (db *Postgres) DeleteNode(ctx context.Context, req *scheduler.Node) (*scheduler.DeleteNodeResponse, error)

+ func (db *Postgres) GetNode(ctx context.Context, req *scheduler.GetNodeRequest) (*scheduler.Node, error)

+ func (db *Postgres) GetTask(ctx context.Context, req *tes.GetTaskRequest) (*tes.Task, error)

+ func (db *Postgres) Init() error

+ func (db *Postgres) ListNodes(ctx context.Context, req *scheduler.ListNodesRequest) (*scheduler.ListNodesResponse, error)

+ func (db *Postgres) ListTasks(ctx context.Context, req *tes.ListTasksRequest) (*tes.ListTasksResponse, error)

+ func (db *Postgres) PutNode(ctx context.Context, node *scheduler.Node) (*scheduler.PutNodeResponse, error)

+ func (db *Postgres) ReadQueue(n int) []*tes.Task

+ func (db *Postgres) WriteEvent(ctx context.Context, req *events.Event) error

+ type TaskCore struct

+ DataJSON []byte

+ ID string

+ Owner string

+ StateStr string