Documentation ¶
Index ¶
- type Client
- func (c *Client) AddUser(ctx context.Context, id uuid.UUID, user app.User) error
- func (c *Client) Close() error
- func (c *Client) DeleteUser(ctx context.Context, id uuid.UUID, user app.User) error
- func (c *Client) Monitor(ctx context.Context) error
- func (c *Client) UpdateUser(ctx context.Context, id uuid.UUID, user app.User) error
- type Config
- type Metrics
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client provided data from and to message broker.
func New ¶
func New(ctx context.Context, reg *prometheus.Registry, namespace string, cfg Config) (*Client, error)
New build and returns new queue instance.
func (*Client) DeleteUser ¶
DeleteUser implements app.Queue.
type Metrics ¶
type Metrics struct {
// contains filtered or unexported fields
}
Metrics contains general metrics for DAL methods.
func NewMetrics ¶
func NewMetrics(reg *prometheus.Registry, namespace, subsystem string, topics []string) (metric Metrics)
NewMetrics registers and returns common queue metrics.
Click to show internal directories.
Click to hide internal directories.