isglb

README

isglb

islb?is-graph-lb!

Documentation

Index

• func SFUStatusIsSame(s1, s2 *pb.SFUStatus) bool
• type Config
  • func (c *Config) Load(file string) error
• type ISGLB
  • func New(algConstructor func() algorithms.Algorithm) *ISGLB
  • func (s *ISGLB) Close()
  • func (s *ISGLB) ConfigBase() runner.ConfigBase
  • func (s *ISGLB) Load(confFile string) error
  • func (s *ISGLB) Start(conf Config) error
  • func (s *ISGLB) StartGRPC(registrar grpc.ServiceRegistrar) error
• type ISGLBClient
  • func NewISGLBClient(node *ion.Node, peerNID string, parameters map[string]interface{}) *ISGLBClient
  • func (c *ISGLBClient) Close()
  • func (c *ISGLBClient) Connect()
  • func (c *ISGLBClient) Connected() bool
  • func (c *ISGLBClient) Name() string
  • func (c *ISGLBClient) SendSyncRequest(r *pb.SyncRequest) error
• type ISGLBService
  • func NewISGLBService(alg algorithms.Algorithm) *ISGLBService
  • func (isglb *ISGLBService) RegisterService(registrar grpc.ServiceRegistrar)
  • func (isglb *ISGLBService) SyncSFU(sig pb.ISGLB_SyncSFUServer) error

Functions

func SFUStatusIsSame

func SFUStatusIsSame(s1, s2 *pb.SFUStatus) bool

SFUStatusIsSame compare whether the two SFUStatus is same

Types

type Config

type Config config.Common

func (*Config) Load

func (c *Config) Load(file string) error

type ISGLB

type ISGLB struct {
	ion.Node

	runner.Service
	// contains filtered or unexported fields
}

func New

func New(algConstructor func() algorithms.Algorithm) *ISGLB

New create a new ISGLB algConstructor should return a algorithms.Algorithm

func (*ISGLB) Close

func (s *ISGLB) Close()

Close all

func (*ISGLB) ConfigBase

func (s *ISGLB) ConfigBase() runner.ConfigBase

func (*ISGLB) Load

func (s *ISGLB) Load(confFile string) error

Load load config file

func (*ISGLB) Start

func (s *ISGLB) Start(conf Config) error

func (*ISGLB) StartGRPC

func (s *ISGLB) StartGRPC(registrar grpc.ServiceRegistrar) error

StartGRPC start with grpc.ServiceRegistrar

type ISGLBClient

type ISGLBClient struct {
	sdk.Service

	Metadata metadata.MD

	OnSFUStatusRecv func(s *pb.SFUStatus)
	// contains filtered or unexported fields
}

func NewISGLBClient

func NewISGLBClient(node *ion.Node, peerNID string, parameters map[string]interface{}) *ISGLBClient

func (*ISGLBClient) Close

func (c *ISGLBClient) Close()

func (*ISGLBClient) Connect

func (c *ISGLBClient) Connect()

func (*ISGLBClient) Connected

func (c *ISGLBClient) Connected() bool

func (*ISGLBClient) Name

func (c *ISGLBClient) Name() string

func (*ISGLBClient) SendSyncRequest

func (c *ISGLBClient) SendSyncRequest(r *pb.SyncRequest) error

type ISGLBService

type ISGLBService struct {
	pb.UnimplementedISGLBServer
	Alg algorithms.Algorithm // The core algorithm
	// contains filtered or unexported fields
}

ISGLBService represents isglb node

func NewISGLBService

func NewISGLBService(alg algorithms.Algorithm) *ISGLBService

func (*ISGLBService) RegisterService

func (isglb *ISGLBService) RegisterService(registrar grpc.ServiceRegistrar)

func (*ISGLBService) SyncSFU

func (isglb *ISGLBService) SyncSFU(sig pb.ISGLB_SyncSFUServer) error

SyncSFU receive current SFUStatus, call the algorithm, and reply expected SFUStatus