status

Documentation

Index

• Constants
• func Debug(message string)
• func Error(message string)
• func Info(message string)
• func InitService() error
• func Subscribe(ctx context.Context) <-chan pubsub.Event[StatusMessage]
• func Warn(message string)
• type Level
• type Service
  • func GetService() Service
• type StatusMessage

Constants

const (
	EventStatusPublished pubsub.EventType = "status_published"
)

Functions

func Debug

func Debug(message string)

func Error

func Error(message string)

func Info

func Info(message string)

func InitService

func InitService() error

func Subscribe

func Subscribe(ctx context.Context) <-chan pubsub.Event[StatusMessage]

func Warn

func Warn(message string)

Types

type Level

type Level string

const (
	LevelInfo  Level = "info"
	LevelWarn  Level = "warn"
	LevelError Level = "error"
	LevelDebug Level = "debug"
)

type Service

type Service interface {
	pubsub.Subscriber[StatusMessage]

	Info(message string)
	Warn(message string)
	Error(message string)
	Debug(message string)
}

func GetService

func GetService() Service

type StatusMessage

type StatusMessage struct {
	Level     Level     `json:"level"`
	Message   string    `json:"message"`
	Timestamp time.Time `json:"timestamp"`
}