The highest tagged major version is
Documentation
¶
Index ¶
Constants ¶
View Source
const ( Infinity = math.MaxInt32 MinAttempts = 4 )
Variables ¶
This section is empty.
Functions ¶
func CloseDefaultClient ¶
func CloseDefaultClient()
func IsInitialized ¶
func IsInitialized() bool
Types ¶
type DurableSub ¶
type DurableSub struct {
stan.Subscription
// contains filtered or unexported fields
}
type NatsClient ¶
type NatsClient struct {
stan.Conn
Addr string
// contains filtered or unexported fields
}
func GetDefaultClient ¶
func GetDefaultClient() *NatsClient
func InitDefaultClient ¶
func InitDefaultClient(natsConfig *structure.NatsConfig) (nc *NatsClient)
func NewNatsStreamingServerClient ¶
func NewNatsStreamingServerClient(natsConfig *structure.NatsConfig, disconnectionHandler nats.ConnHandler) (*NatsClient, error)
func (*NatsClient) Close ¶
func (nc *NatsClient) Close() error
func (*NatsClient) MakeDurableQueueSubscription ¶
func (nc *NatsClient) MakeDurableQueueSubscription(subject string, handler stan.MsgHandler) (stan.Subscription, error)
Source Files
Click to show internal directories.
Click to hide internal directories.