steward

package module

Go to main page

Versions in this module

v0

v0.3.25

Sep 8, 2023

v0.3.24

Jun 30, 2023

v0.3.23

Jun 27, 2023

Changes in this version

+ func EncodeSeed(public PrefixByte, src []byte) ([]byte, error)

type Configuration

+ NkeyFromED25519SSHKeyFile string

+ func (c *Configuration) CreateKeyPair(prefix PrefixByte) (kp, error)

type ConfigurationFromFile

+ NkeyFromED25519SSHKeyFile *string

+ type PrefixByte byte

+ const PrefixByteSeed

+ const PrefixByteUser

v0.3.22

Jun 14, 2023

v0.3.21

Apr 20, 2023

v0.3.20

Jan 13, 2023

v0.3.19

Jan 12, 2023

v0.3.18

Jan 12, 2023

Changes in this version

type Configuration

+ LogConsoleTimestamps bool

+ LogLevel string

type ConfigurationFromFile

+ LogConsoleTimestamps *bool

+ LogLevel *string

v0.3.17

Jan 9, 2023

Changes in this version

type Configuration

+ EnableReadFolder bool

+ ReadFolder string

type ConfigurationFromFile

+ EnableReadFolder *bool

+ ReadFolder *string

v0.3.16

Jan 6, 2023

v0.3.15

Dec 21, 2022

v0.3.14

Dec 19, 2022

v0.3.13

Dec 14, 2022

v0.3.12

Dec 2, 2022

v0.3.11

Nov 30, 2022

v0.3.10

Nov 23, 2022

v0.3.9

Oct 14, 2022

v0.3.8

Oct 14, 2022

v0.3.7

Oct 14, 2022

v0.3.6

Oct 12, 2022

v0.3.5

Oct 12, 2022

v0.3.4

Oct 12, 2022

v0.3.3

Oct 12, 2022

v0.3.2

Sep 29, 2022

v0.3.1

Sep 8, 2022

v0.3.0

Jun 24, 2022

Changes in this version

+ var ErrACKSubscribeRetry = errors.New("steward: retrying to subscribe for ack message")

type Configuration

+ EnableAclCheck bool

+ EnableAclUpdates bool

+ EnableKeyUpdates bool

+ IsCentralErrorLogger bool

+ KeepPublishersAliveFor int

+ NkeyPublicKey string

+ REQAclRequestUpdateInterval int

+ REQKeysRequestUpdateInterval int

+ RingBufferPersistStore bool

+ StartSubREQCopyDst bool

+ StartSubREQCopySrc bool

type ConfigurationFromFile

+ EnableAclCheck *bool

+ EnableAclUpdates *bool

+ EnableKeyUpdates *bool

+ IsCentralErrorLogger *bool

+ KeepPublishersAliveFor *int

+ REQAclRequestUpdateInterval *int

+ REQKeysRequestUpdateInterval *int

+ RingBufferPersistStore *bool

+ StartSubREQCopyDst *bool

+ StartSubREQCopySrc *bool

+ type HostACLsSerializedWithHash struct

+ Data []byte

+ Hash [32]byte

type Message

+ IsSubPublishedMsg bool

+ RetryWait int

+ Schedule []int

type Method

+ const REQAclAddCommand

+ const REQAclDeleteCommand

+ const REQAclDeleteSource

+ const REQAclDeliverUpdate

+ const REQAclExport

+ const REQAclGroupCommandsAddCommand

+ const REQAclGroupCommandsDeleteCommand

+ const REQAclGroupCommandsDeleteGroup

+ const REQAclGroupNodesAddNode

+ const REQAclGroupNodesDeleteGroup

+ const REQAclGroupNodesDeleteNode

+ const REQAclImport

+ const REQAclRequestUpdate

+ const REQCopyDst

+ const REQCopySrc

+ const REQKeysAllow

+ const REQKeysDelete

+ const REQKeysDeliverUpdate

+ const REQKeysRequestUpdate

+ const REQSUBCopyDst

+ const REQSUBCopySrc

+ const REQTest

v0.2.6

Mar 17, 2022

v0.2.5

Mar 9, 2022

v0.2.4

Mar 4, 2022

Changes in this version

type Configuration

+ StartSubREQToFileNACK bool

type ConfigurationFromFile

+ StartSubREQToFileNACK *bool

type Method

+ const REQToFileNACK

v0.2.3

Feb 23, 2022

v0.2.2

Feb 22, 2022

v0.2.1

Feb 18, 2022

Changes in this version

type Configuration

+ EnableDebug bool

type ConfigurationFromFile

+ EnableDebug *bool

v0.2.0

Feb 11, 2022

Changes in this version

type Configuration

+ Compression string

+ EnableSignatureCheck bool

+ EnableSocket bool

+ EnableTUI bool

+ IsCentralAuth bool

+ RingBufferSize int

+ Serialization string

+ SetBlockProfileRate int

+ StartSubREQHttpGetScheduled bool

type ConfigurationFromFile

+ Compression *string

+ EnableSignatureCheck *bool

+ EnableSocket *bool

+ EnableTUI *bool

+ IsCentralAuth *bool

+ RingBufferSize *int

+ Serialization *string

+ SetBlockProfileRate *int

+ StartSubREQHttpGetScheduled *bool

+ type Event string

+ func (c Event) CheckEventAvailable() EventAvailable

+ type EventAvailable struct

+ func (e EventAvailable) CheckIfExists(event Event, subject Subject) bool

type Message

+ ArgSignature []byte

type Method

+ const REQHttpGetScheduled

+ const REQNone

+ const REQPublicKey

+ const REQTuiToConsole

type Subject

+ Event Event

v0.1.15

Dec 17, 2021

Changes in this version

type Configuration

+ NatsConnOptTimeout int

+ NatsReconnectJitter int

+ NatsReconnectJitterTLS int

type ConfigurationFromFile

+ NatsConnOptTimeout *int

+ NatsReconnectJitter *int

+ NatsReconnectJitterTLS *int

v0.1.14

Dec 8, 2021

Changes in this version

type Configuration

+ DefaultMethodTimeout int

+ StartSubREQCopyFileFrom bool

+ StartSubREQCopyFileTo bool

+ StartSubREQRelay bool

type ConfigurationFromFile

+ DefaultMethodTimeout *int

+ StartSubREQCopyFileFrom *bool

+ StartSubREQCopyFileTo *bool

+ StartSubREQRelay *bool

type Message

+ RelayFromNode Node

+ RelayOriginalMethod Method

+ RelayOriginalViaNode Node

+ RelayReplyMethod Method

+ RelayToNode Node

+ RelayViaNode Node

type Method

+ const REQCopyFileFrom

+ const REQCopyFileTo

+ const REQRelay

+ const REQRelayInitial

v0.1.13

Oct 8, 2021

v0.1.12

Sep 23, 2021

v0.1.11

Sep 23, 2021

Changes in this version

type Configuration

+ HTTPListener string

+ StartSubREQCliCommandCont bool

type ConfigurationFromFile

+ HTTPListener *string

+ StartSubREQCliCommandCont *bool

type Message

+ IsReply bool

+ MethodArgs []string

+ ReplyMethodArgs []string

+ ReplyMethodTimeout int

type Method

+ const REQCliCommandCont

+ const REQOpProcessList

+ const REQOpProcessStart

+ const REQOpProcessStop

v0.1.10

Sep 9, 2021

Changes in this version

type Configuration

+ ErrorMessageRetries int

+ ErrorMessageTimeout int

+ type ConfigurationFromFile struct

+ BrokerAddress *string

+ CentralNodeName *string

+ ConfigFolder *string

+ DatabaseFolder *string

+ DefaultMessageRetries *int

+ DefaultMessageTimeout *int

+ ErrorMessageRetries *int

+ ErrorMessageTimeout *int

+ ExposeDataFolder *string

+ NatsConnectRetryInterval *int

+ NkeySeedFile *string

+ NodeName *string

+ ProfilingPort *string

+ PromHostAndPort *string

+ RootCAPath *string

+ SocketFolder *string

+ StartPubREQHello *int

+ StartSubREQCliCommand *bool

+ StartSubREQErrorLog *bool

+ StartSubREQHello *bool

+ StartSubREQHttpGet *bool

+ StartSubREQPing *bool

+ StartSubREQPong *bool

+ StartSubREQTailFile *bool

+ StartSubREQToConsole *bool

+ StartSubREQToFile *bool

+ StartSubREQToFileAppend *bool

+ StartSubREQnCliCommand *bool

+ StartSubREQnCliCommandCont *bool

+ SubscribersDataFolder *string

+ TCPListener *string

v0.1.9

Sep 1, 2021

Changes in this version

type Configuration

+ NatsConnectRetryInterval int

v0.1.8

Aug 27, 2021

v0.1.7

Aug 27, 2021

v0.1.6

Aug 26, 2021

Changes in this version

type Configuration

+ ExposeDataFolder string

+ TCPListener string

type Message

+ FileName string

+ ToNodes []Node

v0.1.5

Aug 18, 2021

Changes in this version

type Configuration

+ StartSubREQnCliCommandCont flagNodeSlice

type Method

+ const REQToSocket

+ func (m Method) GetReplyMethods() []Method

type MethodsAvailable

+ Methodhandlers map[Method]methodHandler

+ type Node string

v0.1.4

Jun 9, 2021

Changes in this version

type Method

+ const REQnCliCommandCont

type OpCmdStopProc

+ ID int

v0.1.3

May 28, 2021

v0.1.2

May 25, 2021

Changes in this version

type Configuration

+ NkeySeedFile string

v0.1.1

May 12, 2021

Changes in this version

type Configuration

+ DatabaseFolder string

+ RootCAPath string

+ SocketFolder string

v0.1.0

Apr 16, 2021

Changes in this version

+ func NewServer(c *Configuration) (*server, error)

+ type CommandOrEvent string

+ const CommandACK

+ const CommandNACK

+ const EventACK

+ const EventNACK

+ func (c CommandOrEvent) GetCommandOrEventAvailable() CommandOrEventAvailable

+ type CommandOrEventAvailable struct

+ func (co CommandOrEventAvailable) CheckIfExists(c CommandOrEvent, subject Subject) bool

+ type Configuration struct

+ BrokerAddress string

+ CentralNodeName string

+ ConfigFolder string

+ DefaultMessageRetries int

+ DefaultMessageTimeout int

+ NodeName string

+ ProfilingPort string

+ PromHostAndPort string

+ StartPubREQHello int

+ StartSubREQCliCommand flagNodeSlice

+ StartSubREQErrorLog flagNodeSlice

+ StartSubREQHello flagNodeSlice

+ StartSubREQHttpGet flagNodeSlice

+ StartSubREQPing flagNodeSlice

+ StartSubREQPong flagNodeSlice

+ StartSubREQTailFile flagNodeSlice

+ StartSubREQToConsole flagNodeSlice

+ StartSubREQToFile flagNodeSlice

+ StartSubREQToFileAppend flagNodeSlice

+ StartSubREQnCliCommand flagNodeSlice

+ SubscribersDataFolder string

+ func NewConfiguration() *Configuration

+ func (c *Configuration) CheckFlags() error

+ func (c *Configuration) ReadConfigFile() (Configuration, error)

+ func (c *Configuration) WriteConfigFile() error

+ type Message struct

+ ACKTimeout int

+ Data []string

+ Directory string

+ FileExtension string

+ FromNode node

+ ID int

+ Method Method

+ MethodTimeout int

+ Operation Operation

+ PreviousMessage *Message

+ ReplyACKTimeout int

+ ReplyMethod Method

+ ReplyRetries int

+ Retries int

+ ToNode node

+ type Method string

+ const REQCliCommand

+ const REQErrorLog

+ const REQHello

+ const REQHttpGet

+ const REQInitial

+ const REQOpCommand

+ const REQPing

+ const REQPong

+ const REQTailFile

+ const REQToConsole

+ const REQToFile

+ const REQToFileAppend

+ const REQnCliCommand

+ func (m Method) GetMethodsAvailable() MethodsAvailable

+ type MethodsAvailable struct

+ func (ma MethodsAvailable) CheckIfExists(m Method) (methodHandler, bool)

+ type OpCmdStartProc struct

+ AllowedNodes []node

+ Method Method

+ type OpCmdStopProc struct

+ Kind processKind

+ Method Method

+ RecevingNode node

+ type Operation struct

+ OpArg json.RawMessage

+ OpCmd string

+ type Subject struct

+ CommandOrEvent CommandOrEvent

+ Method Method

+ ToNode string

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