grpc

Documentation

Overview

Package grpc provides a Pydio GRPC service for querying the logs

Index

• type Handler
  • func (h *Handler) AggregatedLogs(ctx context.Context, req *proto.TimeRangeRequest, ...) error
  • func (h *Handler) DeleteLogs(ctx context.Context, req *proto.ListLogRequest, resp *proto.DeleteLogsResponse) error
  • func (h *Handler) ListLogs(ctx context.Context, req *proto.ListLogRequest, ...) error
  • func (h *Handler) PutLog(ctx context.Context, stream proto.LogRecorder_PutLogStream) error
  • func (h *Handler) TriggerResync(ctx context.Context, request *sync.ResyncRequest, ...) error

Types

type Handler

type Handler struct {
	Repo log.MessageRepository
}

Handler is the gRPC interface for the log service.

func (*Handler) AggregatedLogs

func (h *Handler) AggregatedLogs(ctx context.Context, req *proto.TimeRangeRequest, stream proto.LogRecorder_AggregatedLogsStream) error

AggregatedLogs retrieves aggregated figures from the indexer to generate charts and reports.

func (*Handler) DeleteLogs

func (h *Handler) DeleteLogs(ctx context.Context, req *proto.ListLogRequest, resp *proto.DeleteLogsResponse) error

func (*Handler) ListLogs

func (h *Handler) ListLogs(ctx context.Context, req *proto.ListLogRequest, stream proto.LogRecorder_ListLogsStream) error

ListLogs is a simple gateway from protobuf to the indexer search engine.

func (*Handler) PutLog

func (h *Handler) PutLog(ctx context.Context, stream proto.LogRecorder_PutLogStream) error

PutLog retrieves the log messages from the proto stream and stores them in the index.

func (*Handler) TriggerResync

func (h *Handler) TriggerResync(ctx context.Context, request *sync.ResyncRequest, response *sync.ResyncResponse) error

TriggerResync uses the request.Path as parameter. If nothing is passed, it reads all the logs from index and reconstructs a new index entirely. If truncate/{int64} is passed, it truncates the log to the given size (or closer)