Documentation ¶
Index ¶
- Variables
- func Check(visitor Visitor, sig Signal)
- func Flush(ctx context.Context, vistor Visitor, writeC chan<- []byte) error
- func Logger(conn *websocket.Conn) zerolog.Logger
- func Reader(ctx context.Context, conn *websocket.Conn, log zerolog.Logger) <-chan []byte
- func Upgrade(w http.ResponseWriter, r *http.Request) (*websocket.Conn, error)
- func Writer(ctx context.Context, conn *websocket.Conn, log zerolog.Logger, sig Signal) <-chan chan []byte
- type BufferVisitor
- type OnceVisitor
- type Signal
- type Visitor
- type Vistors
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrVisitorEmpty = errors.New("visitor empty")
Functions ¶
Types ¶
type BufferVisitor ¶
type BufferVisitor struct {
// contains filtered or unexported fields
}
func NewBufferVisitor ¶
func NewBufferVisitor(count int) *BufferVisitor
func (*BufferVisitor) HasMore ¶
func (v *BufferVisitor) HasMore() bool
func (*BufferVisitor) Push ¶
func (v *BufferVisitor) Push(data []byte) bool
type OnceVisitor ¶
type OnceVisitor struct { Done bool // contains filtered or unexported fields }
func NewOnceVisitor ¶
func NewOnceVisitor() *OnceVisitor
func (*OnceVisitor) HasMore ¶
func (v *OnceVisitor) HasMore() bool
func (*OnceVisitor) Set ¶
func (v *OnceVisitor) Set(data []byte)
Click to show internal directories.
Click to hide internal directories.