sofarpc

Documentation

Index

• Constants
• Variables
• func NewConnPool(host types.Host) types.ConnectionPool
• func NewSofaRPCKeepAlive(codec str.Client, proto byte, timeout time.Duration, thres uint32) types.KeepAlive
• func SetIdleTimeout(d time.Duration)
• type StreamDirection

Constants

const (
	Init = iota
	Connecting
	Connected
)

Variables

var (
	ErrNotSofarpcCmd      = errors.New("not sofarpc command")
	ErrNotResponseBuilder = errors.New("no response builder")
)

Functions

func NewConnPool

func NewConnPool(host types.Host) types.ConnectionPool

NewConnPool

func NewSofaRPCKeepAlive

func NewSofaRPCKeepAlive(codec str.Client, proto byte, timeout time.Duration, thres uint32) types.KeepAlive

func SetIdleTimeout

func SetIdleTimeout(d time.Duration)

SetIdleTimeout calculates the idle timeout as max idle count.

Types

type StreamDirection

type StreamDirection int

StreamDirection represent the stream's direction

const (
	ServerStream StreamDirection = 1
	ClientStream StreamDirection = 0
)

ServerStream = 1 ClientStream = 0