lbreg

Documentation

Index

• Constants
• func InitPushServer(cluster []string) *r.PushServer
• type LBFileProcessor
  • func (p LBFileProcessor) Process(name string, files map[string][]byte) ([]r.DBInsert, error)
• type LBFiles
• type LBPullClient
  • func InitLBPullClient(cluster []string) *LBPullClient
  • func (c *LBPullClient) Pull(name string) LBFiles
• type PushClient
  • func InitPushClient(saddr string) *PushClient
  • func (c *PushClient) PushFiles(name string, files PushClientFiles)
• type PushClientFiles
• type ServerFiles
• type ServerPullClient
  • func InitServerPullClient(cluster []string) *ServerPullClient
  • func (c *ServerPullClient) Pull(name string) ServerFiles

Constants

const (
	CHUNK_SIZE = 1024
	DATABASE   = "lbregistry"
	BALANCER   = "balancer"
	SERVER     = "server"
	PROTO      = "proto"
	HANDLER    = "handler"
	PB         = "pb"
	PARSER     = "parser"
	SPORT      = 10000
)

Functions

func InitPushServer

func InitPushServer(cluster []string) *r.PushServer

Types

type LBFileProcessor

type LBFileProcessor struct{}

func (LBFileProcessor) Process

func (p LBFileProcessor) Process(name string, files map[string][]byte) ([]r.DBInsert, error)

type LBFiles

type LBFiles struct {
	Parser []byte
}

type LBPullClient

type LBPullClient struct {
	Client *r.PullClient
}

func InitLBPullClient

func InitLBPullClient(cluster []string) *LBPullClient

func (*LBPullClient) Pull

func (c *LBPullClient) Pull(name string) LBFiles

type PushClient

type PushClient struct {
	Client *r.PushClient
}

func InitPushClient

func InitPushClient(saddr string) *PushClient

func (*PushClient) PushFiles

func (c *PushClient) PushFiles(name string, files PushClientFiles)

type PushClientFiles

type PushClientFiles struct {
	Handler string
	Proto   string
}

type ServerFiles

type ServerFiles struct {
	Handler []byte
	PB      []byte
}

type ServerPullClient

type ServerPullClient struct {
	Client *r.PullClient
}

func InitServerPullClient

func InitServerPullClient(cluster []string) *ServerPullClient

func (*ServerPullClient) Pull

func (c *ServerPullClient) Pull(name string) ServerFiles