ingest

Documentation

Index

• type Option
  • func WithReadTimeout(t time.Duration) Option
  • func WithVersion(ver string) Option
  • func WithWriteTimeout(t time.Duration) Option
• type Server
  • func New(listen string, indexer indexer.Interface, ingester *ingest.Ingester, ...) (*Server, error)
  • func (s *Server) Close() error
  • func (s *Server) Start() error
  • func (s *Server) URL() string

Types

type Option

type Option func(*serverConfig) error

Option is a function that sets a value in a serverConfig.

func WithReadTimeout

func WithReadTimeout(t time.Duration) Option

WithReadTimeout serverConfigures server read timeout.

func WithVersion

func WithVersion(ver string) Option

WithVersion sets the version string used in /health output.

func WithWriteTimeout

func WithWriteTimeout(t time.Duration) Option

WithWriteTimeout serverConfigures server write timeout.

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 ...Option) (*Server, error)

func (*Server) Close

func (s *Server) Close() error

func (*Server) Start

func (s *Server) Start() error

func (*Server) URL

func (s *Server) URL() string