Versions in this module Expand all Collapse all v0 v0.2.1 Apr 22, 2025 Changes in this version type Configuration + NodeAlias string v0.2.0 Feb 19, 2025 Changes in this version type Message + MethodInstructions []string + ReplyMethodInstructions []string type Method + const WebUI v0.1.0 Jan 25, 2025 Changes in this version + var ErrACKSubscribeRetry = errors.New("ctrl: retrying to subscribe for ack message") + var ErrOther = errors.New("other error") + func CheckEnv[T any](key string, v T) any + func EncodeSeed(public PrefixByte, src []byte) ([]byte, error) + func NewPortInitialData(uuid string, sourceNode Node, sourceSubMethod Method, sourcePort string, ...) portInitialData + func NewPortSortedBuffer() *portSortedBuffer + func NewServer(configuration *Configuration, version string) (*server, error) + type Configuration struct + AclUpdateInterval int + BrokerAddress string + CentralNodeName string + ConfigFolder string + DatabaseFolder string + DefaultMessageRetries int + DefaultMessageTimeout int + DefaultMethodTimeout int + EnableAclCheck bool + EnableReadFolder bool + EnableSignatureCheck bool + EnableSocket bool + ErrorMessageRetries int + ErrorMessageTimeout int + ExposeDataFolder string + HTTPListener string + JetStreamMaxMsgsPerSubject int + JetstreamsConsume string + KeepPublishersAliveFor int + KeysUpdateInterval int + LogConsoleTimestamps bool + LogLevel string + NatsConnOptTimeout int + NatsConnectRetryInterval int + NatsReconnectJitter int + NatsReconnectJitterTLS int + NkeyFromED25519SSHKeyFile string + NkeyPublicKey string + NkeySeed string + NkeySeedFile string + NodeName string + Profiling string + ProfilingPort string + PromHostAndPort string + ReadFolder string + RootCAPath string + SetBlockProfileRate int + ShellOnNode string + SocketFolder string + StartProcesses StartProcesses + SubscribersDataFolder string + TCPListener string + func NewConfiguration() *Configuration + func (c *Configuration) CreateKeyPair(prefix PrefixByte) (kp, error) + type Handler func(proc process, message Message, node string) ([]byte, error) + type HostACLsSerializedWithHash struct + Data []byte + Hash [32]byte + type Message struct + ACKTimeout int + ArgSignature []byte + Data []byte + Directory string + FileName string + FromNode Node + ID int + IsReply bool + IsSubPublishedMsg bool + JetstreamToNode Node + Method Method + MethodArgs []string + MethodTimeout int + PreviousMessage *Message + ReplyACKTimeout int + ReplyMethod Method + ReplyMethodArgs []string + ReplyMethodTimeout int + ReplyRetries int + Retries int + RetryWait int + Schedule []int + ToNode Node + ToNodes []Node + UseDetectedShell bool + type Method string + const AclAddCommand + const AclDeleteCommand + const AclDeleteSource + const AclDeliverUpdate + const AclExport + const AclGroupCommandsAddCommand + const AclGroupCommandsDeleteCommand + const AclGroupCommandsDeleteGroup + const AclGroupNodesAddNode + const AclGroupNodesDeleteGroup + const AclGroupNodesDeleteNode + const AclImport + const AclRequestUpdate + const CliCommand + const CliCommandCont + const Console + const CopyDst + const CopySrc + const DummyDst + const DummySrc + const ErrorLog + const File + const FileAppend + const Hello + const HelloPublisher + const HttpGet + const Initial + const KeysAllow + const KeysDelete + const KeysUpdateReceive + const KeysUpdateRequest + const None + const OpProcessList + const OpProcessStart + const OpProcessStop + const PortDst + const PortSrc + const PublicKey + const SUBCopyDst + const SUBCopySrc + const SUBDummyDst + const SUBDummySrc + const SUBPortDst + const SUBPortSrc + const TailFile + const Test + func (m Method) GetMethodsAvailable() MethodsAvailable + type MethodsAvailable struct + Methodhandlers map[Method]Handler + func (ma MethodsAvailable) CheckIfExists(m Method) (Handler, bool) + type Node string + type PrefixByte byte + const PrefixByteSeed + const PrefixByteUser + type StartProcesses struct + EnableAclUpdates bool + EnableKeyUpdates bool + IsCentralAcl bool + IsCentralErrorLogger bool + IsCentralKey bool + StartPubHello int + StartSubCliCommand bool + StartSubCliCommandCont bool + StartSubConsole bool + StartSubCopyDst bool + StartSubCopySrc bool + StartSubFile bool + StartSubFileAppend bool + StartSubHello bool + StartSubHttpGet bool + StartSubTailFile bool + type Subject struct + Method Method + ToNode string
Go to main page