core

package

v0.1.2 Latest Latest Go to latest Published: Sep 3, 2026 License: MIT Imports: 13 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

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

func New(ctx context.Context, config *types.Config) (*Store, error)

func (c *Store) GetClient() pb.CoreRPCClient

func (c *Store) GetIdentifier(ctx context.Context) string

func (c *Store) GetNode(ctx context.Context, nodename string) (*types.Node, error)

func (c *Store) ListRunningWorkloadIDs(ctx context.Context) ([]string, error)

func (c *Store) SetNodeStatus(ctx context.Context, ttl int64) error

SetNodeStatus always reports the node as alive, core expires the status by ttl.

func (c *Store) SetWorkloadStatus(ctx context.Context, status *types.WorkloadStatus) error

func (c *Store) WorkloadExists(ctx context.Context, ID string) (bool, error)

WorkloadExists reports whether core still owns the workload; core answers a missing one with its count or not-exists sentinel.