Versions in this module Expand all Collapse all v0 v0.0.1 Apr 5, 2022 Changes in this version + var GitCommit string + var GitVersion string + func GetClientName() string + type IUsvcStub interface + Component func() string + Fullname func() string + Name func() string + Version func() int + type Usvc struct + ApplySettings func() + Executor func() + Settings types.Settings + func (svc *Usvc) Abort() + func (svc *Usvc) Component() string + func (svc *Usvc) DispatchLocalInvocation(method string, payload string) (interface{}, error) + func (svc *Usvc) Fullname() string + func (svc *Usvc) InitializeService(broker *UsvcBroker, version int, component string, name string, ...) + func (svc *Usvc) LoadSettings() error + func (svc *Usvc) LogError(msg string, err error) + func (svc *Usvc) LogGeneric(category string, format string, args ...interface{}) + func (svc *Usvc) LogInfection(title string, format string, args ...interface{}) + func (svc *Usvc) LogInfo(msg string) + func (svc *Usvc) LogPanic(caller string) + func (svc *Usvc) LogWarning(msg string) + func (svc *Usvc) Name() string + func (svc *Usvc) Pause() + func (svc *Usvc) Publish(subject string, msg interface{}) error + func (svc *Usvc) PublishData(name string, msg interface{}) error + func (svc *Usvc) PublishDataString(name string, msg string) error + func (svc *Usvc) PublishEventMessage(name string, msg interface{}) error + func (svc *Usvc) PublishEventString(name string, msg string) error + func (svc *Usvc) PublishString(subject string, msg string) error + func (svc *Usvc) RegisterMethod(name string, callback func(payload string) (interface{}, error)) + func (svc *Usvc) Resume() + func (svc *Usvc) SaveSettings() + func (svc *Usvc) SetTaskIdleTime(durationSeconds int64) + func (svc *Usvc) Start() + func (svc *Usvc) State() types.ServiceState + func (svc *Usvc) Stop() + func (svc *Usvc) Trace(traceid string, msg string) + func (svc *Usvc) Version() int + type UsvcBroker struct — darwin/amd64, linux/amd64, windows/amd64 + func (broker *UsvcBroker) CheckConnection() error + func (broker *UsvcBroker) DispatchBytes(subject string, data []byte) (interface{}, error, bool) + func (broker *UsvcBroker) DispatchMessage(subject string, request *types.Request) (interface{}, error) + func (broker *UsvcBroker) Error() error + func (broker *UsvcBroker) Initialize() error + func (broker *UsvcBroker) IsServiceAvailable(fullname string) bool + func (broker *UsvcBroker) Log(fullname string, category string, title string) + func (broker *UsvcBroker) LogDescription(fullname string, category string, title string, description string) + func (broker *UsvcBroker) LogError(fullname string, msg string, err error) + func (broker *UsvcBroker) LogGeneric(name string, category string, format string, args ...interface{}) + func (broker *UsvcBroker) LogInfection(name string, title string, format string, args ...interface{}) + func (broker *UsvcBroker) LogInfo(fullname string, msg string) + func (broker *UsvcBroker) LogWarning(fullname string, msg string) + func (broker *UsvcBroker) PublishBytes(subject string, message []byte) error + func (broker *UsvcBroker) PublishJson(subject string, message string) error + func (broker *UsvcBroker) PublishMessage(subject string, message *interface{}) error + func (broker *UsvcBroker) PublishString(subject string, message string) error + func (broker *UsvcBroker) RegisterDependencies(deps []string) + func (broker *UsvcBroker) RegisterUsvc(svc *Usvc) error + func (broker *UsvcBroker) Request(subject string) (*types.Response, error) + func (broker *UsvcBroker) RequestMessage(subject string, message interface{}) (*types.Response, error) + func (broker *UsvcBroker) SetTimeout(tmo uint) + func (broker *UsvcBroker) Shutdown() error + func (broker *UsvcBroker) Subscribe(subject string, callback func(m *nats.Msg)) error + func (broker *UsvcBroker) SubscribeToUsvcCalls(svc Usvc) error + func (broker *UsvcBroker) Trace(fullname string, traceid string, msg string) + type UsvcStub struct + func CreateStub(broker *UsvcBroker, name string, component string, version int) *UsvcStub + func (stub *UsvcStub) PublishDataMessage(name string, message *interface{}) error + func (stub *UsvcStub) PublishEventMessage(name string, message *interface{}) error + func (stub *UsvcStub) PublishEventString(name string, json string) error + func (stub *UsvcStub) PublishMessage(subject string, message interface{}) error + func (stub *UsvcStub) Request(name string) (*types.Response, error) + func (stub *UsvcStub) RequestMessage(name string, request interface{}) (*types.Response, error) + func (stub *UsvcStub) SubscribeData(name string, callback func(msg *nats.Msg)) error + func (stub *UsvcStub) SubscribeEvent(name string, callback func(msg *nats.Msg)) error
Go to main page