api

package

v3.0.0-beta10 Latest Latest Go to latest Published: Dec 12, 2025 License: Apache-2.0 Imports: 11 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 ¶

type GetClusterStatus
- func NewGetClusterStatus(t api.ClientInterface) *GetClusterStatus
type GetEvents
- func NewGetEvents(t api.ClientInterface) *GetEvents
type GetLogs
- func NewGetLogs(t api.ClientInterface, nodename string) *GetLogs

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type GetClusterStatus ¶

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

func NewGetClusterStatus ¶

func NewGetClusterStatus(t api.ClientInterface) *GetClusterStatus

func (GetClusterStatus) Get ¶

func (t GetClusterStatus) Get() ([]byte, error)

Get fetches the daemon status structure from the agent api

func (*GetClusterStatus) SetNamespace ¶

func (t *GetClusterStatus) SetNamespace(s string) *GetClusterStatus

func (*GetClusterStatus) SetSelector ¶

func (t *GetClusterStatus) SetSelector(s string) *GetClusterStatus

type GetEvents ¶

type GetEvents struct {
	Limit    *uint64
	Filters  []string
	Wait     bool
	Duration *time.Duration
	// contains filtered or unexported fields
}

GetEvents describes the events request options.

func NewGetEvents ¶

func NewGetEvents(t api.ClientInterface) *GetEvents

NewGetEvents allocates a EventsCmdConfig struct and sets default values to its keys.

func (*GetEvents) Do ¶

func (t *GetEvents) Do() (chan event.Event, error)

Do fetches an Event stream from the agent api

func (*GetEvents) GetRaw ¶

func (t *GetEvents) GetRaw() (chan []byte, error)

GetRaw fetches an event json RawMessage stream from the agent api

func (*GetEvents) GetReader ¶

func (t *GetEvents) GetReader() (event.ReadCloser, error)

GetReader returns event.ReadCloser for GetEventReader

func (*GetEvents) NewTimeoutReader ¶

func (t *GetEvents) NewTimeoutReader(timeout time.Duration) (event.ReadCloser, error)

NewTimeoutReader returns a non-blocking event.ReadCloser that yields nil if no events are read within the specified timeout

func (*GetEvents) SetDuration ¶

func (t *GetEvents) SetDuration(duration time.Duration) *GetEvents

func (*GetEvents) SetFilter ¶

func (t *GetEvents) SetFilter(filters ...string) *GetEvents

func (*GetEvents) SetFilters ¶

func (t *GetEvents) SetFilters(filters []string) *GetEvents

func (*GetEvents) SetLimit ¶

func (t *GetEvents) SetLimit(limit uint64) *GetEvents

func (*GetEvents) SetNamespace ¶

func (t *GetEvents) SetNamespace(s string) *GetEvents

func (*GetEvents) SetNodename ¶

func (t *GetEvents) SetNodename(s string) *GetEvents

func (*GetEvents) SetRelatives ¶

func (t *GetEvents) SetRelatives(s bool) *GetEvents

func (*GetEvents) SetSelector ¶

func (t *GetEvents) SetSelector(s string) *GetEvents

func (*GetEvents) SetWait ¶

func (t *GetEvents) SetWait(wait bool) *GetEvents

type GetLogs ¶

type GetLogs struct {
	Filters *[]string
	Paths   *[]string
	Lines   *int
	Follow  *bool
	// contains filtered or unexported fields
}

GetLogs describes the events request options.

func NewGetLogs ¶

func NewGetLogs(t api.ClientInterface, nodename string) *GetLogs

NewGetLogs allocates a EventsCmdConfig struct and sets default values to its keys.

func (GetLogs) Do ¶

func (t GetLogs) Do() (chan event.Event, error)

Do fetches an Event stream from the agent api

func (GetLogs) GetRaw ¶

func (t GetLogs) GetRaw() (chan []byte, error)

GetRaw fetches an event json RawMessage stream from the agent api

func (*GetLogs) GetReader ¶

func (t *GetLogs) GetReader() (event.ReadCloser, error)

GetReader returns event.ReadCloser for GetLogReader

func (*GetLogs) SetFilters ¶

func (t *GetLogs) SetFilters(filters *[]string) *GetLogs

func (*GetLogs) SetFollow ¶

func (t *GetLogs) SetFollow(n *bool) *GetLogs

func (*GetLogs) SetLines ¶

func (t *GetLogs) SetLines(n *int) *GetLogs

func (*GetLogs) SetPaths ¶

func (t *GetLogs) SetPaths(l *[]string) *GetLogs

Source Files ¶

View all Source files

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