logservice

Documentation

Index

• type Repo
• type Service
  • func New(r Repo) *Service
  • func (s *Service) CreateLogLine(ctx context.Context, r *v1.CreateLogLineRequest) (*v1.CreateLogLineResponse, error)
  • func (s *Service) CreateLogLines(ctx context.Context, r *v1.CreateLogLinesRequest) (*v1.CreateLogLinesResponse, error)
  • func (s *Service) GetLogLineTotal(ctx context.Context, r *emptypb.Empty) (*v1.GetLogLineTotalResponse, error)
  • func (s *Service) GetLogLinesHistory(ctx context.Context, r *v1.GetLogLinesHistoryRequest) (*v1.GetLogLinesHistoryResponse, error)

Types

type Repo

type Repo interface {
	CreateLogLine(ctx context.Context, line *models.LogLine) error
	CreateLogLines(ctx context.Context, lines []*models.LogLine) error
	GetLogLinesTotal(ctx context.Context) (uint64, error)
	GetLogLinesHistory(ctx context.Context, source string, limit int) ([]*models.LogLine, error)
}

type Service

type Service struct {
	v1.UnimplementedLogServiceServer
	// contains filtered or unexported fields
}

func New

func New(r Repo) *Service

func (*Service) CreateLogLine

func (s *Service) CreateLogLine(ctx context.Context, r *v1.CreateLogLineRequest) (*v1.CreateLogLineResponse, error)

func (*Service) CreateLogLines

func (s *Service) CreateLogLines(ctx context.Context, r *v1.CreateLogLinesRequest) (*v1.CreateLogLinesResponse, error)

func (*Service) GetLogLineTotal

func (s *Service) GetLogLineTotal(ctx context.Context, r *emptypb.Empty) (*v1.GetLogLineTotalResponse, error)

func (*Service) GetLogLinesHistory

func (s *Service) GetLogLinesHistory(ctx context.Context, r *v1.GetLogLinesHistoryRequest) (*v1.GetLogLinesHistoryResponse, error)