logs

Documentation

Index

• type LogConsumer
  • func NewConsumer(conn *amqp.Connection, mongo *mongo.Client) (LogConsumer, error)
  • func (consumer *LogConsumer) Listen() error
• type LogEntry
• type LogPayload
• type LogPublisher
  • func (l *LogPublisher) LogERROR(serviceName, data string)
  • func (l *LogPublisher) LogINFO(serviceName, data string)
  • func (l *LogPublisher) LogWARNING(serviceName, data string)
  • func (l *LogPublisher) SetAMQPConnection(connection *amqp.Connection)
  • func (l *LogPublisher) SetLogLevel(level uint)

Types

type LogConsumer

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

func NewConsumer

func NewConsumer(conn *amqp.Connection, mongo *mongo.Client) (LogConsumer, error)

func (*LogConsumer) Listen

func (consumer *LogConsumer) Listen() error

type LogEntry

type LogEntry struct {
	ID        string    `bson:"_id,omitempty" json:"id,omitempty"`
	Service   string    `bson:"service" json:"service"`
	Data      string    `bson:"data" json:"data"`
	LogLevel  string    `bson:"log_level" json:"log_level"`
	CreatedAt time.Time `bson:"created_at" json:"created_at"`
	UpdatedAt time.Time `bson:"updated_at" json:"updated_at"`
}

type LogPayload

type LogPayload struct {
	Service  string `json:"service"`
	Data     string `json:"data"`
	LogLevel string `json:"log_level"`
}

type LogPublisher

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

func (*LogPublisher) LogERROR

func (l *LogPublisher) LogERROR(serviceName, data string)

func (*LogPublisher) LogINFO

func (l *LogPublisher) LogINFO(serviceName, data string)

func (*LogPublisher) LogWARNING

func (l *LogPublisher) LogWARNING(serviceName, data string)

func (*LogPublisher) SetAMQPConnection

func (l *LogPublisher) SetAMQPConnection(connection *amqp.Connection)

func (*LogPublisher) SetLogLevel

func (l *LogPublisher) SetLogLevel(level uint)