Documentation
¶
Index ¶
- Constants
- Variables
- func IsSSEAcceptable(r *http.Request) bool
- func SetupSSEHeaders(w http.ResponseWriter)
- type Event
- func (e *Event) AppendData(data []byte)
- func (e *Event) AppendDataString(data string)
- func (e *Event) Clone() *Event
- func (e *Event) IsSetData() bool
- func (e *Event) IsSetID() bool
- func (e *Event) IsSetRetry() bool
- func (e *Event) IsSetType() bool
- func (e *Event) Release()
- func (e *Event) SetData(data []byte)
- func (e *Event) SetDataString(data string)
- func (e *Event) SetEvent(eventType string)
- func (e *Event) SetID(id string)
- func (e *Event) SetRetry(retry time.Duration)
- func (e *Event) String() string
- type Writer
- func (w *Writer) Close()
- func (w *Writer) IsClosed() bool
- func (w *Writer) SetDone(f func(http.ResponseWriter) error)
- func (w *Writer) Stream(ctx context.Context, stream *schema.StreamReader[*schema.AgenticMessage], ...) error
- func (w *Writer) WriteComment(comment string) error
- func (w *Writer) WriteData(data []byte) error
- func (w *Writer) WriteDataString(data string) error
- func (w *Writer) WriteDone() error
- func (w *Writer) WriteEvent(event *Event) error
- func (w *Writer) WriteEventJSON(id, eventType string, data interface{}) error
- func (w *Writer) WriteEventSimple(id, eventType string, data []byte) error
- func (w *Writer) WriteEventString(id, eventType, data string) error
- func (w *Writer) WriteJSONData(data interface{}) error
- func (w *Writer) WriteKeepAlive() error
Constants ¶
View Source
const (
MIMEType = "text/event-stream"
)
Variables ¶
View Source
var ErrWriterClosed = errors.New("sse: writer is closed")
ErrWriterClosed 在 Writer 关闭后继续写入时返回。 旧版本对已关闭的写入静默返回 nil，调用方无法感知连接已结束。
Functions ¶
func IsSSEAcceptable ¶
func SetupSSEHeaders ¶
func SetupSSEHeaders(w http.ResponseWriter)
Types ¶
type Event ¶
type Event struct {
ID string
Type string
Data []byte
Retry time.Duration
// contains filtered or unexported fields
}
func (*Event) AppendData ¶
func (*Event) AppendDataString ¶
func (*Event) IsSetRetry ¶
func (*Event) SetDataString ¶
type Writer ¶
type Writer struct {
Done func(http.ResponseWriter) error
// contains filtered or unexported fields
}
func (*Writer) SetDone ¶ added in v0.0.12
func (w *Writer) SetDone(f func(http.ResponseWriter) error)
func (*Writer) Stream ¶
func (w *Writer) Stream(ctx context.Context, stream *schema.StreamReader[*schema.AgenticMessage], fn func(output *schema.AgenticMessage, index int) any) error
func (*Writer) WriteComment ¶
func (*Writer) WriteDataString ¶
func (*Writer) WriteEvent ¶
func (*Writer) WriteEventJSON ¶
func (*Writer) WriteEventSimple ¶
func (*Writer) WriteEventString ¶
func (*Writer) WriteJSONData ¶
func (*Writer) WriteKeepAlive ¶
Source Files
Click to show internal directories.
Click to hide internal directories.