v.io: v.io/x/ref/cmd/vrpc/internal Index | Files

package internal

import "v.io/x/ref/cmd/vrpc/internal"

nolint:golint

Index

Package Files

internal.vdl.go

Variables

var TypeTesterDesc rpc.InterfaceDesc = descTypeTester

TypeTesterDesc describes the TypeTester interface.

type Array2Int Uses

type Array2Int [2]int32

func (Array2Int) VDLIsZero Uses

func (x Array2Int) VDLIsZero() bool

func (*Array2Int) VDLRead Uses

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

func (Array2Int) VDLReflect Uses

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

func (Array2Int) VDLWrite Uses

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

type Struct Uses

type Struct struct {
    X   int32
    Y   int32
}

func (Struct) VDLIsZero Uses

func (x Struct) VDLIsZero() bool

func (*Struct) VDLRead Uses

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

func (Struct) VDLReflect Uses

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

func (Struct) VDLWrite Uses

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

type TypeTesterClientMethods Uses

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 Uses

type TypeTesterClientStub interface {
    TypeTesterClientMethods
}

TypeTesterClientStub embeds TypeTesterClientMethods and is a placeholder for additional management operations.

func TypeTesterClient Uses

func TypeTesterClient(name string) TypeTesterClientStub

TypeTesterClient returns a client stub for TypeTester.

type TypeTesterServerMethods Uses

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 Uses

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

TypeTesterServerStub adds universal methods to TypeTesterServerStubMethods.

func TypeTesterServer Uses

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 Uses

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 Uses

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 Uses

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 Uses

type TypeTesterZStreamServerCall interface {
    rpc.ServerCall
    TypeTesterZStreamServerStream
}

TypeTesterZStreamServerCall represents the context passed to TypeTester.ZStream.

type TypeTesterZStreamServerCallStub Uses

type TypeTesterZStreamServerCallStub struct {
    rpc.StreamServerCall
}

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

func (*TypeTesterZStreamServerCallStub) Init Uses

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

Init initializes TypeTesterZStreamServerCallStub from rpc.StreamServerCall.

func (*TypeTesterZStreamServerCallStub) SendStream Uses

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

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

type TypeTesterZStreamServerStream Uses

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.

Package internal imports 6 packages (graph). Updated 2020-10-24. Refresh now. Tools for package owners.