httpingestserver

Documentation

Index

• type Server
  • func New(listen string, indexer indexer.Interface, ingester *ingest.Ingester, ...) (*Server, error)
  • func (s *Server) Shutdown(ctx context.Context) error
  • func (s *Server) Start() error
  • func (s *Server) URL() string
• type ServerOption
  • func ReadTimeout(t time.Duration) ServerOption
  • func WriteTimeout(t time.Duration) ServerOption

Types

type Server

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

func New

func New(listen string, indexer indexer.Interface, ingester *ingest.Ingester, registry *registry.Registry, options ...ServerOption) (*Server, error)

func (*Server) Shutdown

func (s *Server) Shutdown(ctx context.Context) error

func (*Server) Start

func (s *Server) Start() error

func (*Server) URL

func (s *Server) URL() string

type ServerOption

type ServerOption func(*serverConfig) error

ServerOption for httpserver

func ReadTimeout

func ReadTimeout(t time.Duration) ServerOption

ReadTimeout config for API

func WriteTimeout

func WriteTimeout(t time.Duration) ServerOption

WriteTimeout config for API