monitoring

Documentation

Index

• Constants
• type APIRoleConfigInput
• type APIRoleConfigOutput
• type Role
  • func New(instance roles.Instance) *Role
  • func (r *Role) APIRoleConfigGet() usecase.Interactor
  • func (r *Role) APIRoleConfigPut() usecase.Interactor
  • func (r *Role) HandleHealthLive(w http.ResponseWriter, re *http.Request)
  • func (r *Role) HandleMetrics(w http.ResponseWriter, re *http.Request)
  • func (r *Role) IsRunning() bool
  • func (r *Role) Start(ctx context.Context, config []byte) error
  • func (r *Role) Stop()
• type RoleConfig

Constants

const (
	KeyRole = "monitoring"
)

Types

type APIRoleConfigInput

type APIRoleConfigInput struct {
	Config RoleConfig `json:"config" required:"true"`
}

type APIRoleConfigOutput

type APIRoleConfigOutput struct {
	Config RoleConfig `json:"config" required:"true"`
}

type Role

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

func New

func New(instance roles.Instance) *Role

func (*Role) APIRoleConfigGet

func (r *Role) APIRoleConfigGet() usecase.Interactor

func (*Role) APIRoleConfigPut

func (r *Role) APIRoleConfigPut() usecase.Interactor

func (*Role) HandleHealthLive

func (r *Role) HandleHealthLive(w http.ResponseWriter, re *http.Request)

func (*Role) HandleMetrics

func (r *Role) HandleMetrics(w http.ResponseWriter, re *http.Request)

func (*Role) IsRunning

func (r *Role) IsRunning() bool

func (*Role) Start

func (r *Role) Start(ctx context.Context, config []byte) error

func (*Role) Stop

func (r *Role) Stop()

type RoleConfig

type RoleConfig struct {
	Port int32 `json:"port"`
}