server

Documentation

Index

• type BlockResponse
  • func (r *BlockResponse) Write(w io.Writer, segmentBuf []byte) error
• type Config
  • func DefaultConfig() *Config
  • func (conf *Config) RequiredDataServers() int
• type Server
  • func NewServer(conf *Config, configSource config.Source) (*Server, error)
  • func (s *Server) Listen(ctx context.Context)
  • func (s *Server) ListenAddr() string
  • func (s *Server) ReadDecodeClientMessage(r io.Reader) (*schema.TlogClientMessage, error)

Types

type BlockResponse

type BlockResponse struct {
	Status    int8
	Sequences []uint64
}

BlockResponse defines response for block operations(recv, flush)

func (*BlockResponse) Write

func (r *BlockResponse) Write(w io.Writer, segmentBuf []byte) error

Write encode and writes this response to the given io.Writer

type Config

type Config struct {
	DataShards   int
	ParityShards int
	BlockSize    int // size of each block, used as hint for the flusher buffer size
	ListenAddr   string
	FlushSize    int
	FlushTime    int
	PrivKey      string
	AggMq        *aggmq.MQ
}

Config used for creating the tlogserver

func DefaultConfig

func DefaultConfig() *Config

DefaultConfig creates a new config, using sane defaults

func (*Config) RequiredDataServers

func (conf *Config) RequiredDataServers() int

RequiredDataServers returns how many data servers are required, based on the DataShards and ParityShards values.

type Server

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

Server defines a tlog server

func NewServer

func NewServer(conf *Config, configSource config.Source) (*Server, error)

NewServer creates a new tlog server

func (*Server) Listen

func (s *Server) Listen(ctx context.Context)

Listen to incoming (tcp) Requests

func (*Server) ListenAddr

func (s *Server) ListenAddr() string

ListenAddr returns the address the (tcp) server is listening on

func (*Server) ReadDecodeClientMessage

func (s *Server) ReadDecodeClientMessage(r io.Reader) (*schema.TlogClientMessage, error)

ReadDecodeClientMessage reads and decodes tlog message from client