logger

Documentation

Index

• Constants
• type Kit
  • func NewKit(sys *piazza.SystemConfig, logWriter pzsyslog.Writer, ...) (*Kit, error)
  • func (kit *Kit) Start() error
  • func (kit *Kit) Stop() error
  • func (kit *Kit) Wait() error
• type Server
  • func (server *Server) Init(service *Service) error
• type Service
  • func (service *Service) GetRoot() *piazza.JsonResponse
  • func (service *Service) GetStats() *piazza.JsonResponse
  • func (service *Service) GetSyslog(params *piazza.HttpQueryParams) *piazza.JsonResponse
  • func (service *Service) Init(sys *piazza.SystemConfig, logWriter pzsyslog.Writer, ...) error
  • func (service *Service) PostQuery(params *piazza.HttpQueryParams, jsnQuery string) *piazza.JsonResponse
  • func (service *Service) PostSyslog(mNew *pzsyslog.Message) *piazza.JsonResponse
• type Stats

Constants

const Version = "1.0.0"

Types

type Kit

type Kit struct {
	Service       *Service
	Server        *Server
	LogWriter     pzsyslog.Writer
	AuditWriter   pzsyslog.Writer
	Sys           *piazza.SystemConfig
	GenericServer *piazza.GenericServer
	Url           string
	Async         bool
	// contains filtered or unexported fields
}

func NewKit

func NewKit(
	sys *piazza.SystemConfig,
	logWriter pzsyslog.Writer,
	auditWriter pzsyslog.Writer,
	esi elasticsearch.IIndex,
	asyncLogging bool,
	pen string,
) (*Kit, error)

NewKit starts a logger.Server, using a real or mocked ES backend. This is only used for testing.

func (*Kit) Start

func (kit *Kit) Start() error

func (*Kit) Stop

func (kit *Kit) Stop() error

func (*Kit) Wait

func (kit *Kit) Wait() error

type Server

type Server struct {
	Routes []piazza.RouteData
	// contains filtered or unexported fields
}

func (*Server) Init

func (server *Server) Init(service *Service) error

type Service

type Service struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*Service) GetRoot

func (service *Service) GetRoot() *piazza.JsonResponse

func (*Service) GetStats

func (service *Service) GetStats() *piazza.JsonResponse

func (*Service) GetSyslog

func (service *Service) GetSyslog(params *piazza.HttpQueryParams) *piazza.JsonResponse

func (*Service) Init

func (service *Service) Init(sys *piazza.SystemConfig, logWriter pzsyslog.Writer, auditWriter pzsyslog.Writer, esi elasticsearch.IIndex, asyncLogging bool, pen string) error

func (*Service) PostQuery

func (service *Service) PostQuery(params *piazza.HttpQueryParams, jsnQuery string) *piazza.JsonResponse

func (*Service) PostSyslog

func (service *Service) PostSyslog(mNew *pzsyslog.Message) *piazza.JsonResponse

type Stats

type Stats struct {
	CreatedOn time.Time `json:"createdOn"`

	// this is the number of messages since the service was started,
	// not the total number of messages in the system
	NumMessages int `json:"numMessages"`

	NumMessagesByApplication map[string]int `json:"numMessagesByApplication"`
}