one

README

ONE-RPC

A tiny RPC framework

Documentation

Index

• Constants
• Variables
• func Init()
• func RegisterService(name string, serverConf *transport.OneSvrConf, metaInfo ...string) error
• func Run()
• func SetRegisterCenter(regName string) error
• type ClientConstructor
• type Context
  • func GetContext() Context
• type OneGlobalConf
• type ServiceController
  • func NewServiceController(name string, constructor ClientConstructor, addrs ...string) (sc *ServiceController, err error)
  • func (sc *ServiceController) Send(ctx context.Context, servant string, funcName string, pkg []byte) (rspPkg []byte, err error)

Constants

const (
	ONE_RPC_VERSION = 1
	PROTOCOL        = "tcp"

	SvrAcceptTimeout = 500 * time.Millisecond

	CltDialTimeout  = 500 * time.Millisecond
	CltReadTimeout  = 500 * time.Millisecond
	CltWriteTimeout = 500 * time.Millisecond
	CltIdleTimeout  = 500 * time.Millisecond

	QueueCap = 10000

	TCPReadBuf  = 128 * 1024 * 1024
	TCPWriteBuf = 128 * 1024 * 1024

	CLT_REQ_TIMEOUT = 3 * time.Second

	NORMAL_BALANCE = "normal"

	REGISTER_CENTER_ETCD = "etcd"
)

const MAX_INT int32 = 1<<31 - 1

Variables

var (
	ConfPath string
)

Functions

func Init

func Init()

func RegisterService

func RegisterService(name string, serverConf *transport.OneSvrConf, metaInfo ...string) error

func Run

func Run()

func SetRegisterCenter

func SetRegisterCenter(regName string) error

Types

type ClientConstructor

type ClientConstructor func(name string, conf *transport.OneCltConf) transport.CltProtocol

type Context

type Context *contextImp

func GetContext

func GetContext() Context

type OneGlobalConf

type OneGlobalConf struct {
	LogPath  string                           `yaml:"logpath"`
	Server   map[string]*transport.OneSvrConf `yaml:"server"`
	Client   transport.OneCltConf             `yaml:"client"`
	Registry *registry.RegistryConf           `yaml:"registry"`
}

type ServiceController

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

func NewServiceController

func NewServiceController(name string, constructor ClientConstructor, addrs ...string) (sc *ServiceController, err error)

func (*ServiceController) Send

func (sc *ServiceController) Send(ctx context.Context, servant string, funcName string, pkg []byte) (rspPkg []byte, err error)