postgres

package

v0.12.2 Latest Latest Go to latest Published: Feb 23, 2026 License: MIT Imports: 18 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Postgres struct {
	scheduler.UnimplementedSchedulerServiceServer
	// contains filtered or unexported fields
}

Postgres provides a PostgreSQL database server backend.

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

func (db *Postgres) Close()

Close closes the database session.

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

DeleteNode deletes a node

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

GetNode gets a node

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

GetTask gets a task.

func (db *Postgres) Init() error

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

ListNodes is an API endpoint that returns a list of nodes.

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

ListTasks returns a list of tasks.

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

PutNode is an RPC endpoint that is used by nodes to send heartbeats and status updates.

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

ReadQueue returns a slice of queued Tasks. Up to "n" tasks are returned.

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

WriteEvent creates an event for the server to handle.

type TaskCore struct {
	ID       string `db:"id"`
	Owner    string `db:"owner"`
	StateStr string `db:"state"`
	DataJSON []byte `db:"data"`
}

The PostgreSQL struct for minimal projection (only fields outside the JSONB blob)