server

Documentation

Index

• type Option
  • func WithAdFlushFrequency(t time.Duration) Option
  • func WithListenAddr(addr string) Option
  • func WithReadTimeout(t time.Duration) Option
  • func WithWriteTimeout(t time.Duration) Option
• type Server
  • func New(cidTtl time.Duration, chunkSize int, snapshotSize int, pageSize int, ...) (*Server, error)
  • func (s *Server) Shutdown(ctx context.Context) error
  • func (s *Server) Start() error

Types

type Option

type Option func(*options) error

Option captures a configurable parameter in admin HTTP server.

func WithAdFlushFrequency

func WithAdFlushFrequency(t time.Duration) Option

WithAdFlushFrequency sets the frequency at which the current chunk is publihsed even if it's not full

func WithListenAddr

func WithListenAddr(addr string) Option

WithListenAddr sets the net address on which the delegated routing HTTP server is exposed.

func WithReadTimeout

func WithReadTimeout(t time.Duration) Option

WithReadTimeout set s the HTTP read timeout. If unset, the default of 30 seconds is used.

func WithWriteTimeout

func WithWriteTimeout(t time.Duration) Option

WithWriteTimeout sets the HTTP write timeout. If unset, the default of 30 seconds is used.

type Server

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

func New

func New(cidTtl time.Duration,
	chunkSize int,
	snapshotSize int,
	pageSize int,
	providerID string,
	addrs []string,
	e provider.Interface,
	ds datastore.Batching,
	o ...Option) (*Server, error)

func (*Server) Shutdown

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

func (*Server) Start

func (s *Server) Start() error