Documentation
¶
Index ¶
- Variables
- func NewErrComplex(ctx *context.T, first ComplexErrorParam, second string, third int32) error
- func NewErrNoFortunes(ctx *context.T) error
- type ComplexErrorParam
- type FortuneClientMethods
- type FortuneClientStub
- type FortuneMultipleStreamingGetClientCall
- type FortuneMultipleStreamingGetClientStream
- type FortuneMultipleStreamingGetServerCall
- type FortuneMultipleStreamingGetServerCallStub
- type FortuneMultipleStreamingGetServerStream
- type FortuneServerMethods
- type FortuneServerStub
- type FortuneServerStubMethods
- type FortuneStreamingGetClientCall
- type FortuneStreamingGetClientStream
- type FortuneStreamingGetServerCall
- type FortuneStreamingGetServerCallStub
- type FortuneStreamingGetServerStream
Constants ¶
This section is empty.
Variables ¶
var ( ErrNoFortunes = verror.Register("v.io/x/jni/test/fortune.NoFortunes", verror.NoRetry, "{1:}{2:} no fortunes added") ErrComplex = verror.Register("v.io/x/jni/test/fortune.Complex", verror.NoRetry, "{1:}{2:} this is a complex error with params {3} {4} {5}") )
var FortuneDesc rpc.InterfaceDesc = descFortune
FortuneDesc describes the Fortune interface.
Functions ¶
func NewErrComplex ¶
NewErrComplex returns an error with the ErrComplex ID.
func NewErrNoFortunes ¶
NewErrNoFortunes returns an error with the ErrNoFortunes ID.
Types ¶
type ComplexErrorParam ¶
func (ComplexErrorParam) VDLIsZero ¶
func (x ComplexErrorParam) VDLIsZero() bool
func (ComplexErrorParam) VDLReflect ¶
func (ComplexErrorParam) VDLReflect(struct { Name string `vdl:"v.io/x/jni/test/fortune.ComplexErrorParam"` })
type FortuneClientMethods ¶
type FortuneClientMethods interface { // Add stores a fortune in the set used by Get. Add(_ *context.T, Fortune string, _ ...rpc.CallOpt) error // Get returns the last-added fortune. Get(*context.T, ...rpc.CallOpt) (Fortune string, _ error) // ParameterizedGet returns the last-added fortune as a map (which is a parameterized // type in Java). ParameterizedGet(*context.T, ...rpc.CallOpt) (map[string]string, error) // StreamingGet returns a stream that can be used to obtain fortunes, and returns the // total number of items sent. StreamingGet(*context.T, ...rpc.CallOpt) (FortuneStreamingGetClientCall, error) // MultipleGet returns the same fortune twice. MultipleGet(*context.T, ...rpc.CallOpt) (Fortune string, Another string, _ error) // MultipleStreamingGet returns a stream that can be used to obtain fortunes, and returns // the total number of items sent, twice. MultipleStreamingGet(*context.T, ...rpc.CallOpt) (FortuneMultipleStreamingGetClientCall, error) // GetComplexError returns (always!) ErrComplex. GetComplexError(*context.T, ...rpc.CallOpt) error // NoTags is a method without tags. NoTags(*context.T, ...rpc.CallOpt) error // TestServerCall is a method used for testing that the server receives a // correct ServerCall. TestServerCall(*context.T, ...rpc.CallOpt) error // GetServerThread returns a name of the server thread that executes this method. GetServerThread(*context.T, ...rpc.CallOpt) (string, error) }
FortuneClientMethods is the client interface containing Fortune methods.
Fortune allows clients to Get and Add fortune strings.
type FortuneClientStub ¶
type FortuneClientStub interface { FortuneClientMethods rpc.UniversalServiceMethods }
FortuneClientStub adds universal methods to FortuneClientMethods.
func FortuneClient ¶
func FortuneClient(name string) FortuneClientStub
FortuneClient returns a client stub for Fortune.
type FortuneMultipleStreamingGetClientCall ¶
type FortuneMultipleStreamingGetClientCall interface { FortuneMultipleStreamingGetClientStream // Finish performs the equivalent of SendStream().Close, then blocks until // the server is done, and returns the positional return values for the 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() (total int32, another int32, _ error) }
FortuneMultipleStreamingGetClientCall represents the call returned from Fortune.MultipleStreamingGet.
type FortuneMultipleStreamingGetClientStream ¶
type FortuneMultipleStreamingGetClientStream interface { // RecvStream returns the receiver side of the Fortune.MultipleStreamingGet 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() string // Err returns any error encountered by Advance. Never blocks. Err() error } // SendStream returns the send side of the Fortune.MultipleStreamingGet client stream. SendStream() interface { // Send places the item onto the output stream. Returns errors // encountered while sending, or if Send is called after Close or // the stream has been canceled. Blocks if there is no buffer // space; will unblock when buffer space is available or after // the stream has been canceled. Send(item bool) error // Close indicates to the server that no more items will be sent; // server Recv calls will receive io.EOF after all sent items. // This is an optional call - e.g. a client might call Close if it // needs to continue receiving items from the server after it's // done sending. Returns errors encountered while closing, or if // Close is called after the stream has been canceled. Like Send, // blocks if there is no buffer space available. Close() error } }
FortuneMultipleStreamingGetClientStream is the client stream for Fortune.MultipleStreamingGet.
type FortuneMultipleStreamingGetServerCall ¶
type FortuneMultipleStreamingGetServerCall interface { rpc.ServerCall FortuneMultipleStreamingGetServerStream }
FortuneMultipleStreamingGetServerCall represents the context passed to Fortune.MultipleStreamingGet.
type FortuneMultipleStreamingGetServerCallStub ¶
type FortuneMultipleStreamingGetServerCallStub struct { rpc.StreamServerCall // contains filtered or unexported fields }
FortuneMultipleStreamingGetServerCallStub is a wrapper that converts rpc.StreamServerCall into a typesafe stub that implements FortuneMultipleStreamingGetServerCall.
func (*FortuneMultipleStreamingGetServerCallStub) Init ¶
func (s *FortuneMultipleStreamingGetServerCallStub) Init(call rpc.StreamServerCall)
Init initializes FortuneMultipleStreamingGetServerCallStub from rpc.StreamServerCall.
func (*FortuneMultipleStreamingGetServerCallStub) RecvStream ¶
func (s *FortuneMultipleStreamingGetServerCallStub) RecvStream() interface { Advance() bool Value() bool Err() error }
RecvStream returns the receiver side of the Fortune.MultipleStreamingGet server stream.
func (*FortuneMultipleStreamingGetServerCallStub) SendStream ¶
func (s *FortuneMultipleStreamingGetServerCallStub) SendStream() interface { Send(item string) error }
SendStream returns the send side of the Fortune.MultipleStreamingGet server stream.
type FortuneMultipleStreamingGetServerStream ¶
type FortuneMultipleStreamingGetServerStream interface { // RecvStream returns the receiver side of the Fortune.MultipleStreamingGet server 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 } // SendStream returns the send side of the Fortune.MultipleStreamingGet 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 string) error } }
FortuneMultipleStreamingGetServerStream is the server stream for Fortune.MultipleStreamingGet.
type FortuneServerMethods ¶
type FortuneServerMethods interface { // Add stores a fortune in the set used by Get. Add(_ *context.T, _ rpc.ServerCall, Fortune string) error // Get returns the last-added fortune. Get(*context.T, rpc.ServerCall) (Fortune string, _ error) // ParameterizedGet returns the last-added fortune as a map (which is a parameterized // type in Java). ParameterizedGet(*context.T, rpc.ServerCall) (map[string]string, error) // StreamingGet returns a stream that can be used to obtain fortunes, and returns the // total number of items sent. StreamingGet(*context.T, FortuneStreamingGetServerCall) (total int32, _ error) // MultipleGet returns the same fortune twice. MultipleGet(*context.T, rpc.ServerCall) (Fortune string, Another string, _ error) // MultipleStreamingGet returns a stream that can be used to obtain fortunes, and returns // the total number of items sent, twice. MultipleStreamingGet(*context.T, FortuneMultipleStreamingGetServerCall) (total int32, another int32, _ error) // GetComplexError returns (always!) ErrComplex. GetComplexError(*context.T, rpc.ServerCall) error // NoTags is a method without tags. NoTags(*context.T, rpc.ServerCall) error // TestServerCall is a method used for testing that the server receives a // correct ServerCall. TestServerCall(*context.T, rpc.ServerCall) error // GetServerThread returns a name of the server thread that executes this method. GetServerThread(*context.T, rpc.ServerCall) (string, error) }
FortuneServerMethods is the interface a server writer implements for Fortune.
Fortune allows clients to Get and Add fortune strings.
type FortuneServerStub ¶
type FortuneServerStub interface { FortuneServerStubMethods // Describe the Fortune interfaces. Describe__() []rpc.InterfaceDesc }
FortuneServerStub adds universal methods to FortuneServerStubMethods.
func FortuneServer ¶
func FortuneServer(impl FortuneServerMethods) FortuneServerStub
FortuneServer returns a server stub for Fortune. It converts an implementation of FortuneServerMethods into an object that may be used by rpc.Server.
type FortuneServerStubMethods ¶
type FortuneServerStubMethods interface { // Add stores a fortune in the set used by Get. Add(_ *context.T, _ rpc.ServerCall, Fortune string) error // Get returns the last-added fortune. Get(*context.T, rpc.ServerCall) (Fortune string, _ error) // ParameterizedGet returns the last-added fortune as a map (which is a parameterized // type in Java). ParameterizedGet(*context.T, rpc.ServerCall) (map[string]string, error) // StreamingGet returns a stream that can be used to obtain fortunes, and returns the // total number of items sent. StreamingGet(*context.T, *FortuneStreamingGetServerCallStub) (total int32, _ error) // MultipleGet returns the same fortune twice. MultipleGet(*context.T, rpc.ServerCall) (Fortune string, Another string, _ error) // MultipleStreamingGet returns a stream that can be used to obtain fortunes, and returns // the total number of items sent, twice. MultipleStreamingGet(*context.T, *FortuneMultipleStreamingGetServerCallStub) (total int32, another int32, _ error) // GetComplexError returns (always!) ErrComplex. GetComplexError(*context.T, rpc.ServerCall) error // NoTags is a method without tags. NoTags(*context.T, rpc.ServerCall) error // TestServerCall is a method used for testing that the server receives a // correct ServerCall. TestServerCall(*context.T, rpc.ServerCall) error // GetServerThread returns a name of the server thread that executes this method. GetServerThread(*context.T, rpc.ServerCall) (string, error) }
FortuneServerStubMethods is the server interface containing Fortune methods, as expected by rpc.Server. The only difference between this interface and FortuneServerMethods is the streaming methods.
type FortuneStreamingGetClientCall ¶
type FortuneStreamingGetClientCall interface { FortuneStreamingGetClientStream // Finish performs the equivalent of SendStream().Close, then blocks until // the server is done, and returns the positional return values for the 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() (total int32, _ error) }
FortuneStreamingGetClientCall represents the call returned from Fortune.StreamingGet.
type FortuneStreamingGetClientStream ¶
type FortuneStreamingGetClientStream interface { // RecvStream returns the receiver side of the Fortune.StreamingGet 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() string // Err returns any error encountered by Advance. Never blocks. Err() error } // SendStream returns the send side of the Fortune.StreamingGet client stream. SendStream() interface { // Send places the item onto the output stream. Returns errors // encountered while sending, or if Send is called after Close or // the stream has been canceled. Blocks if there is no buffer // space; will unblock when buffer space is available or after // the stream has been canceled. Send(item bool) error // Close indicates to the server that no more items will be sent; // server Recv calls will receive io.EOF after all sent items. // This is an optional call - e.g. a client might call Close if it // needs to continue receiving items from the server after it's // done sending. Returns errors encountered while closing, or if // Close is called after the stream has been canceled. Like Send, // blocks if there is no buffer space available. Close() error } }
FortuneStreamingGetClientStream is the client stream for Fortune.StreamingGet.
type FortuneStreamingGetServerCall ¶
type FortuneStreamingGetServerCall interface { rpc.ServerCall FortuneStreamingGetServerStream }
FortuneStreamingGetServerCall represents the context passed to Fortune.StreamingGet.
type FortuneStreamingGetServerCallStub ¶
type FortuneStreamingGetServerCallStub struct { rpc.StreamServerCall // contains filtered or unexported fields }
FortuneStreamingGetServerCallStub is a wrapper that converts rpc.StreamServerCall into a typesafe stub that implements FortuneStreamingGetServerCall.
func (*FortuneStreamingGetServerCallStub) Init ¶
func (s *FortuneStreamingGetServerCallStub) Init(call rpc.StreamServerCall)
Init initializes FortuneStreamingGetServerCallStub from rpc.StreamServerCall.
func (*FortuneStreamingGetServerCallStub) RecvStream ¶
func (s *FortuneStreamingGetServerCallStub) RecvStream() interface { Advance() bool Value() bool Err() error }
RecvStream returns the receiver side of the Fortune.StreamingGet server stream.
func (*FortuneStreamingGetServerCallStub) SendStream ¶
func (s *FortuneStreamingGetServerCallStub) SendStream() interface { Send(item string) error }
SendStream returns the send side of the Fortune.StreamingGet server stream.
type FortuneStreamingGetServerStream ¶
type FortuneStreamingGetServerStream interface { // RecvStream returns the receiver side of the Fortune.StreamingGet server 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 } // SendStream returns the send side of the Fortune.StreamingGet 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 string) error } }
FortuneStreamingGetServerStream is the server stream for Fortune.StreamingGet.