wzd

README

wzd

Client daemon for running Whizz-supported modules.

Documentation

Index

• type WzDaemon
  • func NewWzDaemon() *WzDaemon
  • func (wd *WzDaemon) AppLoop()
  • func (wd *WzDaemon) GetAES() *wzlib_crypto.WzAES
  • func (wd *WzDaemon) GetClusterFingerprint() string
  • func (wd *WzDaemon) GetCryptoUtils() *wzlib_crypto.WzCryptoUtils
  • func (wd *WzDaemon) GetPingService() *wzd_events.WzPingEvent
  • func (wd *WzDaemon) GetPkiDirectory() string
  • func (wd *WzDaemon) GetRSA() *wzlib_crypto.WzRSA
  • func (wd *WzDaemon) GetTraits() *wzlib_traits.WzTraits
  • func (wd *WzDaemon) GetTransport() *wzlib_transport.WzdPubSub
  • func (wd *WzDaemon) IsRunning() bool
  • func (wd *WzDaemon) Run() *WzDaemon
  • func (wd *WzDaemon) SaveClusterPublicPEMKey(pem []byte) (int, error)
  • func (wd *WzDaemon) SetClusterFingerprint(fp string) *WzDaemon
  • func (wd *WzDaemon) SetPkiDirectory(dirname string) *WzDaemon
  • func (wd *WzDaemon) SetTraitsFile(fpath string) *WzDaemon
  • func (wd *WzDaemon) Stop()
• type WzDaemonBoot
  • func NewWzDaemonBoot(daemon *WzDaemon) *WzDaemonBoot
• type WzDaemonEvents
  • func NewWzDaemonEvents(daemon *WzDaemon) *WzDaemonEvents
  • func (wd *WzDaemonEvents) OnControllerEvent(m *nats.Msg)
  • func (wd *WzDaemonEvents) OnPublicEvent(m *nats.Msg)
• type WzDaemonLocSockMiddleware
  • func NewWzDaemonLocSockMiddleware() *WzDaemonLocSockMiddleware
  • func (wdlsm *WzDaemonLocSockMiddleware) Name() string
  • func (wdlsm *WzDaemonLocSockMiddleware) OnCommand(command string) string
• type WzDaemonStatus

Types

type WzDaemon

type WzDaemon struct {
	wzlib_utils.WzMachineIDUtil
	wzlib_logger.WzLogger
	// contains filtered or unexported fields
}

func NewWzDaemon

func NewWzDaemon() *WzDaemon

Constructor

func (*WzDaemon) AppLoop

func (wd *WzDaemon) AppLoop()

func (*WzDaemon) GetAES

func (wd *WzDaemon) GetAES() *wzlib_crypto.WzAES

GetAES returns AES utility API

func (*WzDaemon) GetClusterFingerprint

func (wd *WzDaemon) GetClusterFingerprint() string

GetClusterFingerprint returns a configured known fingerprint of a public RSA key of a cluster

func (*WzDaemon) GetCryptoUtils

func (wd *WzDaemon) GetCryptoUtils() *wzlib_crypto.WzCryptoUtils

GetCryptoUtils returns an instance of PKI utils

func (*WzDaemon) GetPingService

func (wd *WzDaemon) GetPingService() *wzd_events.WzPingEvent

func (*WzDaemon) GetPkiDirectory

func (wd *WzDaemon) GetPkiDirectory() string

GetPkiDirectory which hold all the keys for the daemon

func (*WzDaemon) GetRSA

func (wd *WzDaemon) GetRSA() *wzlib_crypto.WzRSA

GetRSA returns RSA utility API

func (*WzDaemon) GetTraits

func (wd *WzDaemon) GetTraits() *wzlib_traits.WzTraits

GetTraits returns initialised traits

func (*WzDaemon) GetTransport

func (wd *WzDaemon) GetTransport() *wzlib_transport.WzdPubSub

GetTransport return transport object

func (*WzDaemon) IsRunning

func (wd *WzDaemon) IsRunning() bool

func (*WzDaemon) Run

func (wd *WzDaemon) Run() *WzDaemon

Run the daemon

func (*WzDaemon) SaveClusterPublicPEMKey

func (wd *WzDaemon) SaveClusterPublicPEMKey(pem []byte) (int, error)

SaveClusterPublicPEMKey to the PKI directory as cluster.pub.pem

func (*WzDaemon) SetClusterFingerprint

func (wd *WzDaemon) SetClusterFingerprint(fp string) *WzDaemon

SetClusterFingerprint sets configured fingerprint of a public RSA key, representing trusted cluster components. This value is coming from the configuration file.

func (*WzDaemon) SetPkiDirectory

func (wd *WzDaemon) SetPkiDirectory(dirname string) *WzDaemon

SetPkiDirectory to define where to store/work-with for PKI artifacts

func (*WzDaemon) SetTraitsFile

func (wd *WzDaemon) SetTraitsFile(fpath string) *WzDaemon

SetTraitsFile initialises traits instance in the boot sub-object

func (*WzDaemon) Stop

func (wd *WzDaemon) Stop()

Stop wzd

type WzDaemonBoot

type WzDaemonBoot struct {
	wzlib_logger.WzLogger
	// contains filtered or unexported fields
}

func NewWzDaemonBoot

func NewWzDaemonBoot(daemon *WzDaemon) *WzDaemonBoot

type WzDaemonEvents

type WzDaemonEvents struct {
	wzlib_logger.WzLogger
	// contains filtered or unexported fields
}

func NewWzDaemonEvents

func NewWzDaemonEvents(daemon *WzDaemon) *WzDaemonEvents

func (*WzDaemonEvents) OnControllerEvent

func (wd *WzDaemonEvents) OnControllerEvent(m *nats.Msg)

func (*WzDaemonEvents) OnPublicEvent

func (wd *WzDaemonEvents) OnPublicEvent(m *nats.Msg)

type WzDaemonLocSockMiddleware

type WzDaemonLocSockMiddleware struct {
}

func NewWzDaemonLocSockMiddleware

func NewWzDaemonLocSockMiddleware() *WzDaemonLocSockMiddleware

func (*WzDaemonLocSockMiddleware) Name

func (wdlsm *WzDaemonLocSockMiddleware) Name() string

func (*WzDaemonLocSockMiddleware) OnCommand

func (wdlsm *WzDaemonLocSockMiddleware) OnCommand(command string) string

type WzDaemonStatus

type WzDaemonStatus struct {
	Running bool
}