core

package

v0.1.0 Latest Latest Go to latest Published: Aug 25, 2026 License: MIT Imports: 10 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 Get(ctx context.Context, config *types.Config) (*Store, error)

Get returns the process-wide core store, creating it on first call.

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) GetNodeStatus(ctx context.Context, nodename string) (*types.NodeStatus, 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, ttl int64) error