darkrpc

Documentation

Index

• Constants
• type Args
• type ClientOpt
  • func WithSockCli(sock string) ClientOpt
• type ClientRpc
  • func (r *ClientRpc) GetBases(args Args, reply *Reply) error
  • func (r *ClientRpc) GetHealth(args Args, reply *bool) error
• type Reply
• type RpcI
  • func NewClient(opts ...ClientOpt) RpcI
  • func NewRpc(app_data *router.AppData) RpcI
• type RpcServer
  • func NewRpcServer(opts ...ServerOpt) *RpcServer
  • func (r *RpcServer) Close()
  • func (r *RpcServer) Serve(app_data *router.AppData)
• type ServerOpt
  • func WithPortSrv(port int) ServerOpt
  • func WithSockSrv(sock string) ServerOpt
• type ServerRpc
  • func (t *ServerRpc) GetBases(args Args, reply *Reply) error
  • func (t *ServerRpc) GetHealth(args Args, reply *bool) error

Constants

const DarkstatSock = "/tmp/darkstat/rpc.sock"

Types

type Args

type Args struct {
}

type ClientOpt

type ClientOpt func(r *ClientRpc)

func WithSockCli

func WithSockCli(sock string) ClientOpt

type ClientRpc

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

/ CLIENT///////////////////

func (*ClientRpc) GetBases

func (r *ClientRpc) GetBases(args Args, reply *Reply) error

func (*ClientRpc) GetHealth

func (r *ClientRpc) GetHealth(args Args, reply *bool) error

type Reply

type Reply struct {
	Bases []*configs_export.Base
}

type RpcI

type RpcI interface {
	GetBases(args Args, reply *Reply) error
	GetHealth(args Args, reply *bool) error
}

func NewClient

func NewClient(opts ...ClientOpt) RpcI

func NewRpc

func NewRpc(app_data *router.AppData) RpcI

type RpcServer

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

func NewRpcServer

func NewRpcServer(opts ...ServerOpt) *RpcServer

func (*RpcServer) Close

func (r *RpcServer) Close()

func (*RpcServer) Serve

func (r *RpcServer) Serve(app_data *router.AppData)

type ServerOpt

type ServerOpt func(r *RpcServer)

func WithPortSrv

func WithPortSrv(port int) ServerOpt

func WithSockSrv

func WithSockSrv(sock string) ServerOpt

type ServerRpc

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

func (*ServerRpc) GetBases

func (t *ServerRpc) GetBases(args Args, reply *Reply) error

func (*ServerRpc) GetHealth

func (t *ServerRpc) GetHealth(args Args, reply *bool) error