destination

Documentation

Index

• type Map
• type Server
• type ServerHostPort
• type ServersStr
• type Setting
  • func NewSetting() *Setting
  • func (s *Setting) ChooseNextServer() (srv ServerHostPort, ok bool)
  • func (s *Setting) Destroy()
  • func (s *Setting) Init()
  • func (s *Setting) TempDisableHost(srv ServerHostPort, aliveCheck aliveCheckFunc)

Types

type Map

type Map map[ServersStr]*Setting

Map represents routing map config

type Server

type Server struct {
	HostPort ServerHostPort
	Weight   uint32
}

Server is a single entry in cluster specification

type ServerHostPort

type ServerHostPort string

ServerHostPort is a full host name with port, e.g. "srv1:8123"

type ServersStr

type ServersStr string

ServersStr represent location that accepts logs (e.g. "srv1:8123" or "=srv1*100 =srv2*100 =srv3*100")

type Setting

type Setting struct {
	Default bool
	Servers []Server
	Tables  []string
	// contains filtered or unexported fields
}

Setting represents group of settings for specific destination Server

func NewSetting

func NewSetting() *Setting

NewSetting must be used to initialize Setting struct

func (*Setting) ChooseNextServer

func (s *Setting) ChooseNextServer() (srv ServerHostPort, ok bool)

ChooseNextServer returns next server from the list or ok=false, which means that there are no available hosts

func (*Setting) Destroy

func (s *Setting) Destroy()

Destroy stops health check goroutines, if any

func (*Setting) Init

func (s *Setting) Init()

Init sets up current state based on public settings

func (*Setting) TempDisableHost

func (s *Setting) TempDisableHost(srv ServerHostPort, aliveCheck aliveCheckFunc)

TempDisableHost marks provided host as temporarily disabled (it will not be returned in ChooseNextServer()). Provided callback checkCb is used to periodically check that server went live again.