ns

Documentation

Index

• Constants
• type NatsStreaming
  • func NewClient(url string, clusterID string, clientID string, timeout time.Duration) *NatsStreaming
  • func (ns *NatsStreaming) Close() error
  • func (ns *NatsStreaming) Connect() error
  • func (ns *NatsStreaming) GetClient() stan.Conn

Constants

const (
	DefaultURL     = "nats://nats:4222"
	ClusterID      = "test-cluster"
	LogsSubject    = "amp-logs"
	MetricsSubject = "amp-metrics"
)

Types

type NatsStreaming

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

NatsStreaming NATS-Streaming wrapper

func NewClient

func NewClient(url string, clusterID string, clientID string, timeout time.Duration) *NatsStreaming

NewClient instantiates a NatsStreaming wrapper

func (*NatsStreaming) Close

func (ns *NatsStreaming) Close() error

Close the client

func (*NatsStreaming) Connect

func (ns *NatsStreaming) Connect() error

Connect to NATS-Streaming

func (*NatsStreaming) GetClient

func (ns *NatsStreaming) GetClient() stan.Conn

GetClient return client