natsio

type Client struct {
	// contains filtered or unexported fields
}

type Config struct {
	Type                 string            `yaml:"type"`
	ServerURL            string            `yaml:"server_url"`
	Token                string            `yaml:"token"`
	Username             string            `yaml:"username"`
	Password             string            `yaml:"password"`
	Insecure             bool              `yaml:"insecure"`
	BufferSize           int               `yaml:"buffer_size"`
	RetryOnFailedConnect bool              `yaml:"retry_on_failed_connect"`
	ConnectionTimeout    string            `yaml:"connection_timeout"`
	MaximumReconnect     int               `yaml:"maximum_reconnect"`
	ReconnectWait        string            `yaml:"reconnect_wait"`
	WebsocketOptions     *WebsocketOptions `yaml:"websocket_options"`
	TopicPrefix          string            `yaml:"topic_prefix"`
}

type CustomDialer struct {
	// contains filtered or unexported fields
}

type WebsocketOptions struct {
	RequestHeader   http.Header `yaml:"request_header"`
	ReadBufferSize  int         `yaml:"read_buffer_size"`
	WriteBufferSize int         `yaml:"write_buffer_size"`
}