stream

Documentation

Index

• type BInOpenPublisherStreamOutCall
• type BOutOpenConsumerStreamOutCall
• type BOutOpenStreamingConsumerStreamOutCall

Types

type BInOpenPublisherStreamOutCall

type BInOpenPublisherStreamOutCall interface {
	// Write writes an argument to the request stream. The written items may not
	// be sent till Flush or Done is called.
	Write(arg *cherami.PutMessage) error

	// Flush flushes all written arguments.
	Flush() error

	// Done closes the request stream and should be called after all arguments have been written.
	Done() error

	// Read returns the next result, if any is available. If there are no more
	// results left, it will return io.EOF.
	Read() (*cherami.InputHostCommand, error)

	// ResponseHeaders returns the response headers sent from the server. This will
	// block until server headers have been received.
	ResponseHeaders() (map[string]string, error)
}

BInOpenPublisherStreamOutCall is the object used to stream arguments/results and read response headers for outgoing calls.

type BOutOpenConsumerStreamOutCall

type BOutOpenConsumerStreamOutCall interface {
	// Write writes an argument to the request stream. The written items may not
	// be sent till Flush or Done is called.
	Write(arg *cherami.ControlFlow) error

	// Flush flushes all written arguments.
	Flush() error

	// Done closes the request stream and should be called after all arguments have been written.
	Done() error

	// Read returns the next result, if any is available. If there are no more
	// results left, it will return io.EOF.
	Read() (*cherami.OutputHostCommand, error)

	// ResponseHeaders returns the response headers sent from the server. This will
	// block until server headers have been received.
	ResponseHeaders() (map[string]string, error)
}

BOutOpenConsumerStreamOutCall is the object used to stream arguments/results and read response headers for outgoing calls.

type BOutOpenStreamingConsumerStreamOutCall

type BOutOpenStreamingConsumerStreamOutCall interface {
	// Write writes an argument to the request stream. The written items may not
	// be sent till Flush or Done is called.
	Write(arg *cherami.ControlFlow) error

	// Flush flushes all written arguments.
	Flush() error

	// Done closes the request stream and should be called after all arguments have been written.
	Done() error

	// Read returns the next result, if any is available. If there are no more
	// results left, it will return io.EOF.
	Read() (*cherami.OutputHostCommand, error)

	// ResponseHeaders returns the response headers sent from the server. This will
	// block until server headers have been received.
	ResponseHeaders() (map[string]string, error)
}

BOutOpenStreamingConsumerStreamOutCall is the object used to stream arguments/results and read response headers for outgoing calls.