fastrpc

package module

v0.0.4 Latest Latest Go to latest Published: Oct 26, 2025 License: GPL-3.0 Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/AmanTrance/FastRpc

Links

Open Source Insights

Documentation ¶

Index ¶

type IOOperator
- func NewIOOperator(stream *net.TCPConn, readLength uint64) *IOOperator
type MasterCapabilities
type RpcMaster
- func NewMaster() (*RpcMaster, error)
type RpcSlave
- func NewRpcSlave(masterIP net.IP, masterPort int, poolSize int) (*RpcSlave, error)
- func (r *RpcSlave) DeInitialize()
- func (r *RpcSlave) GetMasterCapabilities() ([]struct{ ... }, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type IOOperator ¶

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

func NewIOOperator ¶

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

func (*IOOperator) ReadDataLeft ¶

func (i *IOOperator) ReadDataLeft() uint64

func (*IOOperator) ReadIOStream ¶

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

func (*IOOperator) WriteError ¶

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

func (*IOOperator) WriteIOFromBuffer ¶

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

func (*IOOperator) WriteIOFromReader ¶

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

func (*IOOperator) WriteNothing ¶

func (i *IOOperator) WriteNothing() error

type MasterCapabilities ¶

type MasterCapabilities struct {
	Name              string `json:"name"`
	Description       string `json:"description"`
	IncomingEncoding  string `json:"incomingEncoding"`
	ReturningEncoding string `json:"returningEncoding"`
	// contains filtered or unexported fields
}

type RpcMaster ¶

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

func NewMaster ¶

func NewMaster() (*RpcMaster, error)

func (*RpcMaster) RegisterRPC ¶

func (r *RpcMaster) RegisterRPC(name string, description string, incomingEncoding string, returningEncoding string,
	rpc func(*IOOperator) error)

func (*RpcMaster) RunRPC ¶

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

func (*RpcMaster) ShowCapabilities ¶

func (r *RpcMaster) ShowCapabilities() ([]struct {
	RpcID uint32 `json:"rpcId"`
	*MasterCapabilities
}, error)

type RpcSlave ¶

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

func NewRpcSlave ¶

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

func (*RpcSlave) DeInitialize ¶

func (r *RpcSlave) DeInitialize()

func (*RpcSlave) GetMasterCapabilities ¶

func (r *RpcSlave) GetMasterCapabilities() ([]struct {
	RpcID uint32 `json:"rpcId"`
	*MasterCapabilities
}, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL