dist

package

v0.0.0-...-b8e6cb6 Latest Latest Go to latest Published: Jan 9, 2020 License: MIT Imports: 9 Imported by: 12

Details

This section is empty.

This section is empty.

func Marshall(message Message) ([]byte, error)

type Body struct {
	RequestHeader RequestHeader
	RequestBody   RequestBody
	ReplyHeader   ReplyHeader
	ReplyBody     interface{}
}

type Header struct {
	Magic   string
	Version int
	Order   bool
	Type    int
	Size    int
}

type Invocation struct {
	ObjectId      int
	IpAddress     string
	PortNumber    int
	OperationName string
	Parameters    []interface{}
}

func NewInvocation(objectId int, ipAddress string, portNumber int, operationName string, parameters []interface{}) *Invocation

type Invoker interface {
	Register(objectId int, remoteObject interface{})
	Invoke(port int) (err error)
}

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

func (inv *InvokerImpl) Invoke(port int, initialConnections int) (err error)

func (inv *InvokerImpl) Register(objectId int, remoteObject interface{})

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

func NewLookupProxy(host string, port int) *LookupProxy

func (lp LookupProxy) Bind(sn string, cp common.ClientProxy) (err error)

func (lp LookupProxy) Close() error

func (lp LookupProxy) List() (services []common.NamingRecord, err error)

func (lp LookupProxy) Lookup(serviceName string) (cp common.ClientProxy, err error)

type Message struct {
	Header Header
	Body   Body
}

func Unmarshall(marshaledMessage []byte) (message Message, err error)

type ReplyHeader struct {
	ServiceContext string
	RequestId      int
	ReplyStatus    int
}

type RequestBody struct {
	Parameters []interface{}
}

type RequestHeader struct {
	Context          string
	RequestId        int
	ResponseExpected bool
	ObjectKey        int
	Operation        string
}

type Requestor interface {
	Invoke(inv Invocation) (t Termination, err error)
	Close() error
}

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

Implements requestor

func NewRequestorImpl(ipAddress string, portNumber int) *RequestorImpl

func (r *RequestorImpl) Close() error

func (r *RequestorImpl) Invoke(inv Invocation) (t Termination, err error)

type Termination struct {
	Result interface{}
}