client

Documentation

Index

• Variables
• func Subscribe[T any](ctx context.Context, protocol, host, path string, ...)
• type Meta
• type OnMessageCallback

Variables

var HandshakeTimeout time.Duration = time.Second * 2

Functions

func Subscribe

func Subscribe[T any](ctx context.Context, protocol, host, path string, callback OnMessageCallback[T])

Types

type Meta

type Meta[T any] struct {
	Created int64  `json:"created"`
	Updated int64  `json:"updated"`
	Index   string `json:"index"`
	Data    T      `json:"data"`
}

type OnMessageCallback

type OnMessageCallback[T any] func([]Meta[T])