example

package
v0.4.17 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 28, 2023 License: MIT Imports: 9 Imported by: 0

Documentation

Overview

Generated by the go idl tools. DO NOT EDIT 2022-03-17 11:34:04 source: TestCaller

Generated by the go idl tools. DO NOT EDIT 2022-03-17 11:27:42 source: box_example

Index

Constants

View Source 
const (
	SrvUUID = 8590810067174448481
	SrvName = "TestCaller"
)

Variables

This section is empty.

Functions

func TestCallerProxyCreator 

func TestCallerProxyCreator(trans transport.ITransport) idlrpc.IProxy

func TestCallerStubCreator 

func TestCallerStubCreator(v interface{}) idlrpc.IStub

Types

type ITestCaller 

type ITestCaller interface {
	idlrpc.IService
	SetInfo(context.Context, string) error
	GetInfo(context.Context) (string, error)
}

type TestCallerImpl 

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

func NewTestCaller 

func NewTestCaller() *TestCallerImpl

func (*TestCallerImpl) GetInfo 

func (sp *TestCallerImpl) GetInfo(ctx context.Context) (ret1 string, err error)

func (*TestCallerImpl) GetNickName 

func (sp *TestCallerImpl) GetNickName() string

func (*TestCallerImpl) GetUUID 

func (sp *TestCallerImpl) GetUUID() uint64

func (*TestCallerImpl) OnAfterFork 

func (sp *TestCallerImpl) OnAfterFork(ctx context.Context) bool

func (*TestCallerImpl) OnBeforeDestroy 

func (sp *TestCallerImpl) OnBeforeDestroy() bool

func (*TestCallerImpl) OnTick 

func (sp *TestCallerImpl) OnTick() bool

func (*TestCallerImpl) SetInfo 

func (sp *TestCallerImpl) SetInfo(ctx context.Context, _1 string) (err error)

type TestCallerProxy 

type TestCallerProxy struct {
	idlrpc.ProxyBase
}

TestCallerProxy define stub.ProxyStub

func (*TestCallerProxy) GetInfo 

func (sp *TestCallerProxy) GetInfo() (ret1 string, err error)

func (*TestCallerProxy) GetSignature 

func (sp *TestCallerProxy) GetSignature(methid uint32) string

func (*TestCallerProxy) GetSrvName 

func (sp *TestCallerProxy) GetSrvName() string

func (*TestCallerProxy) GetUUID 

func (sp *TestCallerProxy) GetUUID() uint64

GetUUID define function

func (*TestCallerProxy) IsOneWay 

func (sp *TestCallerProxy) IsOneWay(methodid uint32) (isoneway bool)

func (*TestCallerProxy) SetInfo 

func (sp *TestCallerProxy) SetInfo(_1 string) (err error)

type TestCallerStub 

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

func NewTestCallerStub 

func NewTestCallerStub(srvImpl ITestCaller) *TestCallerStub

func (*TestCallerStub) Call 

func (sb *TestCallerStub) Call(ctx context.Context, methodId uint32, req []byte) (resp []byte, err error)

func (*TestCallerStub) GetInfo 

func (sb *TestCallerStub) GetInfo(ctx context.Context, req []byte) (resp []byte, err error)

func (*TestCallerStub) GetMutipleNum 

func (sb *TestCallerStub) GetMutipleNum() uint32

func (*TestCallerStub) GetServiceName 

func (sb *TestCallerStub) GetServiceName() string

func (*TestCallerStub) GetSignature 

func (sb *TestCallerStub) GetSignature(methodid uint32) string

func (*TestCallerStub) GetStatus 

func (sb *TestCallerStub) GetStatus() idlrpc.ServiceStatus

func (*TestCallerStub) GetUUID 

func (sb *TestCallerStub) GetUUID() idlrpc.SvcUuid

func (*TestCallerStub) IsOneWay 

func (sb *TestCallerStub) IsOneWay(methodid uint32) (isoneway bool)

func (*TestCallerStub) OnAfterFork 

func (sb *TestCallerStub) OnAfterFork(ctx context.Context) bool

func (*TestCallerStub) OnBeforeDestroy 

func (sb *TestCallerStub) OnBeforeDestroy() bool

func (*TestCallerStub) OnTick 

func (sb *TestCallerStub) OnTick() bool

func (*TestCallerStub) SetInfo 

func (sb *TestCallerStub) SetInfo(ctx context.Context, req []byte) (resp []byte, err error)

func (*TestCallerStub) SetStatus 

func (sb *TestCallerStub) SetStatus(status idlrpc.ServiceStatus)

type TransportRing 

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

TransportRing 双队列，一读一写

func NewTransportRing 

func NewTransportRing() *TransportRing

func (*TransportRing) Close 

func (trans *TransportRing) Close()

func (*TransportRing) GetID 

func (trans *TransportRing) GetID() uint32

func (*TransportRing) GlobalIndex 

func (trans *TransportRing) GlobalIndex() protocol.GlobalIndexType

func (*TransportRing) Heartbeat added in v0.4.16 

func (trans *TransportRing) Heartbeat() error

func (*TransportRing) IsClose 

func (trans *TransportRing) IsClose() bool

func (*TransportRing) LocalAddr 

func (trans *TransportRing) LocalAddr() string

func (*TransportRing) Peek 

func (trans *TransportRing) Peek(length int) ([]byte, int, error)

func (*TransportRing) PopSend 

func (trans *TransportRing) PopSend() []byte

func (*TransportRing) Read 

func (trans *TransportRing) Read(pkg []byte, length int) (int, error)

func (*TransportRing) RemoteAddr 

func (trans *TransportRing) RemoteAddr() string

func (*TransportRing) Send 

func (trans *TransportRing) Send(pkg []byte) error

func (*TransportRing) SetID 

func (trans *TransportRing) SetID(id uint32)

func (*TransportRing) Size 

func (trans *TransportRing) Size() uint32

func (*TransportRing) Write 

func (trans *TransportRing) Write(pkg []byte, length int) (int, error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.