ami

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

type ConnErrHandler func(*Conn, error)

type ConnHandler func(*Conn)

type ConnectOption func(c *ConnectOptions) error

type ConnectOptions struct {
	Context        context.Context
	Timeout        time.Duration
	AllowReconnect bool
	Username       string // login username
	Secret         string // login secret
	Logger         *zap.Logger
	Dialer         CustomDialer
	OnConnectErr   ConnErrHandler
	OnConnected    ConnHandler
	// contains filtered or unexported fields
}

type CustomDialer interface {
	Dial(network, address string) (net.Conn, error)
}

type Message struct {
	Type       MessageType
	Name       string
	Attributes map[string]interface{}
}

type MessageType string

type RequestOption func(o *requestOptions) error

type SubscribeFunc func(ctx context.Context, message *Message) bool

type SubscribeOption func(o *subscribe) error