eventhub

Documentation

Index

• type Client
  • func Dial(addr string, opts ...Option) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) PutToken(ctx context.Context, audience, token string) error
  • func (c *Client) PutTokenContinuously(ctx context.Context, audience string, cred *sas.Credentials, ...) error
  • func (c *Client) Sess() *amqp.Session
  • func (c *Client) SubscribePartitions(ctx context.Context, name, group string, f func(*amqp.Message)) error
• type Credentials
  • func ParseConnectionString(cs string) (*Credentials, error)
• type Option
  • func WithConnOption(opt amqp.ConnOption) Option
  • func WithLogger(l common.Logger) Option
  • func WithSASLPlain(username, password string) Option
  • func WithTLSConfig(tc *tls.Config) Option

Types

type Client

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

Client is eventhub client.

func Dial

func Dial(addr string, opts ...Option) (*Client, error)

Dial connects to the named amqp broker and returns an eventhub client.

func (*Client) Close

func (c *Client) Close() error

Close closes amqp session and connection.

func (*Client) PutToken

func (c *Client) PutToken(ctx context.Context, audience, token string) error

func (*Client) PutTokenContinuously

func (c *Client) PutTokenContinuously(
	ctx context.Context,
	audience string,
	cred *sas.Credentials,
	done <-chan struct{},
) error

PutTokenContinuously writes token first time in blocking mode and returns maintaining token updates in the background until stopCh is closed.

func (*Client) Sess

func (c *Client) Sess() *amqp.Session

func (*Client) SubscribePartitions

func (c *Client) SubscribePartitions(ctx context.Context, name, group string, f func(*amqp.Message)) error

type Credentials

type Credentials struct {
	Endpoint            string
	SharedAccessKeyName string
	SharedAccessKey     string
	EntityPath          string
}

Credentials is an evenhub connection string representation.

func ParseConnectionString

func ParseConnectionString(cs string) (*Credentials, error)

ParseConnectionString parses the given connection string into Credentials structure.

type Option

type Option func(c *Client)

func WithConnOption

func WithConnOption(opt amqp.ConnOption) Option

func WithLogger

func WithLogger(l common.Logger) Option

func WithSASLPlain

func WithSASLPlain(username, password string) Option

func WithTLSConfig

func WithTLSConfig(tc *tls.Config) Option