stream

Documentation

Index

• type BInOpenPublisherStreamInCall
• type BOutOpenConsumerStreamInCall
• type BOutOpenStreamingConsumerStreamInCall
• type BStoreOpenAppendStreamInCall
• type BStoreOpenAppendStreamOutCall
• type BStoreOpenReadStreamInCall
• type BStoreOpenReadStreamOutCall

Types

type BInOpenPublisherStreamInCall

type BInOpenPublisherStreamInCall interface {
	// Read returns the next argument, if any is available. If there are no more arguments left,
	// it will return io.EOF.
	Read() (*cherami.PutMessage, error)

	// SetResponseHeaders sets the response headers. This must be called before any
	// streaming responses are sent.
	SetResponseHeaders(headers map[string]string) error

	// Write writes a result to the response stream. The written items may not
	// be sent till Flush or Done is called.
	Write(arg *cherami.InputHostCommand) error

	// Flush flushes headers (if they have not yet been sent) and any written results.
	Flush() error

	// Done closes the response stream and should be called after all results have been written.
	Done() error
}

BInOpenPublisherStreamInCall is the object used to stream arguments and write response headers for incoming calls.

type BOutOpenConsumerStreamInCall

type BOutOpenConsumerStreamInCall interface {
	// Read returns the next argument, if any is available. If there are no more arguments left,
	// it will return io.EOF.
	Read() (*cherami.ControlFlow, error)

	// SetResponseHeaders sets the response headers. This must be called before any
	// streaming responses are sent.
	SetResponseHeaders(headers map[string]string) error

	// Write writes a result to the response stream. The written items may not
	// be sent till Flush or Done is called.
	Write(arg *cherami.OutputHostCommand) error

	// Flush flushes headers (if they have not yet been sent) and any written results.
	Flush() error

	// Done closes the response stream and should be called after all results have been written.
	Done() error
}

BOutOpenConsumerStreamInCall is the object used to stream arguments and write response headers for incoming calls.

type BOutOpenStreamingConsumerStreamInCall

type BOutOpenStreamingConsumerStreamInCall interface {
	// Read returns the next argument, if any is available. If there are no more arguments left,
	// it will return io.EOF.
	Read() (*cherami.ControlFlow, error)

	// SetResponseHeaders sets the response headers. This must be called before any
	// streaming responses are sent.
	SetResponseHeaders(headers map[string]string) error

	// Write writes a result to the response stream. The written items may not
	// be sent till Flush or Done is called.
	Write(arg *cherami.OutputHostCommand) error

	// Flush flushes headers (if they have not yet been sent) and any written results.
	Flush() error

	// Done closes the response stream and should be called after all results have been written.
	Done() error
}

BOutOpenStreamingConsumerStreamInCall is the object used to stream arguments and write response headers for incoming calls.

type BStoreOpenAppendStreamInCall

type BStoreOpenAppendStreamInCall interface {
	// Read returns the next argument, if any is available. If there are no more arguments left,
	// it will return io.EOF.
	Read() (*store.AppendMessage, error)

	// SetResponseHeaders sets the response headers. This must be called before any
	// streaming responses are sent.
	SetResponseHeaders(headers map[string]string) error

	// Write writes a result to the response stream. The written items may not
	// be sent till Flush or Done is called.
	Write(arg *store.AppendMessageAck) error

	// Flush flushes headers (if they have not yet been sent) and any written results.
	Flush() error

	// Done closes the response stream and should be called after all results have been written.
	Done() error
}

BStoreOpenAppendStreamInCall is the object used to stream arguments and write response headers for incoming calls.

type BStoreOpenAppendStreamOutCall

type BStoreOpenAppendStreamOutCall interface {
	// Write writes an argument to the request stream. The written items may not
	// be sent till Flush or Done is called.
	Write(arg *store.AppendMessage) 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() (*store.AppendMessageAck, error)

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

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

type BStoreOpenReadStreamInCall

type BStoreOpenReadStreamInCall interface {
	// Read returns the next argument, if any is available. If there are no more arguments left,
	// it will return io.EOF.
	Read() (*cherami.ControlFlow, error)

	// SetResponseHeaders sets the response headers. This must be called before any
	// streaming responses are sent.
	SetResponseHeaders(headers map[string]string) error

	// Write writes a result to the response stream. The written items may not
	// be sent till Flush or Done is called.
	Write(arg *store.ReadMessageContent) error

	// Flush flushes headers (if they have not yet been sent) and any written results.
	Flush() error

	// Done closes the response stream and should be called after all results have been written.
	Done() error
}

BStoreOpenReadStreamInCall is the object used to stream arguments and write response headers for incoming calls.

type BStoreOpenReadStreamOutCall

type BStoreOpenReadStreamOutCall 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() (*store.ReadMessageContent, error)

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

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