guard

Documentation

Overview

Copyright © 2024-2025 Macaroni OS Linux See AUTHORS and LICENSE for the license details and contributors.

Copyright © 2021-2023 Macaroni OS Linux See AUTHORS and LICENSE for the license details and contributors.

Index

• type ArtefactWriter
  • func NewArtefactWriter(file string) (*ArtefactWriter, error)
  • func (a *ArtefactWriter) Blake2b() string
  • func (a *ArtefactWriter) Close() error
  • func (a *ArtefactWriter) GetCount() int64
  • func (a *ArtefactWriter) GetPath() string
  • func (a *ArtefactWriter) MD5() string
  • func (a *ArtefactWriter) Sha512() string
  • func (a *ArtefactWriter) Write(p []byte) (int, error)
• type RestGuard
  • func NewRestGuard(cfg *specs.RestGuardConfig) (*RestGuard, error)
  • func (g *RestGuard) AddRestNode(srv string, n *specs.RestNode) error
  • func (g *RestGuard) AddService(srv string, s *specs.RestService)
  • func (g *RestGuard) CreateRequest(t *specs.RestTicket, method, path string) (*http.Request, error)
  • func (g *RestGuard) Do(t *specs.RestTicket) error
  • func (g *RestGuard) DoDownload(t *specs.RestTicket, artefactPath string) (*specs.RestArtefact, error)
  • func (g *RestGuard) DoWithTimeout(t *specs.RestTicket, timeoutSec int) error
  • func (g *RestGuard) GetService(srv string) (*specs.RestService, error)
  • func (g *RestGuard) GetUserAgent() string

Types

type ArtefactWriter

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

func NewArtefactWriter

func NewArtefactWriter(file string) (*ArtefactWriter, error)

func (*ArtefactWriter) Blake2b

func (a *ArtefactWriter) Blake2b() string

func (*ArtefactWriter) Close

func (a *ArtefactWriter) Close() error

func (*ArtefactWriter) GetCount

func (a *ArtefactWriter) GetCount() int64

func (*ArtefactWriter) GetPath

func (a *ArtefactWriter) GetPath() string

func (*ArtefactWriter) MD5

func (a *ArtefactWriter) MD5() string

func (*ArtefactWriter) Sha512

func (a *ArtefactWriter) Sha512() string

func (*ArtefactWriter) Write

func (a *ArtefactWriter) Write(p []byte) (int, error)

type RestGuard

type RestGuard struct {
	Client    *http.Client `json:"-" yaml:"-"`
	UserAgent string       `json:"user_agent,omitempty" yaml:"user_agent,omitempty"`

	Services map[string]*specs.RestService `json:"services" yaml:"services"`
	RetryCb  func(guard *RestGuard, t *specs.RestTicket) (*specs.RestNode, error)
}

func NewRestGuard

func NewRestGuard(cfg *specs.RestGuardConfig) (*RestGuard, error)

func (*RestGuard) AddRestNode

func (g *RestGuard) AddRestNode(srv string, n *specs.RestNode) error

func (*RestGuard) AddService

func (g *RestGuard) AddService(srv string, s *specs.RestService)

func (*RestGuard) CreateRequest

func (g *RestGuard) CreateRequest(t *specs.RestTicket, method, path string) (*http.Request, error)

func (*RestGuard) Do

func (g *RestGuard) Do(t *specs.RestTicket) error

func (*RestGuard) DoDownload

func (g *RestGuard) DoDownload(t *specs.RestTicket, artefactPath string) (*specs.RestArtefact, error)

func (*RestGuard) DoWithTimeout

func (g *RestGuard) DoWithTimeout(t *specs.RestTicket, timeoutSec int) error

func (*RestGuard) GetService

func (g *RestGuard) GetService(srv string) (*specs.RestService, error)

func (*RestGuard) GetUserAgent

func (g *RestGuard) GetUserAgent() string