inter

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

Changes in this version

type PluginType

+ func (t PluginType) String() string

v0.27.0

Mar 22, 2023

Changes in this version

+ const JsonLineDiscoveredKind

+ const JsonLineErrorKind

+ const JsonLineResultKind

+ const JsonLineStatsKind

+ const JsonLineSummariesKind

+ type JsonLineOutput struct

+ Aggregates json.RawMessage

+ Discovered int

+ DiscoveryMethod string

+ DiscoverySeconds float64

+ Error string

+ Kind string

+ ProtocolReply json.RawMessage

+ RPCReply json.RawMessage

+ Stats json.RawMessage

type RequestSignerConfig

+ RemoteSignerSeedFile func() (string, error)

type SecurityProvider

+ ShouldSignReplies func() bool

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

v0.26.2

Nov 7, 2022

Changes in this version

type Connector

+ InboxPrefix func() string

type ConnectorInfo

+ InboxPrefix func() string

type Framework

+ NewGovernor func(ctx context.Context, name string, conn Connector, opts ...governor.Option) (governor.Governor, Connector, error)

+ NewGovernorManager func(ctx context.Context, name string, limit uint64, maxAge time.Duration, ...) (governor.Manager, Connector, error)

type ProtocolConstructor

+ RequestProtocol func() protocol.ProtocolVersion

type SecurityProvider

+ BackingTechnology func() SecurityTechnology

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

+ ShouldAllowCaller func(data []byte, name string) (privileged bool, err error)

+ VerifySignatureBytes func(dat []byte, sig []byte, public ...[]byte) (should bool, signer string)

+ type SecurityTechnology int

+ const SecurityTechnologyED25519JWT

+ const SecurityTechnologyUnknown

+ const SecurityTechnologyX509

v0.26.1

Aug 3, 2022

Changes in this version

+ type SecurityProvider interface

+ CachePublicData func(data []byte, identity string) error

+ CachedPublicData func(identity string) ([]byte, error)

+ CallerIdentity func(caller string) (string, error)

+ CallerName func() string

+ ChecksumBytes func(data []byte) []byte

+ ChecksumString func(data string) []byte

+ ClientTLSConfig func() (*tls.Config, error)

+ Enroll func(ctx context.Context, wait time.Duration, cb func(digest string, try int)) error

+ HTTPClient func(secure bool) (*http.Client, error)

+ Identity func() string

+ IsRemoteSigning func() bool

+ PrivilegedVerifyByteSignature func(dat []byte, sig []byte, identity string) bool

+ PrivilegedVerifyStringSignature func(dat string, sig []byte, identity string) bool

+ Provider func() string

+ PublicCert func() (*x509.Certificate, error)

+ PublicCertPem func() (*pem.Block, error)

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

+ RemoteSignRequest func(ctx context.Context, str []byte) (signed []byte, err error)

+ SSLContext func() (*http.Transport, error)

+ SignBytes func(b []byte) (signature []byte, err error)

+ SignString func(s string) (signature []byte, err error)

+ TLSConfig func() (*tls.Config, error)

+ Validate func() ([]string, bool)

+ VerifyByteSignature func(str []byte, signature []byte, identity string) bool

+ VerifyCertificate func(certpem []byte, identity string) error

+ VerifyStringSignature func(str string, signature []byte, identity string) bool

v0.26.0

Jun 23, 2022

Changes in this version

+ type FlagApp interface

+ Command func(name, help string) *fisk.CmdClause

+ Flag func(name, help string) *fisk.FlagClause

v0.25.1

Feb 25, 2022

v0.25.0

Feb 23, 2022

Changes in this version

+ type DDLResolver interface

+ DDL func(ctx context.Context, kind string, name string, target interface{}, ...) error

+ DDLBytes func(ctx context.Context, kind string, name string, fw Framework) ([]byte, error)

+ DDLNames func(ctx context.Context, kind string, w Framework) ([]string, error)

+ String func() string

+ type Election interface

+ IsLeader func() bool

+ Start func(ctx context.Context) error

+ Stop func()

type Framework

+ DDLResolvers func() ([]DDLResolver, error)

+ NewElection func(ctx context.Context, conn Connector, name string, imported bool, ...) (Election, error)

+ NewElectionWithConn func(ctx context.Context, conn Connector, name string, imported bool, ...) (Election, Connector, error)

+ SignerSeedFile func() (f string, err error)

+ SignerTokenFile func() (f string, err error)

v0.24.1

Sep 21, 2021

v0.24.0

Sep 21, 2021

Changes in this version

+ const DirectRequestMessageType

+ const MessageMessageType

+ const ReplyMessageType

+ const RequestMessageType

+ const ServiceRequestMessageType

+ type AgentConnector interface

+ AgentBroadcastTarget func(collective string, agent string) string

+ ConnectedServer func() string

+ ConnectionOptions func() nats.Options

+ ConnectionStats func() nats.Statistics

+ QueueSubscribe func(ctx context.Context, name string, subject string, group string, ...) error

+ ServiceBroadcastTarget func(collective string, agent string) string

+ Unsubscribe func(name string) error

+ type ConfigurationProvider interface

+ Configuration func() *config.Config

+ type ConnectionManager interface

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

+ type Connector interface

+ AgentBroadcastTarget func(collective string, agent string) string

+ ChanQueueSubscribe func(name string, subject string, group string, capacity int) (chan ConnectorMessage, error)

+ Close func()

+ Connect func(ctx context.Context) (err error)

+ ConnectedServer func() string

+ ConnectionOptions func() nats.Options

+ ConnectionStats func() nats.Statistics

+ IsConnected func() bool

+ Nats func() *nats.Conn

+ NodeDirectedTarget func(collective string, identity string) string

+ Publish func(msg Message) error

+ PublishRaw func(target string, data []byte) error

+ PublishRawMsg func(msg *nats.Msg) error

+ QueueSubscribe func(ctx context.Context, name string, subject string, group string, ...) error

+ ReplyTarget func(msg Message) (string, error)

+ RequestRawMsgWithContext func(ctx context.Context, msg *nats.Msg) (*nats.Msg, error)

+ ServiceBroadcastTarget func(collective string, agent string) string

+ Unsubscribe func(name string) error

+ type ConnectorInfo interface

+ ConnectedServer func() string

+ ConnectionOptions func() nats.Options

+ ConnectionStats func() nats.Statistics

+ type ConnectorMessage interface

+ Data func() []byte

+ Msg func() interface{}

+ Reply func() string

+ Subject func() string

+ type Framework interface

+ BuildInfo func() *build.Info

+ CallerID func() string

+ Certname func() string

+ ClientTLSConfig func() (*tls.Config, error)

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

+ ConfigureProvisioning func()

+ DisableTLSVerify func() bool

+ Enroll func(ctx context.Context, wait time.Duration, cb func(digest string, try int)) error

+ FacterCmd func() string

+ FacterDomain func() (string, error)

+ FacterFQDN func() (string, error)

+ FacterStringFact func(fact string) (string, error)

+ FederationCollectives func() (collectives []string)

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

+ Getuid func() int

+ GovernorSubject func(name string) string

+ HTTPClient func(secure bool) (*http.Client, error)

+ HasCollective func(collective string) bool

+ IsFederated func() (result bool)

+ KV func(ctx context.Context, conn Connector, bucket string, create bool, ...) (kv.KV, error)

+ KVWithConn func(ctx context.Context, conn Connector, bucket string, create bool, ...) (kv.KV, Connector, error)

+ Logger func(component string) *logrus.Entry

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

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

+ OverrideCertname func() string

+ PQLQuery func(query string) ([]byte, error)

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

+ ParseSignerTokenUnverified func() (token *jwt.Token, claims jwt.MapClaims, err error)

+ ProgressWidth func() int

+ PrometheusTextFileDir func() string

+ ProvisionMode func() bool

+ ProvisioningServers func(ctx context.Context) (srvcache.Servers, error)

+ PublicCert func() (*x509.Certificate, error)

+ PuppetAIOCmd func(command string, def string) string

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

+ PuppetSetting func(setting string) (string, error)

+ QuerySrvRecords func(records []string) (srvcache.Servers, error)

+ SetLogWriter func(out io.Writer)

+ SetLogger func(logger *logrus.Logger)

+ SetupLogging func(debug bool) (err error)

+ ShouldUseNGS func() bool

+ SignerToken func() (token string, err error)

+ SupportsProvisioning func() bool

+ TLSConfig func() (*tls.Config, error)

+ TrySrvLookup func(names []string, defaultSrv srvcache.Server) (srvcache.Server, error)

+ UniqueID func() string

+ UniqueIDFromUnverifiedToken func() (caller string, id string, token string, err error)

+ ValidateSecurity func() (errors []string, ok bool)

+ type Message interface

+ Agent func() string

+ Base64Payload func() string

+ CacheTransport func()

+ CallerID func() string

+ Collective func() string

+ CustomTarget func() string

+ DiscoveredHosts func() []string

+ ExpectedMessageID func() string

+ Filter func() *protocol.Filter

+ IsCachedTransport func() bool

+ NotifyPublish func()

+ OnPublish func(func())

+ Payload func() string

+ ProtocolVersion func() string

+ ReplyTarget func() string

+ ReplyTo func() string

+ Request func() Message

+ RequestID func() string

+ SenderID func() string

+ SetBase64Payload func(payload string) error

+ SetCollective func(string) error

+ SetCustomTarget func(string)

+ SetDiscoveredHosts func(hosts []string)

+ SetExpectedMsgID func(id string) error

+ SetFilter func(*protocol.Filter)

+ SetPayload func(string)

+ SetProtocolVersion func(string)

+ SetReplyTo func(string) error

+ SetTTL func(int)

+ SetType func(string) error

+ String func() string

+ TTL func() int

+ TimeStamp func() time.Time

+ Transport func() (protocol.TransportMessage, error)

+ Type func() string

+ Validate func() (bool, error)

+ ValidateTTL func() bool

+ type Pluggable interface

+ PluginInstance func() interface{}

+ PluginName func() string

+ PluginType func() PluginType

+ PluginVersion func() string

+ type PluginType int

+ const AgentPlugin

+ const AgentProviderPlugin

+ const ConfigMutatorPlugin

+ const DataPlugin

+ const MachinePlugin

+ const MachineWatcherPlugin

+ const ProvisionTargetResolverPlugin

+ const UnknownPlugin

+ type ProtocolConstructor interface

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

+ NewMessageFromRequest func(req protocol.Request, replyto string) (Message, error)

+ NewReply func(request protocol.Request) (reply protocol.Reply, err error)

+ NewReplyFromMessage func(version string, msg Message) (rep protocol.Reply, err error)

+ NewReplyFromSecureReply func(sr protocol.SecureReply) (reply protocol.Reply, err error)

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

+ NewReplyTransportForMessage func(msg Message, request protocol.Request) (protocol.TransportMessage, error)

+ NewRequest func(version string, agent string, senderid string, callerid string, ttl int, ...) (request protocol.Request, err error)

+ NewRequestFromMessage func(version string, msg Message) (req protocol.Request, err error)

+ NewRequestFromSecureRequest func(sr protocol.SecureRequest) (request protocol.Request, err error)

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

+ NewRequestID func() (string, error)

+ NewRequestMessageFromTransportJSON func(payload []byte) (Message, error)

+ NewRequestTransportForMessage func(msg Message, version string) (protocol.TransportMessage, error)

+ NewSecureReply func(reply protocol.Reply) (secure protocol.SecureReply, err error)

+ NewSecureReplyFromTransport func(message protocol.TransportMessage, skipvalidate bool) (secure protocol.SecureReply, err error)

+ NewSecureRequest func(request protocol.Request) (secure protocol.SecureRequest, err error)

+ NewSecureRequestFromTransport func(message protocol.TransportMessage, skipvalidate bool) (secure protocol.SecureRequest, err error)

+ NewTransportForSecureReply func(reply protocol.SecureReply) (message protocol.TransportMessage, err error)

+ NewTransportForSecureRequest func(request protocol.SecureRequest) (message protocol.TransportMessage, err error)

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

+ NewTransportMessage func(version string) (message protocol.TransportMessage, err error)

+ type RawNATSConnector interface

+ PublishRaw func(target string, data []byte) error

+ PublishRawMsg func(msg *nats.Msg) error

+ RequestRawMsgWithContext func(ctx context.Context, msg *nats.Msg) (*nats.Msg, error)

+ type RequestSigner interface

+ Kind func() string

+ Sign func(ctx context.Context, request []byte, cfg RequestSignerConfig) ([]byte, error)

+ type RequestSignerConfig interface

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

+ RemoteSignerURL func() (*url.URL, error)

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