rpcutilclient

package

Go to main page

Versions in this module

v0

v0.29.4

Sep 1, 2024

v0.29.3

Jul 29, 2024

v0.29.2

Jul 29, 2024

v0.29.1

Jul 17, 2024

v0.29.0

Jul 17, 2024

v0.28.0

Feb 3, 2024

v0.27.0

Mar 22, 2023

Changes in this version

type DaemonStatsOutput

+ func (d *DaemonStatsOutput) Events() int64

type InventoryOutput

+ func (d *InventoryOutput) Upgradable() bool

v0.26.2

Nov 7, 2022

v0.26.1

Aug 3, 2022

v0.26.0

Jun 23, 2022

Changes in this version

type AgentInventoryResult

+ func (d *AgentInventoryResult) AllOutputs() []*AgentInventoryOutput

type CollectiveInfoResult

+ func (d *CollectiveInfoResult) AllOutputs() []*CollectiveInfoOutput

type DaemonStatsResult

+ func (d *DaemonStatsResult) AllOutputs() []*DaemonStatsOutput

type GetConfigItemResult

+ func (d *GetConfigItemResult) AllOutputs() []*GetConfigItemOutput

type GetDataResult

+ func (d *GetDataResult) AllOutputs() []*GetDataOutput

type GetFactResult

+ func (d *GetFactResult) AllOutputs() []*GetFactOutput

type GetFactsResult

+ func (d *GetFactsResult) AllOutputs() []*GetFactsOutput

type InventoryResult

+ func (d *InventoryResult) AllOutputs() []*InventoryOutput

type PingResult

+ func (d *PingResult) AllOutputs() []*PingOutput

v0.25.1

Feb 25, 2022

v0.25.0

Feb 23, 2022

v0.24.1

Sep 21, 2021

v0.24.0

Sep 21, 2021

v0.23.0

Aug 24, 2021

Changes in this version

type InitializationOption

+ func Choria(fw ChoriaFramework) InitializationOption

type RpcutilClient

+ func (p *RpcutilClient) OptionReplyTo(t string) *RpcutilClient

type Stats

+ UniqueRequestID func() string

v0.22.0

Apr 22, 2021

v0.21.0

Mar 29, 2021

v0.20.2

Feb 3, 2021

v0.20.1

Feb 3, 2021

v0.20.0

Feb 3, 2021

Changes in this version

type ChoriaFramework

+ ProgressWidth func() int

+ type ExternalNS struct

+ func (p *ExternalNS) Discover(ctx context.Context, fw ChoriaFramework, filters []FilterFunc) ([]string, error)

+ func (p *ExternalNS) Reset()

+ type MetaNS struct

+ Agent string

+ DisablePipedDiscovery bool

+ Options *discovery.StandardOptions

+ func NewMetaNS(opts *discovery.StandardOptions, enablePipeMode bool) *MetaNS

+ func (p *MetaNS) Discover(ctx context.Context, fw ChoriaFramework, _ []FilterFunc) ([]string, error)

+ func (p *MetaNS) Reset()

type Stats

+ OverrideDiscoveryTime func(start time.Time, end time.Time)

v0.19.0

Jan 13, 2021

Changes in this version

+ const Aborted

+ const DisplayAll

+ const DisplayDDL

+ const DisplayFailed

+ const DisplayNone

+ const DisplayOK

+ const InvalidData

+ const MissingData

+ const OK

+ const UnknownAction

+ const UnknownError

+ func DDL() (*agent.DDL, error)

+ func DDLBytes() ([]byte, error)

+ type AgentInventoryOutput struct

+ func (d *AgentInventoryOutput) Agents() interface{}

+ func (d *AgentInventoryOutput) HashMap() map[string]interface{}

+ func (d *AgentInventoryOutput) JSON() ([]byte, error)

+ func (d *AgentInventoryOutput) ParseAgentInventoryOutput(target interface{}) error

+ func (d *AgentInventoryOutput) ResultDetails() *ResultDetails

+ type AgentInventoryRequester struct

+ func (d *AgentInventoryRequester) Do(ctx context.Context) (*AgentInventoryResult, error)

+ type AgentInventoryResult struct

+ func (d *AgentInventoryResult) EachOutput(h func(r *AgentInventoryOutput))

+ func (d *AgentInventoryResult) RenderResults(w io.Writer, format RenderFormat, displayMode DisplayMode, verbose bool, ...) error

+ func (d *AgentInventoryResult) Stats() Stats

+ type BroadcastNS struct

+ func (b *BroadcastNS) Discover(ctx context.Context, fw ChoriaFramework, filters []FilterFunc) ([]string, error)

+ func (b *BroadcastNS) Reset()

+ type ChoriaFramework interface

+ Certname func() string

+ Colorize func(c string, format string, a ...interface{}) string

+ Configuration func() *config.Config

+ Logger func(string) *logrus.Entry

+ MiddlewareServers func() (servers srvcache.Servers, err error)

+ NewConnector func(ctx context.Context, servers func() (srvcache.Servers, error), name string, ...) (conn choria.Connector, err error)

+ NewMessage func(payload string, agent string, collective string, msgType string, ...) (msg *choria.Message, err error)

+ NewReplyFromTransportJSON func(payload []byte, skipvalidate bool) (msg protocol.Reply, err error)

+ NewRequestID func() (string, error)

+ NewTransportFromJSON func(data string) (message protocol.TransportMessage, err error)

+ PQLQueryCertNames func(query string) ([]string, error)

+ SetLogger func(*logrus.Logger)

+ type CollectiveInfoOutput struct

+ func (d *CollectiveInfoOutput) Collectives() interface{}

+ func (d *CollectiveInfoOutput) HashMap() map[string]interface{}

+ func (d *CollectiveInfoOutput) JSON() ([]byte, error)

+ func (d *CollectiveInfoOutput) MainCollective() interface{}

+ func (d *CollectiveInfoOutput) ParseCollectiveInfoOutput(target interface{}) error

+ func (d *CollectiveInfoOutput) ResultDetails() *ResultDetails

+ type CollectiveInfoRequester struct

+ func (d *CollectiveInfoRequester) Do(ctx context.Context) (*CollectiveInfoResult, error)

+ type CollectiveInfoResult struct

+ func (d *CollectiveInfoResult) EachOutput(h func(r *CollectiveInfoOutput))

+ func (d *CollectiveInfoResult) RenderResults(w io.Writer, format RenderFormat, displayMode DisplayMode, verbose bool, ...) error

+ func (d *CollectiveInfoResult) Stats() Stats

+ type DaemonStatsOutput struct

+ func (d *DaemonStatsOutput) Agents() interface{}

+ func (d *DaemonStatsOutput) Configfile() interface{}

+ func (d *DaemonStatsOutput) Filtered() interface{}

+ func (d *DaemonStatsOutput) HashMap() map[string]interface{}

+ func (d *DaemonStatsOutput) JSON() ([]byte, error)

+ func (d *DaemonStatsOutput) ParseDaemonStatsOutput(target interface{}) error

+ func (d *DaemonStatsOutput) Passed() interface{}

+ func (d *DaemonStatsOutput) Pid() interface{}

+ func (d *DaemonStatsOutput) Replies() interface{}

+ func (d *DaemonStatsOutput) ResultDetails() *ResultDetails

+ func (d *DaemonStatsOutput) Starttime() interface{}

+ func (d *DaemonStatsOutput) Threads() interface{}

+ func (d *DaemonStatsOutput) Times() interface{}

+ func (d *DaemonStatsOutput) Total() interface{}

+ func (d *DaemonStatsOutput) Ttlexpired() interface{}

+ func (d *DaemonStatsOutput) Unvalidated() interface{}

+ func (d *DaemonStatsOutput) Validated() interface{}

+ func (d *DaemonStatsOutput) Version() interface{}

+ type DaemonStatsRequester struct

+ func (d *DaemonStatsRequester) Do(ctx context.Context) (*DaemonStatsResult, error)

+ type DaemonStatsResult struct

+ func (d *DaemonStatsResult) EachOutput(h func(r *DaemonStatsOutput))

+ func (d *DaemonStatsResult) RenderResults(w io.Writer, format RenderFormat, displayMode DisplayMode, verbose bool, ...) error

+ func (d *DaemonStatsResult) Stats() Stats

+ type DisplayMode uint8

+ type FilterFunc func(f *protocol.Filter) error

+ type GetConfigItemOutput struct

+ func (d *GetConfigItemOutput) HashMap() map[string]interface{}

+ func (d *GetConfigItemOutput) Item() interface{}

+ func (d *GetConfigItemOutput) JSON() ([]byte, error)

+ func (d *GetConfigItemOutput) ParseGetConfigItemOutput(target interface{}) error

+ func (d *GetConfigItemOutput) ResultDetails() *ResultDetails

+ func (d *GetConfigItemOutput) Value() interface{}

+ type GetConfigItemRequester struct

+ func (d *GetConfigItemRequester) Do(ctx context.Context) (*GetConfigItemResult, error)

+ type GetConfigItemResult struct

+ func (d *GetConfigItemResult) EachOutput(h func(r *GetConfigItemOutput))

+ func (d *GetConfigItemResult) RenderResults(w io.Writer, format RenderFormat, displayMode DisplayMode, verbose bool, ...) error

+ func (d *GetConfigItemResult) Stats() Stats

+ type GetDataOutput struct

+ func (d *GetDataOutput) HashMap() map[string]interface{}

+ func (d *GetDataOutput) JSON() ([]byte, error)

+ func (d *GetDataOutput) ParseGetDataOutput(target interface{}) error

+ func (d *GetDataOutput) ResultDetails() *ResultDetails

+ type GetDataRequester struct

+ func (d *GetDataRequester) Do(ctx context.Context) (*GetDataResult, error)

+ func (d *GetDataRequester) Query(v string) *GetDataRequester

+ type GetDataResult struct

+ func (d *GetDataResult) EachOutput(h func(r *GetDataOutput))

+ func (d *GetDataResult) RenderResults(w io.Writer, format RenderFormat, displayMode DisplayMode, verbose bool, ...) error

+ func (d *GetDataResult) Stats() Stats

+ type GetFactOutput struct

+ func (d *GetFactOutput) Fact() interface{}

+ func (d *GetFactOutput) HashMap() map[string]interface{}

+ func (d *GetFactOutput) JSON() ([]byte, error)

+ func (d *GetFactOutput) ParseGetFactOutput(target interface{}) error

+ func (d *GetFactOutput) ResultDetails() *ResultDetails

+ func (d *GetFactOutput) Value() interface{}

+ type GetFactRequester struct

+ func (d *GetFactRequester) Do(ctx context.Context) (*GetFactResult, error)

+ type GetFactResult struct

+ func (d *GetFactResult) EachOutput(h func(r *GetFactOutput))

+ func (d *GetFactResult) RenderResults(w io.Writer, format RenderFormat, displayMode DisplayMode, verbose bool, ...) error

+ func (d *GetFactResult) Stats() Stats

+ type GetFactsOutput struct

+ func (d *GetFactsOutput) HashMap() map[string]interface{}

+ func (d *GetFactsOutput) JSON() ([]byte, error)

+ func (d *GetFactsOutput) ParseGetFactsOutput(target interface{}) error

+ func (d *GetFactsOutput) ResultDetails() *ResultDetails

+ func (d *GetFactsOutput) Values() interface{}

+ type GetFactsRequester struct

+ func (d *GetFactsRequester) Do(ctx context.Context) (*GetFactsResult, error)

+ type GetFactsResult struct

+ func (d *GetFactsResult) EachOutput(h func(r *GetFactsOutput))

+ func (d *GetFactsResult) RenderResults(w io.Writer, format RenderFormat, displayMode DisplayMode, verbose bool, ...) error

+ func (d *GetFactsResult) Stats() Stats

+ type InitializationOption func(opts *initOptions)

+ func ConfigFile(f string) InitializationOption

+ func Discovery(ns NodeSource) InitializationOption

+ func DiscoveryMethod(m string) InitializationOption

+ func DiscoveryTimeout(t time.Duration) InitializationOption

+ func Logger(l *logrus.Entry) InitializationOption

+ func Progress() InitializationOption

+ type InventoryOutput struct

+ func (d *InventoryOutput) Agents() interface{}

+ func (d *InventoryOutput) Classes() interface{}

+ func (d *InventoryOutput) Collectives() interface{}

+ func (d *InventoryOutput) DataPlugins() interface{}

+ func (d *InventoryOutput) Facts() interface{}

+ func (d *InventoryOutput) HashMap() map[string]interface{}

+ func (d *InventoryOutput) JSON() ([]byte, error)

+ func (d *InventoryOutput) Machines() interface{}

+ func (d *InventoryOutput) MainCollective() interface{}

+ func (d *InventoryOutput) ParseInventoryOutput(target interface{}) error

+ func (d *InventoryOutput) ResultDetails() *ResultDetails

+ func (d *InventoryOutput) Version() interface{}

+ type InventoryRequester struct

+ func (d *InventoryRequester) Do(ctx context.Context) (*InventoryResult, error)

+ type InventoryResult struct

+ func (d *InventoryResult) EachOutput(h func(r *InventoryOutput))

+ func (d *InventoryResult) RenderResults(w io.Writer, format RenderFormat, displayMode DisplayMode, verbose bool, ...) error

+ func (d *InventoryResult) Stats() Stats

+ type Log interface

+ Debugf func(format string, args ...interface{})

+ Errorf func(format string, args ...interface{})

+ Fatalf func(format string, args ...interface{})

+ Infof func(format string, args ...interface{})

+ Panicf func(format string, args ...interface{})

+ Warnf func(format string, args ...interface{})

+ type Metadata struct

+ Author string

+ Description string

+ License string

+ Name string

+ Timeout int

+ URL string

+ Version string

+ type NodeSource interface

+ Discover func(ctx context.Context, fw ChoriaFramework, filters []FilterFunc) ([]string, error)

+ Reset func()

+ type PingOutput struct

+ func (d *PingOutput) HashMap() map[string]interface{}

+ func (d *PingOutput) JSON() ([]byte, error)

+ func (d *PingOutput) ParsePingOutput(target interface{}) error

+ func (d *PingOutput) Pong() interface{}

+ func (d *PingOutput) ResultDetails() *ResultDetails

+ type PingRequester struct

+ func (d *PingRequester) Do(ctx context.Context) (*PingResult, error)

+ type PingResult struct

+ func (d *PingResult) EachOutput(h func(r *PingOutput))

+ func (d *PingResult) RenderResults(w io.Writer, format RenderFormat, displayMode DisplayMode, verbose bool, ...) error

+ func (d *PingResult) Stats() Stats

+ type PuppetDBNS struct

+ func (p *PuppetDBNS) Discover(ctx context.Context, fw ChoriaFramework, filters []FilterFunc) ([]string, error)

+ func (p *PuppetDBNS) Reset()

+ type RenderFormat int

+ const JSONFormat

+ const TXTFooter

+ const TableFormat

+ const TextFormat

+ type ResultDetails struct

+ func (d *ResultDetails) OK() bool

+ func (d *ResultDetails) Sender() string

+ func (d *ResultDetails) StatusCode() StatusCode

+ func (d *ResultDetails) StatusMessage() string

+ type RpcutilClient struct

+ func Must(opts ...InitializationOption) (client *RpcutilClient)

+ func New(opts ...InitializationOption) (client *RpcutilClient, err error)

+ func (p *RpcutilClient) AgentInventory() *AgentInventoryRequester

+ func (p *RpcutilClient) AgentMetadata() *Metadata

+ func (p *RpcutilClient) CollectiveInfo() *CollectiveInfoRequester

+ func (p *RpcutilClient) DaemonStats() *DaemonStatsRequester

+ func (p *RpcutilClient) DiscoverNodes(ctx context.Context) (nodes []string, err error)

+ func (p *RpcutilClient) GetConfigItem(itemI string) *GetConfigItemRequester

+ func (p *RpcutilClient) GetData(sourceI string) *GetDataRequester

+ func (p *RpcutilClient) GetFact(factI string) *GetFactRequester

+ func (p *RpcutilClient) GetFacts(factsI string) *GetFactsRequester

+ func (p *RpcutilClient) Inventory() *InventoryRequester

+ func (p *RpcutilClient) OptionAgentFilter(a ...string) *RpcutilClient

+ func (p *RpcutilClient) OptionClassFilter(f ...string) *RpcutilClient

+ func (p *RpcutilClient) OptionCollective(c string) *RpcutilClient

+ func (p *RpcutilClient) OptionCombinedFilter(f ...string) *RpcutilClient

+ func (p *RpcutilClient) OptionCompoundFilter(f ...string) *RpcutilClient

+ func (p *RpcutilClient) OptionDiscoveryTimeout(t time.Duration) *RpcutilClient

+ func (p *RpcutilClient) OptionExprFilter(f string) *RpcutilClient

+ func (p *RpcutilClient) OptionFactFilter(f ...string) *RpcutilClient

+ func (p *RpcutilClient) OptionIdentityFilter(f ...string) *RpcutilClient

+ func (p *RpcutilClient) OptionInBatches(size int, sleep int) *RpcutilClient

+ func (p *RpcutilClient) OptionLimitMethod(m string) *RpcutilClient

+ func (p *RpcutilClient) OptionLimitSeed(s int64) *RpcutilClient

+ func (p *RpcutilClient) OptionLimitSize(s string) *RpcutilClient

+ func (p *RpcutilClient) OptionReset() *RpcutilClient

+ func (p *RpcutilClient) OptionTargets(t []string) *RpcutilClient

+ func (p *RpcutilClient) OptionWorkers(w int) *RpcutilClient

+ func (p *RpcutilClient) Ping() *PingRequester

+ type Stats interface

+ Action func() string

+ Agent func() string

+ All func() bool

+ DiscoveredCount func() int

+ DiscoveredNodes func() *[]string

+ DiscoveryDuration func() (time.Duration, error)

+ FailCount func() int

+ NoResponseFrom func() []string

+ OKCount func() int

+ PublishDuration func() (time.Duration, error)

+ RequestDuration func() (time.Duration, error)

+ ResponsesCount func() int

+ UnexpectedResponseFrom func() []string

+ type StatusCode uint8

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