example

package
v1.41.0 Latest Latest
Warning

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

Go to latest
Published: Oct 2, 2019 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// FireDoneTimeout is how long fireDone will wait for both sending and receiving.
	FireDoneTimeout = 3 * time.Second
)

Variables

This section is empty.

Functions

This section is empty.

Types

type FooYARPCServer added in v1.27.0

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

FooYARPCServer implements examplepb.FooYARPCServer.

func NewFooYARPCServer added in v1.27.0

func NewFooYARPCServer(expectedHeaders transport.Headers) *FooYARPCServer

NewFooYARPCServer returns a new FooYARPCServer.

func (*FooYARPCServer) EchoBoth added in v1.27.0

EchoBoth immediately echos a request back to the client.

func (*FooYARPCServer) EchoIn added in v1.27.0

EchoIn echos a series of requests back on a stream.

func (*FooYARPCServer) EchoOut added in v1.27.0

EchoOut reads from a stream and echos all requests in the response.

type KeyValueYARPCServer added in v1.10.0

type KeyValueYARPCServer struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

KeyValueYARPCServer implements examplepb.KeyValueYARPCServer.

func NewKeyValueYARPCServer added in v1.10.0

func NewKeyValueYARPCServer() *KeyValueYARPCServer

NewKeyValueYARPCServer returns a new KeyValueYARPCServer.

func (*KeyValueYARPCServer) GetValue added in v1.10.0

GetValue implements GetValue.

func (*KeyValueYARPCServer) SetNextError added in v1.10.0

func (k *KeyValueYARPCServer) SetNextError(err error)

SetNextError sets the error to return on the next call to KeyValueYARPCServer.

func (*KeyValueYARPCServer) SetValue added in v1.10.0

SetValue implements SetValue.

type SinkYARPCServer added in v1.10.0

type SinkYARPCServer struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

SinkYARPCServer implements examplepb.SinkYARPCServer.

func NewSinkYARPCServer added in v1.10.0

func NewSinkYARPCServer(withFireDone bool) *SinkYARPCServer

NewSinkYARPCServer returns a new SinkYARPCServer.

func (*SinkYARPCServer) Fire added in v1.10.0

func (s *SinkYARPCServer) Fire(ctx context.Context, request *examplepb.FireRequest) error

Fire implements Fire.

func (*SinkYARPCServer) Values added in v1.10.0

func (s *SinkYARPCServer) Values() []string

Values returns a copy of the values that have been fired.

func (*SinkYARPCServer) WaitFireDone added in v1.10.0

func (s *SinkYARPCServer) WaitFireDone() error

WaitFireDone blocks until a fire is done, if withFireDone is set.

If will timeout after FireDoneTimeout and return error.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL