internal

Documentation

Index

• Variables
• type Array2Int
  • func (x Array2Int) VDLIsZero() bool
  • func (x *Array2Int) VDLRead(dec vdl.Decoder) error
  • func (Array2Int) VDLReflect(struct{ ... })
  • func (x Array2Int) VDLWrite(enc vdl.Encoder) error
• type Struct
  • func (x Struct) VDLIsZero() bool
  • func (x *Struct) VDLRead(dec vdl.Decoder) error
  • func (Struct) VDLReflect(struct{ ... })
  • func (x Struct) VDLWrite(enc vdl.Encoder) error
• type TypeTesterClientMethods
• type TypeTesterClientStub
  • func TypeTesterClient(name string) TypeTesterClientStub
• type TypeTesterServerMethods
• type TypeTesterServerStub
  • func TypeTesterServer(impl TypeTesterServerMethods) TypeTesterServerStub
• type TypeTesterServerStubMethods
• type TypeTesterZStreamClientCall
• type TypeTesterZStreamClientStream
• type TypeTesterZStreamServerCall
• type TypeTesterZStreamServerCallStub
  • func (s *TypeTesterZStreamServerCallStub) Init(call rpc.StreamServerCall)
  • func (s *TypeTesterZStreamServerCallStub) SendStream() interface{ ... }
• type TypeTesterZStreamServerStream

Variables

var TypeTesterDesc rpc.InterfaceDesc = descTypeTester

TypeTesterDesc describes the TypeTester interface.

Types

type Array2Int

type Array2Int [2]int32

func (Array2Int) VDLIsZero

func (x Array2Int) VDLIsZero() bool

func (*Array2Int) VDLRead

func (x *Array2Int) VDLRead(dec vdl.Decoder) error

func (Array2Int) VDLReflect

func (Array2Int) VDLReflect(struct {
	Name string `vdl:"v.io/x/ref/cmd/vrpc/internal.Array2Int"`
})

func (Array2Int) VDLWrite

func (x Array2Int) VDLWrite(enc vdl.Encoder) error

type Struct

type Struct struct {
	X int32
	Y int32
}

func (Struct) VDLIsZero

func (x Struct) VDLIsZero() bool

func (*Struct) VDLRead

func (x *Struct) VDLRead(dec vdl.Decoder) error

func (Struct) VDLReflect

func (Struct) VDLReflect(struct {
	Name string `vdl:"v.io/x/ref/cmd/vrpc/internal.Struct"`
})

func (Struct) VDLWrite

func (x Struct) VDLWrite(enc vdl.Encoder) error

type TypeTesterClientMethods

type TypeTesterClientMethods interface {
	// Methods to test support for primitive types.
	EchoBool(_ *context.T, I1 bool, _ ...rpc.CallOpt) (O1 bool, _ error)
	EchoFloat32(_ *context.T, I1 float32, _ ...rpc.CallOpt) (O1 float32, _ error)
	EchoFloat64(_ *context.T, I1 float64, _ ...rpc.CallOpt) (O1 float64, _ error)
	EchoInt32(_ *context.T, I1 int32, _ ...rpc.CallOpt) (O1 int32, _ error)
	EchoInt64(_ *context.T, I1 int64, _ ...rpc.CallOpt) (O1 int64, _ error)
	EchoString(_ *context.T, I1 string, _ ...rpc.CallOpt) (O1 string, _ error)
	EchoByte(_ *context.T, I1 byte, _ ...rpc.CallOpt) (O1 byte, _ error)
	EchoUint32(_ *context.T, I1 uint32, _ ...rpc.CallOpt) (O1 uint32, _ error)
	EchoUint64(_ *context.T, I1 uint64, _ ...rpc.CallOpt) (O1 uint64, _ error)
	// Methods to test support for composite types.
	XEchoArray(_ *context.T, I1 Array2Int, _ ...rpc.CallOpt) (O1 Array2Int, _ error)
	XEchoMap(_ *context.T, I1 map[int32]string, _ ...rpc.CallOpt) (O1 map[int32]string, _ error)
	XEchoSet(_ *context.T, I1 map[int32]struct{}, _ ...rpc.CallOpt) (O1 map[int32]struct{}, _ error)
	XEchoSlice(_ *context.T, I1 []int32, _ ...rpc.CallOpt) (O1 []int32, _ error)
	XEchoStruct(_ *context.T, I1 Struct, _ ...rpc.CallOpt) (O1 Struct, _ error)
	// Methods to test support for different number of arguments.
	YMultiArg(_ *context.T, I1 int32, I2 int32, _ ...rpc.CallOpt) (O1 int32, O2 int32, _ error)
	YNoArgs(*context.T, ...rpc.CallOpt) error
	// Methods to test support for streaming.
	ZStream(_ *context.T, NumStreamItems int32, StreamItem bool, _ ...rpc.CallOpt) (TypeTesterZStreamClientCall, error)
}

TypeTesterClientMethods is the client interface containing TypeTester methods.

TypeTester methods are listed in alphabetical order, to make it easier to test Signature output, which sorts methods alphabetically.

type TypeTesterClientStub

type TypeTesterClientStub interface {
	TypeTesterClientMethods
	rpc.UniversalServiceMethods
}

TypeTesterClientStub adds universal methods to TypeTesterClientMethods.

func TypeTesterClient

func TypeTesterClient(name string) TypeTesterClientStub

TypeTesterClient returns a client stub for TypeTester.

type TypeTesterServerMethods

type TypeTesterServerMethods interface {
	// Methods to test support for primitive types.
	EchoBool(_ *context.T, _ rpc.ServerCall, I1 bool) (O1 bool, _ error)
	EchoFloat32(_ *context.T, _ rpc.ServerCall, I1 float32) (O1 float32, _ error)
	EchoFloat64(_ *context.T, _ rpc.ServerCall, I1 float64) (O1 float64, _ error)
	EchoInt32(_ *context.T, _ rpc.ServerCall, I1 int32) (O1 int32, _ error)
	EchoInt64(_ *context.T, _ rpc.ServerCall, I1 int64) (O1 int64, _ error)
	EchoString(_ *context.T, _ rpc.ServerCall, I1 string) (O1 string, _ error)
	EchoByte(_ *context.T, _ rpc.ServerCall, I1 byte) (O1 byte, _ error)
	EchoUint32(_ *context.T, _ rpc.ServerCall, I1 uint32) (O1 uint32, _ error)
	EchoUint64(_ *context.T, _ rpc.ServerCall, I1 uint64) (O1 uint64, _ error)
	// Methods to test support for composite types.
	XEchoArray(_ *context.T, _ rpc.ServerCall, I1 Array2Int) (O1 Array2Int, _ error)
	XEchoMap(_ *context.T, _ rpc.ServerCall, I1 map[int32]string) (O1 map[int32]string, _ error)
	XEchoSet(_ *context.T, _ rpc.ServerCall, I1 map[int32]struct{}) (O1 map[int32]struct{}, _ error)
	XEchoSlice(_ *context.T, _ rpc.ServerCall, I1 []int32) (O1 []int32, _ error)
	XEchoStruct(_ *context.T, _ rpc.ServerCall, I1 Struct) (O1 Struct, _ error)
	// Methods to test support for different number of arguments.
	YMultiArg(_ *context.T, _ rpc.ServerCall, I1 int32, I2 int32) (O1 int32, O2 int32, _ error)
	YNoArgs(*context.T, rpc.ServerCall) error
	// Methods to test support for streaming.
	ZStream(_ *context.T, _ TypeTesterZStreamServerCall, NumStreamItems int32, StreamItem bool) error
}

TypeTesterServerMethods is the interface a server writer implements for TypeTester.

TypeTester methods are listed in alphabetical order, to make it easier to test Signature output, which sorts methods alphabetically.

type TypeTesterServerStub

type TypeTesterServerStub interface {
	TypeTesterServerStubMethods
	// Describe the TypeTester interfaces.
	Describe__() []rpc.InterfaceDesc
}

TypeTesterServerStub adds universal methods to TypeTesterServerStubMethods.

func TypeTesterServer

func TypeTesterServer(impl TypeTesterServerMethods) TypeTesterServerStub

TypeTesterServer returns a server stub for TypeTester. It converts an implementation of TypeTesterServerMethods into an object that may be used by rpc.Server.

type TypeTesterServerStubMethods

type TypeTesterServerStubMethods interface {
	// Methods to test support for primitive types.
	EchoBool(_ *context.T, _ rpc.ServerCall, I1 bool) (O1 bool, _ error)
	EchoFloat32(_ *context.T, _ rpc.ServerCall, I1 float32) (O1 float32, _ error)
	EchoFloat64(_ *context.T, _ rpc.ServerCall, I1 float64) (O1 float64, _ error)
	EchoInt32(_ *context.T, _ rpc.ServerCall, I1 int32) (O1 int32, _ error)
	EchoInt64(_ *context.T, _ rpc.ServerCall, I1 int64) (O1 int64, _ error)
	EchoString(_ *context.T, _ rpc.ServerCall, I1 string) (O1 string, _ error)
	EchoByte(_ *context.T, _ rpc.ServerCall, I1 byte) (O1 byte, _ error)
	EchoUint32(_ *context.T, _ rpc.ServerCall, I1 uint32) (O1 uint32, _ error)
	EchoUint64(_ *context.T, _ rpc.ServerCall, I1 uint64) (O1 uint64, _ error)
	// Methods to test support for composite types.
	XEchoArray(_ *context.T, _ rpc.ServerCall, I1 Array2Int) (O1 Array2Int, _ error)
	XEchoMap(_ *context.T, _ rpc.ServerCall, I1 map[int32]string) (O1 map[int32]string, _ error)
	XEchoSet(_ *context.T, _ rpc.ServerCall, I1 map[int32]struct{}) (O1 map[int32]struct{}, _ error)
	XEchoSlice(_ *context.T, _ rpc.ServerCall, I1 []int32) (O1 []int32, _ error)
	XEchoStruct(_ *context.T, _ rpc.ServerCall, I1 Struct) (O1 Struct, _ error)
	// Methods to test support for different number of arguments.
	YMultiArg(_ *context.T, _ rpc.ServerCall, I1 int32, I2 int32) (O1 int32, O2 int32, _ error)
	YNoArgs(*context.T, rpc.ServerCall) error
	// Methods to test support for streaming.
	ZStream(_ *context.T, _ *TypeTesterZStreamServerCallStub, NumStreamItems int32, StreamItem bool) error
}

TypeTesterServerStubMethods is the server interface containing TypeTester methods, as expected by rpc.Server. The only difference between this interface and TypeTesterServerMethods is the streaming methods.

type TypeTesterZStreamClientCall

type TypeTesterZStreamClientCall interface {
	TypeTesterZStreamClientStream
	// Finish blocks until the server is done, and returns the positional return
	// values for call.
	//
	// Finish returns immediately if the call has been canceled; depending on the
	// timing the output could either be an error signaling cancelation, or the
	// valid positional return values from the server.
	//
	// Calling Finish is mandatory for releasing stream resources, unless the call
	// has been canceled or any of the other methods return an error.  Finish should
	// be called at most once.
	Finish() error
}

TypeTesterZStreamClientCall represents the call returned from TypeTester.ZStream.

type TypeTesterZStreamClientStream

type TypeTesterZStreamClientStream interface {
	// RecvStream returns the receiver side of the TypeTester.ZStream client stream.
	RecvStream() interface {
		// Advance stages an item so that it may be retrieved via Value.  Returns
		// true iff there is an item to retrieve.  Advance must be called before
		// Value is called.  May block if an item is not available.
		Advance() bool
		// Value returns the item that was staged by Advance.  May panic if Advance
		// returned false or was not called.  Never blocks.
		Value() bool
		// Err returns any error encountered by Advance.  Never blocks.
		Err() error
	}
}

TypeTesterZStreamClientStream is the client stream for TypeTester.ZStream.

type TypeTesterZStreamServerCall

type TypeTesterZStreamServerCall interface {
	rpc.ServerCall
	TypeTesterZStreamServerStream
}

TypeTesterZStreamServerCall represents the context passed to TypeTester.ZStream.

type TypeTesterZStreamServerCallStub

type TypeTesterZStreamServerCallStub struct {
	rpc.StreamServerCall
}

TypeTesterZStreamServerCallStub is a wrapper that converts rpc.StreamServerCall into a typesafe stub that implements TypeTesterZStreamServerCall.

func (*TypeTesterZStreamServerCallStub) Init

func (s *TypeTesterZStreamServerCallStub) Init(call rpc.StreamServerCall)

Init initializes TypeTesterZStreamServerCallStub from rpc.StreamServerCall.

func (*TypeTesterZStreamServerCallStub) SendStream

func (s *TypeTesterZStreamServerCallStub) SendStream() interface {
	Send(item bool) error
}

SendStream returns the send side of the TypeTester.ZStream server stream.

type TypeTesterZStreamServerStream

type TypeTesterZStreamServerStream interface {
	// SendStream returns the send side of the TypeTester.ZStream server stream.
	SendStream() interface {
		// Send places the item onto the output stream.  Returns errors encountered
		// while sending.  Blocks if there is no buffer space; will unblock when
		// buffer space is available.
		Send(item bool) error
	}
}

TypeTesterZStreamServerStream is the server stream for TypeTester.ZStream.