loki

Documentation

Index

• func GTagMiddleware(loki *Loki) gtaghttp.Middleware
• func MPv2MessageHandler(loki *Loki) message.NoPublishHandlerFunc
• func MPv2Middleware(loki *Loki) mpv2http.Middleware
• type Line
  • func (l *Line) Marshal() ([]byte, error)
• type Loki
  • func New(l *zap.Logger, addr string, opts ...Option) *Loki
  • func (l *Loki) Start(ctx context.Context)
  • func (l *Loki) Stop()
  • func (l *Loki) Write(payload mpv2.Payload[any])
• type Option
  • func WithBackoffConfig(v *backoff.Config) Option
  • func WithBatchSize(v int) Option
  • func WithBufferSize(v int) Option
  • func WithHTTPClient(v *http.Client) Option
  • func WithUserAgent(v string) Option
• type Service
  • func NewService(loki *Loki) *Service
  • func (s *Service) Close(ctx context.Context) error
  • func (s *Service) Name() string
  • func (s *Service) Start(ctx context.Context) error

Functions

func GTagMiddleware

func GTagMiddleware(loki *Loki) gtaghttp.Middleware

func MPv2MessageHandler

func MPv2MessageHandler(loki *Loki) message.NoPublishHandlerFunc

func MPv2Middleware

func MPv2Middleware(loki *Loki) mpv2http.Middleware

Types

type Line

type Line struct {
	Name               sesamy.EventName  `json:"name"`
	Params             any               `json:"params,omitempty"`
	ClientID           string            `json:"client_id,omitempty"`
	UserID             string            `json:"user_id,omitempty"`
	UserProperties     map[string]any    `json:"user_properties,omitempty"`
	Consent            *mpv2.ConsentData `json:"consent,omitempty"`
	UserData           *mpv2.UserData    `json:"user_data,omitempty"`
	DebugMode          bool              `json:"debug_mode,omitempty"`
	SessionID          string            `json:"session_id,omitempty"`
	EngagementTimeMSec int64             `json:"engagement_time_msec,omitempty"`
}

func (*Line) Marshal

func (l *Line) Marshal() ([]byte, error)

type Loki

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

func New

func New(l *zap.Logger, addr string, opts ...Option) *Loki

New creates an instance of `Push` which writes logs directly to given `lokiAddr`

func (*Loki) Start

func (l *Loki) Start(ctx context.Context)

Start pulls lines out of the channel and sends them to Loki

func (*Loki) Stop

func (l *Loki) Stop()

Stop will cancel any ongoing requests and stop the goroutine listening for requests

func (*Loki) Write

func (l *Loki) Write(payload mpv2.Payload[any])

type Option

type Option func(*Loki)

func WithBackoffConfig

func WithBackoffConfig(v *backoff.Config) Option

func WithBatchSize

func WithBatchSize(v int) Option

func WithBufferSize

func WithBufferSize(v int) Option

func WithHTTPClient

func WithHTTPClient(v *http.Client) Option

func WithUserAgent

func WithUserAgent(v string) Option

type Service

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

func NewService

func NewService(loki *Loki) *Service

func (*Service) Close

func (s *Service) Close(ctx context.Context) error

Close will cancel any ongoing requests and stop the goroutine listening for requests

func (*Service) Name

func (s *Service) Name() string

func (*Service) Start

func (s *Service) Start(ctx context.Context) error

Start pulls lines out of the channel and sends them to Loki