Documentation ¶
Index ¶
- func CheckMessageResponse(msg *amqp.Message) error
- func RandString() (string, error)
- func SubscribePartitions(ctx context.Context, sess *amqp.Session, name, group string, ...) error
- type Client
- 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 *common.Credentials, ...) error
- func (c *Client) Sess() *amqp.Session
- func (c *Client) SubscribePartitions(ctx context.Context, name, group string, f func(*amqp.Message)) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckMessageResponse ¶
CheckMessageResponse checks for 200 response code otherwise returns an error.
func RandString ¶
RandString generates a random 32 bytes long string.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client is eventhub client.
func (*Client) PutTokenContinuously ¶
func (c *Client) PutTokenContinuously( ctx context.Context, audience string, cred *common.Credentials, stopCh chan struct{}, ) error
PutTokenContinuously writes token first time in blocking mode and returns maintaining token updates in the background until stopCh is closed.
Click to show internal directories.
Click to hide internal directories.