server

Documentation

Index

• func Run(logger *zap.SugaredLogger, rpcAddr string, httpAddr string, dataDir string) error
• type Config
• type StructuredLogServer
  • func NewRpcHandler(logger *zap.SugaredLogger, config *Config) (*StructuredLogServer, error)
  • func (s *StructuredLogServer) AppendLogs(ctx context.Context, req *pb.AppendRequest) (*pb.AppendResponse, error)
  • func (s *StructuredLogServer) Close() error
  • func (s *StructuredLogServer) GetLogs(ctx context.Context, req *pb.GetLogsRequest) (*pb.GetLogsResponse, error)
  • func (s *StructuredLogServer) ListTopics(ctx context.Context, req *pb.ListTopicsRequest) (*pb.ListTopicsResponse, error)
  • func (s *StructuredLogServer) StreamLogs(req *pb.GetLogsRequest, stream pb.StructuredLog_StreamLogsServer) error

Functions

func Run

func Run(logger *zap.SugaredLogger, rpcAddr string, httpAddr string, dataDir string) error

Types

type Config

type Config struct {
	DataDir string
}

type StructuredLogServer

type StructuredLogServer struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewRpcHandler

func NewRpcHandler(logger *zap.SugaredLogger, config *Config) (*StructuredLogServer, error)

func (*StructuredLogServer) AppendLogs

func (s *StructuredLogServer) AppendLogs(ctx context.Context, req *pb.AppendRequest) (*pb.AppendResponse, error)

func (*StructuredLogServer) Close

func (s *StructuredLogServer) Close() error

func (*StructuredLogServer) GetLogs

func (s *StructuredLogServer) GetLogs(ctx context.Context, req *pb.GetLogsRequest) (*pb.GetLogsResponse, error)

func (*StructuredLogServer) ListTopics

func (s *StructuredLogServer) ListTopics(ctx context.Context, req *pb.ListTopicsRequest) (*pb.ListTopicsResponse, error)

func (*StructuredLogServer) StreamLogs

func (s *StructuredLogServer) StreamLogs(req *pb.GetLogsRequest, stream pb.StructuredLog_StreamLogsServer) error