yagnats

type Callback func(*Message)

type Client struct {
	ConnectedCallback func()
	// contains filtered or unexported fields
}

type ConnectPacket struct {
	User string
	Pass string
}

type Connection struct {
	Disconnected chan bool
	// contains filtered or unexported fields
}

type ConnectionCluster struct {
	Members []ConnectionProvider
}

type ConnectionInfo struct {
	Addr     string
	Username string
	Password string
	Dial     func(network, address string) (net.Conn, error)
	TLSInfo  *ConnectionTLSInfo
}

type ConnectionProvider interface {
	ProvideConnection() (*Connection, error)
}

type ConnectionTLSInfo struct {
	CertPool              *x509.CertPool
	ClientCert            *tls.Certificate
	VerifyPeerCertificate func(rawCerts [][]byte, verifiedChains [][]*x509.Certificate) error
}

type DefaultLogger struct{}

type ERRPacket struct {
	Message string
}

type InfoPacket struct {
	Payload string
}

type Logger interface {
	Fatal(string)
	Error(string)
	Warn(string)
	Info(string)
	Debug(string)

	Fatald(map[string]interface{}, string)
	Errord(map[string]interface{}, string)
	Warnd(map[string]interface{}, string)
	Infod(map[string]interface{}, string)
	Debugd(map[string]interface{}, string)
}

type Message struct {
	Subject string
	ReplyTo string
	Payload []byte
}

type MsgPacket struct {
	Subject string
	SubID   int64
	ReplyTo string
	Payload []byte
}

type NATSClient interface {
	Ping() bool
	Connect(connectionProvider ConnectionProvider) error
	Disconnect()
	Publish(subject string, payload []byte) error
	PublishWithReplyTo(subject, reply string, payload []byte) error
	Subscribe(subject string, callback Callback) (int64, error)
	SubscribeWithQueue(subject, queue string, callback Callback) (int64, error)
	Unsubscribe(subscription int64) error
	UnsubscribeAll(subject string)
	BeforeConnectCallback(callback func())
}

type NATSConn interface {
	Close()
	Publish(subject string, data []byte) error
	PublishRequest(subj, reply string, data []byte) error
	Subscribe(subject string, handler nats.MsgHandler) (*nats.Subscription, error)
	QueueSubscribe(subject, queue string, handler nats.MsgHandler) (*nats.Subscription, error)
	Unsubscribe(sub *nats.Subscription) error
	Ping() bool
	AddReconnectedCB(func(*nats.Conn))
	AddClosedCB(func(*nats.Conn))
	AddDisconnectedCB(func(*nats.Conn))
	Options() nats.Options
}

type OKPacket struct{}

type Packet interface {
	Encode() []byte
}

type Parser func(*bufio.Reader) (Packet, error)

type PingPacket struct{}

type PongPacket struct{}

type PubPacket struct {
	Subject string
	ReplyTo string
	Payload []byte
}

type SubPacket struct {
	Subject string
	Queue   string
	ID      int64
}

type Subscription struct {
	Subject  string
	Queue    string
	Callback Callback
	ID       int64
}

type UnsubPacket struct {
	ID int64
}