fastrpc

Nov 24, 2025

Changes in this version

+ const MAX_RETRY_COUNT

Nov 15, 2025

Changes in this version

+ const BUFFER_SIZE

+ type ConnectionState struct

Nov 7, 2025

Changes in this version

+ const DEFAULT_CHUNK_SIZE

type MasterCapabilities

+ IncomingType string

+ ReturningType string

type MasterCapabilitiesDTO

+ IncomingType string

+ ReturningType string

type RpcMaster

+ func (r *RpcMaster) Close() error

+ func (r *RpcMaster) Start(ctx context.Context, ip net.IP, port int) error

type RpcSlave

+ func NewSlave(masterIP net.IP, masterPort int, poolSize int) (*RpcSlave, error)

+ func (r *RpcSlave) CallForBuffer(method string, buf []byte) ([]byte, error)

Oct 26, 2025

Changes in this version

+ type MasterCapabilitiesDTO struct

+ Description string

+ IncomingEncoding string

+ Name string

+ ReturningEncoding string

+ RpcID uint32

Oct 26, 2025

Changes in this version

+ type IOOperator struct

+ func NewIOOperator(stream *net.TCPConn, readLength uint64) *IOOperator

+ func (i *IOOperator) ReadDataLeft() uint64

+ func (i *IOOperator) ReadIOStream(count int) ([]byte, error)

+ func (i *IOOperator) WriteError(message string) error

+ func (i *IOOperator) WriteIOFromBuffer(buf []byte) error

+ func (i *IOOperator) WriteIOFromReader(reader io.Reader, count int, chunkSize int) error

+ func (i *IOOperator) WriteNothing() error

+ type MasterCapabilities struct

+ Description string

+ IncomingEncoding string

+ Name string

+ ReturningEncoding string

+ type RpcMaster struct

+ func NewMaster() (*RpcMaster, error)

+ func (r *RpcMaster) RegisterRPC(name string, description string, incomingEncoding string, ...)

+ func (r *RpcMaster) RunRPC(ctx context.Context, ip net.IP, port int) error

+ func (r *RpcMaster) ShowCapabilities() ([]struct{ ... }, error)

+ type RpcSlave struct

+ func NewRpcSlave(masterIP net.IP, masterPort int, poolSize int) (*RpcSlave, error)

+ func (r *RpcSlave) DeInitialize()

+ func (r *RpcSlave) GetMasterCapabilities() ([]struct{ ... }, error)