resourceset

package

v3.0.0-beta14 Latest Latest Go to latest Published: Jan 21, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/opensvc/om3

Links

Open Source Insights

Documentation ¶

Index ¶

func FormatSectionName(driverGroupName, name string) string
func IsSubsetSection(s string) bool
func SubsetSectionToName(s string) string
type DoFunc
type L
- func NewList() L
type ResourceLister
type T

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func FormatSectionName ¶

func FormatSectionName(driverGroupName, name string) string

FormatSectionName returns the resourceset section name for a given driver group name and subset name.

func IsSubsetSection ¶

func IsSubsetSection(s string) bool

func SubsetSectionToName ¶

func SubsetSectionToName(s string) string

Types ¶

type DoFunc ¶

type DoFunc func(context.Context, resource.Driver) error

type L ¶

type L []*T

func NewList ¶

func NewList() L

func (L) Do ¶

func (t L) Do(ctx context.Context, l ResourceLister, barrier, desc string, fn DoFunc) error

Do executes fn on every resourceset of the actor. The barrier can be hit on a resource delayed by a resource link (e.g. ip.cni depending on container.docker)

e.g.

with resourcesets [[ip#1 ip#2(netns=container#1) ip#3] [container#1 container#2]]
with barrier ip#2
with action start (i.e. ascending)

does:
                                                hasHitBarrier  fn executed on  comment
                                                -------------  --------------  -------
  rset[ip#1 ip#2(netns=container#1) ip#3].Do    false          ip#1 ip#3       ip#2 is skipped, depends on container#1
  rset[container#1 container#2].Do              true           container#1     then ip#2 via linkWrap() => ErrBarrier

func (L) Len ¶

func (t L) Len() int

func (L) Less ¶

func (t L) Less(i, j int) bool

func (L) Reverse ¶

func (t L) Reverse()

func (L) Swap ¶

func (t L) Swap(i, j int)

type ResourceLister ¶

type ResourceLister interface {
	Resources() resource.Drivers
	ReconfigureResource(resource.Driver) error
	IsDesc() bool
}

type T ¶

type T struct {
	Name           string
	SectionName    string
	DriverGroup    driver.Group
	Parallel       bool
	PG             *pg.Config
	ResourceLister ResourceLister
	// contains filtered or unexported fields
}

func Generic ¶

func Generic(driverGroupName string) (*T, error)

Generic allocates and initializes a new resourceset for a given driver group, and return an error if this name is not valid.

func New ¶

func New() *T

New allocates and initializes a new resourceset

func Parse ¶

func Parse(s string) (*T, error)

Parse allocates and initializes new resourceset for a given name, and return an error if the name is not valid.

func (T) Do ¶

func (t T) Do(ctx context.Context, l ResourceLister, barrier, desc string, fn DoFunc) (hasHitBarrier bool, err error)

func (T) Fullname ¶

func (t T) Fullname() string

func (*T) Log ¶

func (t *T) Log() *plog.Logger

Log returns the resource logger

func (T) ReconfigureResource ¶

func (t T) ReconfigureResource(r resource.Driver) error

func (T) Resources ¶

func (t T) Resources() resource.Drivers

Resources returns the list of resources handled by the resourceset. This function make the resourceset a ResourceLister.

func (*T) SetLogger ¶

func (t *T) SetLogger(parent *plog.Logger)

SetLogger configures a logger from a parent logger, adding the "subset" attribute

func (T) String ¶

func (t T) String() string

Source Files ¶

View all Source files

resourceset.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL