logs

Documentation

Index

• Variables
• type ErrInvalidBatchSize
  • func (err ErrInvalidBatchSize) Error() string
  • func (err ErrInvalidBatchSize) RecommendedBatchSize() int
• type LogService
  • func (ls LogService) GetLogs(ctx context.Context, request *logs.GetLogsRequest, publisher ResponsePublisher) error
• type ResponsePublisher

Variables

var (
	// ErrUnimplemented is returned whenever requested functionality is planned but unimplemented.
	ErrUnimplemented = errors.New("unimplemented")
	// ErrPublish is returned whenever publishing fails (say, due to a closed client).
	ErrPublish = errors.New("error publishing")
	// ErrBadRequest indicates that the client made an erroneous request.
	ErrBadRequest = errors.New("bad request")
)

Types

type ErrInvalidBatchSize

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

func (ErrInvalidBatchSize) Error

func (err ErrInvalidBatchSize) Error() string

func (ErrInvalidBatchSize) RecommendedBatchSize

func (err ErrInvalidBatchSize) RecommendedBatchSize() int

type LogService

type LogService struct {
	GetLokiClient func() (*loki.Client, error)
	AuthServer    authserver.APIServer
}

LogService implements the core logs functionality.

func (LogService) GetLogs

func (ls LogService) GetLogs(ctx context.Context, request *logs.GetLogsRequest, publisher ResponsePublisher) error

GetLogs gets logs according its request and publishes them. The pattern is similar to that used when handling an HTTP request.

type ResponsePublisher

type ResponsePublisher interface {
	// Publish publishes a single GetLogsResponse to the client.
	Publish(context.Context, *logs.GetLogsResponse) error
}