monitor

Documentation

Index

• Constants
• type Client
• type Option
  • func WithCleanupTimeout(cleanupTimeout time.Duration) Option
  • func WithMaxLatency(latency time.Duration) Option
  • func WithTimeout(timeout time.Duration) Option
• type Probe
  • func NewProbe(client Client, sender Sender, logger logx.Logger, opts ...Option) *Probe
  • func (p *Probe) Run()
• type Sender

Constants

const (
	DefaultTimeout        = time.Second
	DefaultCleanupTimeout = time.Second * 10
	DefaultMaxLatency     = time.Millisecond * 100
)

Types

type Client

type Client interface {
	AssignRole(ctx context.Context, roleName string, actor perm.Actor) (time.Duration, error)
	CreateRole(ctx context.Context, name string, permissions ...perm.Permission) (perm.Role, time.Duration, error)
	DeleteRole(ctx context.Context, name string) (time.Duration, error)
	HasPermission(ctx context.Context, actor perm.Actor, action, resource string) (bool, time.Duration, error)
	UnassignRole(ctx context.Context, roleName string, actor perm.Actor) (time.Duration, error)
}

type Option

type Option func(*options)

func WithCleanupTimeout

func WithCleanupTimeout(cleanupTimeout time.Duration) Option

func WithMaxLatency

func WithMaxLatency(latency time.Duration) Option

func WithTimeout

func WithTimeout(timeout time.Duration) Option

type Probe

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

func NewProbe

func NewProbe(client Client, sender Sender, logger logx.Logger, opts ...Option) *Probe

func (*Probe) Run

func (p *Probe) Run()

type Sender

type Sender interface {
	Gauge(string, int64, float32) error
}