Documentation
¶
Index ¶
- Constants
- func DecodeRequestBody(w http.ResponseWriter, r *http.Request, v interface{}) error
- func StreamData[P Pointer[T], T any](c *RESTClient, ctx context.Context, method string, path string, ...) error
- func WriteResponse(status int, w http.ResponseWriter, r *http.Request, v interface{}) error
- type ChunkedStreamWriter
- type Pointer
- type RESTClient
- func (c *RESTClient) AppendUserAgent(userAgent string) *RESTClient
- func (c *RESTClient) ClearHeaders() *RESTClient
- func (c *RESTClient) Close()
- func (c *RESTClient) Delete(ctx context.Context, path string, request interface{}, response interface{}, ...) (int, error)
- func (c *RESTClient) DeleteHeader(key string) *RESTClient
- func (c *RESTClient) Get(ctx context.Context, path string, response interface{}) (int, error)
- func (c *RESTClient) Post(ctx context.Context, path string, request interface{}, response interface{}, ...) (int, error)
- func (c *RESTClient) Put(ctx context.Context, path string, request interface{}, response interface{}, ...) (int, error)
- func (c *RESTClient) SendData(ctx context.Context, method string, path string, request interface{}, ...) (int, error)
- func (c *RESTClient) SetAuthToken(token string) *RESTClient
- func (c *RESTClient) SetBaseUrl(baseURL string) (*RESTClient, error)
- func (c *RESTClient) SetContentType(contentType string) *RESTClient
- func (c *RESTClient) SetHeader(key, value string) *RESTClient
- func (c *RESTClient) SetTimeout(timeout time.Duration) *RESTClient
- func (c *RESTClient) SetTokenFormat(format string) *RESTClient
- func (c *RESTClient) SetTokenKey(key string) *RESTClient
- func (c *RESTClient) SetUserAgent(userAgent string) *RESTClient
- type SSEStreamWriter
- type StreamResponseFunc
- type StreamType
- type StreamWriter
Constants ¶
View Source
const ( ContentTypeJSON = "application/json" ContentTypeMsgPack = "application/msgpack" )
Variables ¶
This section is empty.
Functions ¶
func DecodeRequestBody ¶
func DecodeRequestBody(w http.ResponseWriter, r *http.Request, v interface{}) error
DecodeRequestBody decodes JSON or Msgpack data from the request body into a struct
func StreamData ¶
func StreamData[P Pointer[T], T any]( c *RESTClient, ctx context.Context, method string, path string, request interface{}, fn func(P) (bool, error), streamType StreamType, ) error
Thin generic wrapper - only this small function is duplicated per type
func WriteResponse ¶
WriteResponse encodes and writes a JSON or Msgpack response
Types ¶
type ChunkedStreamWriter ¶
type ChunkedStreamWriter struct {
// contains filtered or unexported fields
}
ChunkedStreamWriter writes chunks using Transfer-Encoding: chunked
func NewChunkedStreamWriter ¶
func NewChunkedStreamWriter(w http.ResponseWriter, r *http.Request) *ChunkedStreamWriter
NewChunkedStreamWriter creates a new chunked stream writer
func (*ChunkedStreamWriter) Close ¶
func (csw *ChunkedStreamWriter) Close() error
Close closes the stream writer
func (*ChunkedStreamWriter) WriteChunk ¶
func (csw *ChunkedStreamWriter) WriteChunk(chunk interface{}) error
WriteChunk writes a single chunk
func (*ChunkedStreamWriter) WriteEnd ¶
func (csw *ChunkedStreamWriter) WriteEnd() error
WriteEnd signals the end of the stream
type RESTClient ¶
func NewClient ¶
func NewClient(baseURL string, token string, insecureSkipVerify bool) (*RESTClient, error)
func (*RESTClient) AppendUserAgent ¶
func (c *RESTClient) AppendUserAgent(userAgent string) *RESTClient
func (*RESTClient) ClearHeaders ¶
func (c *RESTClient) ClearHeaders() *RESTClient
func (*RESTClient) Close ¶
func (c *RESTClient) Close()
func (*RESTClient) DeleteHeader ¶
func (c *RESTClient) DeleteHeader(key string) *RESTClient
func (*RESTClient) SetAuthToken ¶
func (c *RESTClient) SetAuthToken(token string) *RESTClient
func (*RESTClient) SetBaseUrl ¶
func (c *RESTClient) SetBaseUrl(baseURL string) (*RESTClient, error)
func (*RESTClient) SetContentType ¶
func (c *RESTClient) SetContentType(contentType string) *RESTClient
func (*RESTClient) SetHeader ¶
func (c *RESTClient) SetHeader(key, value string) *RESTClient
func (*RESTClient) SetTimeout ¶
func (c *RESTClient) SetTimeout(timeout time.Duration) *RESTClient
func (*RESTClient) SetTokenFormat ¶
func (c *RESTClient) SetTokenFormat(format string) *RESTClient
func (*RESTClient) SetTokenKey ¶
func (c *RESTClient) SetTokenKey(key string) *RESTClient
func (*RESTClient) SetUserAgent ¶
func (c *RESTClient) SetUserAgent(userAgent string) *RESTClient
type SSEStreamWriter ¶
type SSEStreamWriter struct {
// contains filtered or unexported fields
}
SSEStreamWriter writes chunks using Server-Sent Events
func NewSSEStreamWriter ¶
func NewSSEStreamWriter(w http.ResponseWriter, r *http.Request) *SSEStreamWriter
NewSSEStreamWriter creates a new SSE stream writer
func (*SSEStreamWriter) Close ¶
func (ssw *SSEStreamWriter) Close() error
Close closes the SSE stream writer
func (*SSEStreamWriter) WriteChunk ¶
func (ssw *SSEStreamWriter) WriteChunk(chunk interface{}) error
WriteChunk writes a single chunk as SSE
func (*SSEStreamWriter) WriteEnd ¶
func (ssw *SSEStreamWriter) WriteEnd() error
WriteEnd signals the end of the SSE stream
type StreamResponseFunc ¶
type StreamType ¶
type StreamType int
Add these types to existing server.go
const ( StreamChunked StreamType = iota StreamSSE )
type StreamWriter ¶
StreamWriter interface for different streaming types
Source Files
Click to show internal directories.
Click to hide internal directories.