protoutil

Documentation

Index

• func NewStreamingBytesWriter(streamingBytesServer StreamingBytesServer) io.Writer
• func RelayFromStreamingBytesClient(streamingBytesClient StreamingBytesClient, ...) error
• func WriteFromStreamingBytesClient(streamingBytesClient StreamingBytesClient, writer io.Writer) error
• func WriteToStreamingBytesServer(reader io.Reader, streamingBytesServer StreamingBytesServer) error
• type StreamingBytesClient
• type StreamingBytesClientHandler
  • func NewStreamingBytesClientHandler(handleFunc func(*google_protobuf.BytesValue) error) StreamingBytesClientHandler
• type StreamingBytesServer

Functions

func NewStreamingBytesWriter

func NewStreamingBytesWriter(streamingBytesServer StreamingBytesServer) io.Writer

func RelayFromStreamingBytesClient

func RelayFromStreamingBytesClient(streamingBytesClient StreamingBytesClient, streamingBytesServer StreamingBytesServer) error

func WriteFromStreamingBytesClient

func WriteFromStreamingBytesClient(streamingBytesClient StreamingBytesClient, writer io.Writer) error

func WriteToStreamingBytesServer

func WriteToStreamingBytesServer(reader io.Reader, streamingBytesServer StreamingBytesServer) error

Types

type StreamingBytesClient

type StreamingBytesClient interface {
	Recv() (*google_protobuf.BytesValue, error)
}

type StreamingBytesClientHandler

type StreamingBytesClientHandler interface {
	Handle(streamingBytesClient StreamingBytesClient) error
}

func NewStreamingBytesClientHandler

func NewStreamingBytesClientHandler(handleFunc func(*google_protobuf.BytesValue) error) StreamingBytesClientHandler

type StreamingBytesServer

type StreamingBytesServer interface {
	Send(bytesValue *google_protobuf.BytesValue) error
}