fakexds

Documentation

Index

• type Stream
  • func NewStream(ctx context.Context) *Stream
  • func (s *Stream) Await() (*discovery_v3.DiscoveryResponse, error)
  • func (s *Stream) Context() context.Context
  • func (s *Stream) Recv() (*discovery_v3.DiscoveryRequest, error)
  • func (s *Stream) RecvMsg(interface{}) error
  • func (s *Stream) Request(req *discovery_v3.DiscoveryRequest) error
  • func (s *Stream) RequestAndWait(req *discovery_v3.DiscoveryRequest) (*discovery_v3.DiscoveryResponse, error)
  • func (s *Stream) Send(res *discovery_v3.DiscoveryResponse) error
  • func (s *Stream) SendHeader(metadata.MD) error
  • func (s *Stream) SendMsg(interface{}) error
  • func (s *Stream) SetHeader(metadata.MD) error
  • func (s *Stream) SetTrailer(metadata.MD)

Types

type Stream

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

func NewStream

func NewStream(ctx context.Context) *Stream

func (*Stream) Await

func (s *Stream) Await() (*discovery_v3.DiscoveryResponse, error)

Await is called by the client to await a push from the server.

func (*Stream) Context

func (s *Stream) Context() context.Context

func (*Stream) Recv

func (s *Stream) Recv() (*discovery_v3.DiscoveryRequest, error)

Recv is called by the server to receive a request from the client.

func (*Stream) RecvMsg

func (s *Stream) RecvMsg(interface{}) error

func (*Stream) Request

func (s *Stream) Request(req *discovery_v3.DiscoveryRequest) error

Request is called by the client to send a message to the server.

func (*Stream) RequestAndWait

func (s *Stream) RequestAndWait(req *discovery_v3.DiscoveryRequest) (*discovery_v3.DiscoveryResponse, error)

RequestAndWait is called by the client to send a request to the server and wait for a response.

func (*Stream) Send

func (s *Stream) Send(res *discovery_v3.DiscoveryResponse) error

Send is called by the server to send a response to the client.

func (*Stream) SendHeader

func (s *Stream) SendHeader(metadata.MD) error

func (*Stream) SendMsg

func (s *Stream) SendMsg(interface{}) error

func (*Stream) SetHeader

func (s *Stream) SetHeader(metadata.MD) error

func (*Stream) SetTrailer

func (s *Stream) SetTrailer(metadata.MD)