reportserver

Documentation

Index

• Variables
• type Request
  • func NewRequest(svrAddr addr.Addr, queryPort int, instanceID string, fields map[string]string) Request
• type UseCase
  • func New(serverRepo repositories.ServerRepository, ...) UseCase
  • func (uc UseCase) Execute(ctx context.Context, req Request) error
• type UseCaseOptions

Variables

var ErrInvalidRequestPayload = errors.New("invalid request payload")

Types

type Request

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

func NewRequest

func NewRequest(
	svrAddr addr.Addr,
	queryPort int,
	instanceID string,
	fields map[string]string,
) Request

type UseCase

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

func New

func New(
	serverRepo repositories.ServerRepository,
	instanceRepo repositories.InstanceRepository,
	probeRepo repositories.ProbeRepository,
	opts UseCaseOptions,
	validate *validator.Validate,
	metrics *metrics.Collector,
	clock clockwork.Clock,
	logger *zerolog.Logger,
) UseCase

func (UseCase) Execute

func (uc UseCase) Execute(ctx context.Context, req Request) error

type UseCaseOptions

type UseCaseOptions struct {
	MaxProbeRetries int
}