olreg

Documentation

Index

• Constants
• func InitPushServer(port int, cluster []string) *r.PushServer
• type FileProcessor
  • func (p FileProcessor) Process(name string, files map[string][]byte) ([]r.DBInsert, error)
• type PullClient
  • func InitPullClient(cluster []string) *PullClient
  • func (c *PullClient) Pull(name string) []byte
• type PushClient
  • func InitPushClient(saddr string) *PushClient
  • func (c *PushClient) PushFiles(name, fname, ftype string)

Constants

const (
	CHUNK_SIZE = 1024
	DATABASE   = "olregistry"
	HANDLER    = "handler"
	SPORT      = 10000
	TABLE      = "handlers"
)

Functions

func InitPushServer

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

Types

type FileProcessor

type FileProcessor struct{}

func (FileProcessor) Process

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

type PullClient

type PullClient struct {
	Client *r.PullClient
}

func InitPullClient

func InitPullClient(cluster []string) *PullClient

func (*PullClient) Pull

func (c *PullClient) Pull(name string) []byte

type PushClient

type PushClient struct {
	Client *r.PushClient
}

func InitPushClient

func InitPushClient(saddr string) *PushClient

func (*PushClient) PushFiles

func (c *PushClient) PushFiles(name, fname, ftype string)