client

Documentation

Index

• Constants
• func ExtractCategoryName(baseDir, absolutePath string) string
• func ReadDirIntoChannel(baseDir string, events chan fsnotify.Event, iterateSubDir bool) error
• type Client
  • func NewClient(config *lsdProto.LsdConfigClientConfigT, trafficManager *traffic.Manager) (*Client, error)
  • func (c *Client) Start()
  • func (c *Client) Stop()
• type NetworkRouter
  • func NewNetworkRouter(offsetsDb *offsets.Db, trafficManager *traffic.Manager, ...) (*NetworkRouter, error)

Constants

const BACKLOG_MAX_SIZE = 1000000

const FINAL_SYNC_BUFFER_SIZE = 1000

const READDIR_BUFFER_SIZE = 1000

Functions

func ExtractCategoryName

func ExtractCategoryName(baseDir, absolutePath string) string

func ReadDirIntoChannel

func ReadDirIntoChannel(baseDir string, events chan fsnotify.Event, iterateSubDir bool) error

Types

type Client

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

func NewClient

func NewClient(config *lsdProto.LsdConfigClientConfigT, trafficManager *traffic.Manager) (*Client, error)

func (*Client) Start

func (c *Client) Start()

func (*Client) Stop

func (c *Client) Stop()

type NetworkRouter

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

func NewNetworkRouter

func NewNetworkRouter(offsetsDb *offsets.Db, trafficManager *traffic.Manager, config *lsdProto.LsdConfigClientConfigT) (*NetworkRouter, error)