stan

package

v0.0.113 Latest Latest Go to latest Published: Sep 21, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func ConnectSTAN(ctx context.Context, secretInterface corev1.SecretInterface, x dfv1.STAN, clientID string) (*Conn, error)

func (nsc *Conn) Close() error

func (nsc *Conn) IsClosed() bool

func (nsc *Conn) Publish(subject string, msg []byte) error

func (nsc *Conn) QueueSubscribe(subject, qgroup string, cb stan.MsgHandler, opts ...stan.SubscriptionOption) (stan.Subscription, error)