choria

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 Framework

+ func (fw *Framework) InProcessConnProvider() nats.InProcessConnProvider

+ func (fw *Framework) SetInProcessConnProvider(p nats.InProcessConnProvider)

v0.27.0

Mar 22, 2023

Changes in this version

+ type Option func(fw *Framework) error

+ func WithCustomRequestSigner(s inter.RequestSigner) Option

v0.26.2

Nov 7, 2022

Changes in this version

+ func Ed24419Verify(pk ed25519.PublicKey, msg []byte, sig []byte) (bool, error)

type Connection

+ func (conn *Connection) InboxPrefix() string

type Framework

+ func (fw *Framework) NewGovernor(ctx context.Context, name string, conn inter.Connector, ...) (governor.Governor, inter.Connector, error)

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

+ func (fw *Framework) RequestProtocol() protocol.ProtocolVersion

v0.26.1

Aug 3, 2022

v0.26.0

Jun 23, 2022

v0.25.1

Feb 25, 2022

v0.25.0

Feb 23, 2022

Changes in this version

+ func Ed25519KeyPair() (ed25519.PublicKey, ed25519.PrivateKey, error)

+ func Ed25519KeyPairFromSeed(seed []byte) (ed25519.PublicKey, ed25519.PrivateKey, error)

+ func Ed25519KeyPairFromSeedFile(f string) (ed25519.PublicKey, ed25519.PrivateKey, error)

+ func Ed25519KeyPairToFile(f string) (ed25519.PublicKey, ed25519.PrivateKey, error)

+ func Ed25519Sign(pk ed25519.PrivateKey, msg []byte) ([]byte, error)

+ func Ed25519SignWithSeedFile(f string, msg []byte) ([]byte, error)

type Framework

+ func (fw *Framework) DDLResolvers() ([]inter.DDLResolver, error)

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

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

+ func (fw *Framework) SecurityProvider() string

+ func (fw *Framework) SignerSeedFile() (f string, err error)

+ func (fw *Framework) SignerTokenFile() (f string, err error)

v0.24.1

Sep 21, 2021

v0.24.0

Sep 21, 2021

Changes in this version

+ func ParseDuration(dstr string) (dur time.Duration, err error)

type ConnectorMessage

+ func NewConnectorMessage(subject string, reply string, data []byte, msg interface{}) *ConnectorMessage

type Framework

+ func (fw *Framework) NewMessageFromRequest(req protocol.Request, replyto string) (inter.Message, error)

v0.23.0

Aug 24, 2021

Changes in this version

+ func ECDHKeyPair() (pri []byte, pub []byte, err error)

+ func ECDHSharedSecret(localPrivate []byte, remotePub []byte) ([]byte, error)

+ func ECDHSharedSecretString(localPrivate string, remotePub string) (string, error)

+ func GovernorSubject(name string, collective string) string

+ func Inbox(collective string, caller string) string

type AgentConnector

+ ConnectedServer func() string

+ ConnectionOptions func() nats.Options

+ ConnectionStats func() nats.Statistics

type Connection

+ func (conn *Connection) PublishRawMsg(msg *nats.Msg) error

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

type Connector

+ AgentBroadcastTarget func(collective string, agent string) string

+ Close func()

+ ConnectedServer func() string

+ ConnectionOptions func() nats.Options

+ ConnectionStats func() nats.Statistics

+ IsConnected func() bool

+ 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

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

+ ServiceBroadcastTarget func(collective string, agent string) string

+ Unsubscribe func(name string) error

type Framework

+ func (fw *Framework) DirectorySubmitter() (submission.Submitter, error)

+ func (fw *Framework) GovernorSubject(name string) string

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

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

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

+ func (fw *Framework) SupportsProvisioning() bool

v0.22.0

Apr 22, 2021

Changes in this version

+ const DirectRequestMessageType

+ const MessageMessageType

+ const ReplyMessageType

+ const RequestMessageType

+ const ServiceRequestMessageType

+ func ServiceBroadcastTarget(collective string, agent string) string

type AgentConnector

+ ServiceBroadcastTarget func(collective string, agent string) string

type Connection

+ func (conn *Connection) ServiceBroadcastTarget(collective string, agent string) string

v0.21.0

Mar 29, 2021

Changes in this version

type Framework

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

v0.20.2

Feb 3, 2021

v0.20.1

Feb 3, 2021

v0.20.0

Feb 3, 2021

Changes in this version

type Framework

+ func (fw *Framework) ProgressWidth() int

v0.19.0

Jan 13, 2021

Changes in this version

+ func LongestString(list []string, max int) int

type ConnectorMessage

+ Msg interface{}

type Framework

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

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

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

+ func (fw *Framework) PQLQueryCertNames(query string) ([]string, error)

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

type Message

+ func (m *Message) NotifyPublish()

+ func (m *Message) OnPublish(f func())

v0.18.0

Nov 25, 2020

v0.17.0

Sep 28, 2020

Changes in this version

type Framework

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

+ func (fw *Framework) SignerToken() (token string, err error)

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

v0.16.0

Jul 18, 2020

Changes in this version

type Framework

+ func (fw *Framework) SetLogger(logger *log.Logger)

v0.15.0

Jul 1, 2020

Changes in this version

+ func FileIsDir(path string) bool

+ func FileIsRegular(path string) bool

type Framework

+ func (fw *Framework) PrometheusTextFileDir() string

v0.14.0

Apr 19, 2020

Changes in this version

+ func BuildInfo() *build.Info

type Message

+ func (m *Message) CacheTransport()

+ func (m *Message) IsCachedTransport() bool

+ func (m *Message) UniqueTransport()

v0.13.1

Jan 12, 2020

Changes in this version

+ func InterruptibleSleep(ctx context.Context, d time.Duration) error

type Framework

+ func (fw *Framework) SetLogWriter(out io.Writer)

v0.13.0

Dec 7, 2019

Changes in this version

type Connection

+ func (conn *Connection) IsConnected() bool

type Framework

+ func (fw *Framework) ShouldUseNGS() bool

type InstanceConnector

+ IsConnected func() bool

v0.12.1

Sep 20, 2019

v0.12.0

Sep 9, 2019

Changes in this version

+ func AgentBroadcastTarget(collective string, agent string) string

+ func FileExist(path string) bool

+ func HomeDir() (string, error)

+ func InterruptableSleep(ctx context.Context, d time.Duration) error

+ func MatchAnyRegex(str []byte, regex []string) bool

+ func NewRequestID() (string, error)

+ func NodeDirectedTarget(collective string, identity string) string

+ func ReplyTarget(msg *Message, requestid string) string

+ func SliceGroups(input []string, size int, fn func(group []string))

+ func StrToBool(s string) (bool, error)

+ func TargetForMessage(msg *Message, identity string) (string, error)

+ func UniqueID() (id string)

+ func UserConfig() string

+ type AgentConnector interface

+ AgentBroadcastTarget func(collective string, agent string) string

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

+ Unsubscribe func(name string) error

+ type ClientConnector interface

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

+ ReplyTarget func(msg *Message) string

+ type Connection struct

+ func (conn *Connection) AgentBroadcastTarget(collective string, agent string) string

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

+ func (conn *Connection) Close()

+ func (conn *Connection) Connect(ctx context.Context) (err error)

+ func (conn *Connection) ConnectedServer() string

+ func (conn *Connection) ConnectionOptions() nats.Options

+ func (conn *Connection) ConnectionStats() nats.Statistics

+ func (conn *Connection) Flush()

+ func (conn *Connection) Nats() *nats.Conn

+ func (conn *Connection) NodeDirectedTarget(collective string, identity string) string

+ func (conn *Connection) Publish(msg *Message) error

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

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

+ func (conn *Connection) ReplyTarget(msg *Message) (string, error)

+ func (conn *Connection) TargetForMessage(msg *Message, identity string) (string, error)

+ func (conn *Connection) Unsubscribe(name string) error

+ type ConnectionManager interface

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

+ type Connector interface

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

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

+ Nats func() *nats.Conn

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

+ type ConnectorInfo interface

+ ConnectedServer func() string

+ ConnectionOptions func() nats.Options

+ ConnectionStats func() nats.Statistics

+ type ConnectorMessage struct

+ Data []byte

+ Reply string

+ Subject string

+ func (m *ConnectorMessage) Bytes() []byte

+ type Framework struct

+ Config *config.Config

+ func New(path string) (*Framework, error)

+ func NewWithConfig(cfg *config.Config) (*Framework, error)

+ func (fw *Framework) BuildInfo() *build.Info

+ func (fw *Framework) CallerID() string

+ func (fw *Framework) Certname() string

+ func (fw *Framework) Configuration() *config.Config

+ func (fw *Framework) ConfigureProvisioning()

+ func (fw *Framework) DisableTLSVerify() bool

+ func (fw *Framework) DiscoveryServer() (srvcache.Server, error)

+ func (fw *Framework) Enroll(ctx context.Context, wait time.Duration, cb func(int)) error

+ func (fw *Framework) FacterCmd() string

+ func (fw *Framework) FacterDomain() (string, error)

+ func (fw *Framework) FacterFQDN() (string, error)

+ func (fw *Framework) FacterStringFact(fact string) (string, error)

+ func (fw *Framework) FederationCollectives() (collectives []string)

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

+ func (fw *Framework) Getuid() int

+ func (fw *Framework) HasCollective(collective string) bool

+ func (fw *Framework) IsFederated() (result bool)

+ func (fw *Framework) Logger(component string) *log.Entry

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (fw *Framework) NewRequestID() (string, error)

+ func (fw *Framework) NewRequestMessageFromTransportJSON(payload []byte) (msg *Message, err error)

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

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

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

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

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

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

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

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

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

+ func (fw *Framework) OverrideCertname() string

+ func (fw *Framework) ProvisionMode() bool

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

+ func (fw *Framework) ProxiedDiscovery() bool

+ func (fw *Framework) PuppetAIOCmd(command string, def string) string

+ func (fw *Framework) PuppetSetting(setting string) (string, error)

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

+ func (fw *Framework) SetupLogging(debug bool) (err error)

+ func (fw *Framework) TLSConfig() (tlsc *tls.Config, err error)

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

+ func (fw *Framework) UniqueID() string

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

+ type InstanceConnector interface

+ Close func()

+ NodeDirectedTarget func(collective string, identity string) string

+ type Message struct

+ Agent string

+ CallerID string

+ CustomTarget string

+ DiscoveredHosts []string

+ Filter *protocol.Filter

+ Payload string

+ Request *Message

+ RequestID string

+ SenderID string

+ TTL int

+ TimeStamp time.Time

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

+ func NewMessageFromRequest(req protocol.Request, replyto string, choria *Framework) (msg *Message, err error)

+ func (msg *Message) Base64Payload() string

+ func (msg *Message) Collective() string

+ func (msg *Message) ExpectedMessageID() string

+ func (msg *Message) ReplyTo() string

+ func (msg *Message) SetBase64Payload(payload string) error

+ func (msg *Message) SetCollective(collective string) error

+ func (msg *Message) SetExpectedMsgID(id string) error

+ func (msg *Message) SetProtocolVersion(version string)

+ func (msg *Message) SetReplyTo(replyTo string) error

+ func (msg *Message) SetType(msgType string) (err error)

+ func (msg *Message) String() string

+ func (msg *Message) Transport() (protocol.TransportMessage, error)

+ func (msg *Message) Type() string

+ func (msg *Message) Validate() (bool, error)

+ func (msg *Message) ValidateTTL() bool

+ type PublishableConnector interface

+ Publish func(msg *Message) error

+ type RawPublishableConnector interface

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

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