backend

Documentation

Index

• Variables
• func CallRpc(method string, args, reply interface{}) error
• func InitClients(addresses []string)
• type BackendClients
  • func (this *BackendClients) GetAddresses() []string
  • func (this *BackendClients) GetClient(addr string) (*rpc.Client, bool)
  • func (this *BackendClients) InitAddresses(addresses []string)
  • func (this *BackendClients) InitClients(clients map[string]*rpc.Client)
  • func (this *BackendClients) ReplaceClient(addr string, client *rpc.Client)

Variables

var Clients = &BackendClients{Clients: make(map[string]*rpc.Client)}

Functions

func CallRpc

func CallRpc(method string, args, reply interface{}) error

func InitClients

func InitClients(addresses []string)

Types

type BackendClients

type BackendClients struct {
	sync.RWMutex
	Clients   map[string]*rpc.Client
	Addresses []string
}

func (*BackendClients) GetAddresses

func (this *BackendClients) GetAddresses() []string

func (*BackendClients) GetClient

func (this *BackendClients) GetClient(addr string) (*rpc.Client, bool)

func (*BackendClients) InitAddresses

func (this *BackendClients) InitAddresses(addresses []string)

func (*BackendClients) InitClients

func (this *BackendClients) InitClients(clients map[string]*rpc.Client)

func (*BackendClients) ReplaceClient

func (this *BackendClients) ReplaceClient(addr string, client *rpc.Client)