natsservice

Documentation

Index

• func ParseCommonCommandLineParams(params *CommonCommandLineParams)
• type CommonCommandLineParams
• type Config
  • func LoadConfig(files ...string) (Config, error)
• type MysqlConfig
• type NatsService
  • func NewNatsService(logger *logrus.Entry, transport natsevents.Transport) *NatsService
  • func (ns *NatsService) Logger() *logrus.Entry
  • func (ns *NatsService) SetLogger(logger *logrus.Entry)
  • func (ns *NatsService) SetTransport(transport natsevents.Transport)
  • func (ns *NatsService) Transport() natsevents.Transport
• type NatsServiceIntf
• type NatsServiceProcess
  • func NewServiceProcess(config NatsServiceProcessConfig) (*NatsServiceProcess, error)
  • func (serviceprocess *NatsServiceProcess) Close(timeout time.Duration) error
  • func (serviceprocess *NatsServiceProcess) Logger() *log.Entry
  • func (serviceprocess *NatsServiceProcess) Start(natsSvc NatsServiceIntf, params ...interface{}) *task.Task
  • func (serviceprocess *NatsServiceProcess) WaitUntilAllDone()
• type NatsServiceProcessConfig
• type NatsServiceRepository
  • func NewNatsServiceRepository(name string, natsServers string, logLevel string) (*NatsServiceRepository, error)
  • func (nsr *NatsServiceRepository) Close(timeout time.Duration) error
  • func (nsr *NatsServiceRepository) Logger() *logrus.Entry
  • func (nsr *NatsServiceRepository) Name() string
  • func (nsr *NatsServiceRepository) Start(ctx context.Context, natsSvc NatsServiceIntf, params ...interface{}) *task.Task
  • func (nsr *NatsServiceRepository) Transport() natsevents.Transport
• type PostgresConfig

Functions

func ParseCommonCommandLineParams

func ParseCommonCommandLineParams(params *CommonCommandLineParams)

ParseCommonCommandLineParams sets the command line parameters, or their default values

Types

type CommonCommandLineParams

type CommonCommandLineParams struct {
	Log          string
	ConfigFolder string
}

CommandLineParams holds the common, non generic command line parameters

type Config

type Config struct {
	Servers []struct {
		Url string `default:"nats://nats1.plugis.com:443"`
		Sni bool   `default:"true"`
	}

	Postgres PostgresConfig

	Mysql MysqlConfig

	CommandLineParams CommonCommandLineParams
}

func LoadConfig

func LoadConfig(files ...string) (Config, error)

type MysqlConfig

type MysqlConfig struct {
	Host     string `default:"127.0.0.1"`
	Database string `default:"plugis"`
	User     string `default:"plugis"`
	Password string `required:"true" env:"MysqlPassword" default:"plugis"`
	Port     uint   `default:"3306"`
}

type NatsService

type NatsService struct {
	NatsServiceIntf
	// contains filtered or unexported fields
}

func NewNatsService

func NewNatsService(logger *logrus.Entry, transport natsevents.Transport) *NatsService

NewNatsService creates a nats service

func (*NatsService) Logger

func (ns *NatsService) Logger() *logrus.Entry

implement Logger

func (*NatsService) SetLogger

func (ns *NatsService) SetLogger(logger *logrus.Entry)

func (*NatsService) SetTransport

func (ns *NatsService) SetTransport(transport natsevents.Transport)

func (*NatsService) Transport

func (ns *NatsService) Transport() natsevents.Transport

implement Transporter

type NatsServiceIntf

type NatsServiceIntf interface {
	task.Runnable
	logger.Logger
	natsevents.Transporter
}

type NatsServiceProcess

type NatsServiceProcess struct {
	// contains filtered or unexported fields
}

func NewServiceProcess

func NewServiceProcess(config NatsServiceProcessConfig) (*NatsServiceProcess, error)

func (*NatsServiceProcess) Close

func (serviceprocess *NatsServiceProcess) Close(timeout time.Duration) error

func (*NatsServiceProcess) Logger

func (serviceprocess *NatsServiceProcess) Logger() *log.Entry

func (*NatsServiceProcess) Start

func (serviceprocess *NatsServiceProcess) Start(natsSvc NatsServiceIntf, params ...interface{}) *task.Task

func (*NatsServiceProcess) WaitUntilAllDone

func (serviceprocess *NatsServiceProcess) WaitUntilAllDone()

type NatsServiceProcessConfig

type NatsServiceProcessConfig struct {
	ServiceName   string
	NatsServers   string
	LogLevel      string
	CancelTimeout time.Duration
}

type NatsServiceRepository

type NatsServiceRepository struct {
	task.RunnerRepository
	natsevents.Transporter
	// contains filtered or unexported fields
}

NatsServiceRepository provides logging nats cloud events transport for multiple services

func NewNatsServiceRepository

func NewNatsServiceRepository(name string, natsServers string, logLevel string) (*NatsServiceRepository, error)

NewNatsServiceRepository creates a nats service repository

func (*NatsServiceRepository) Close

func (nsr *NatsServiceRepository) Close(timeout time.Duration) error

Close closes flushes events on nats if timeout > 0 and closes nats connection

func (*NatsServiceRepository) Logger

func (nsr *NatsServiceRepository) Logger() *logrus.Entry

Logger returns the logger for the service repository

func (*NatsServiceRepository) Name

func (nsr *NatsServiceRepository) Name() string

Name returns the name given in NewNatsTransport

func (*NatsServiceRepository) Start

func (nsr *NatsServiceRepository) Start(ctx context.Context, natsSvc NatsServiceIntf, params ...interface{}) *task.Task

Start creates a go routine and runs natsSvc Run function

func (*NatsServiceRepository) Transport

func (nsr *NatsServiceRepository) Transport() natsevents.Transport

Transport returns the transport for the service repository

type PostgresConfig

type PostgresConfig struct {
	Host     string `default:"127.0.0.1"`
	Database string `default:"plugis"`
	User     string `default:"plugis"`
	Password string `required:"true" env:"PostgresPassword" default:"plugis"`
	Port     uint   `default:"5432"`
}