server

Documentation

Overview

Package server provides the demonstration unsecure server.

Index

• func Listen(addrPort string, fn func(*api.Log)) error
• type ByTimestamp
  • func (l ByTimestamp) Len() int
  • func (l ByTimestamp) Less(i, j int) bool
  • func (l ByTimestamp) Swap(i, j int)
• type Server
  • func (s *Server) SendLog(ctx context.Context, in *api.Log) (*api.Ack, error)

Functions

func Listen

func Listen(addrPort string, fn func(*api.Log)) error

Listen with gRPG service

Types

type ByTimestamp

type ByTimestamp []*api.Log

ByTimestamp sorting interface

func (ByTimestamp) Len

func (l ByTimestamp) Len() int

func (ByTimestamp) Less

func (l ByTimestamp) Less(i, j int) bool

func (ByTimestamp) Swap

func (l ByTimestamp) Swap(i, j int)

type Server

type Server struct{}

func (*Server) SendLog

func (s *Server) SendLog(ctx context.Context, in *api.Log) (*api.Ack, error)

Sendlog Handler

Handle incoming log messages