api

Feb 16, 2024

Changes in this version

+ func GetFileHash(name ...string) (string, error)

Feb 13, 2024

Changes in this version

+ func CompareCatalogVersion(a, b string) int

Jul 28, 2023

Changes in this version

+ func BasicClient(skipVerify bool, proxy func(*http.Request) (*url.URL, error)) *http.Client

+ func ProxyClient(skipVerify bool, proxy string) *http.Client

+ func ProxyEnvClient(skipVerify bool) *http.Client

+ func Transport(skipVerify bool) *http.Transport

Jul 21, 2023

Changes in this version

+ const CatalogUrlsToFetchForManagers

+ func UnescapedValue(s string) string

type Client

+ func (c *Client) StaticClient() *http.Client

Jan 10, 2023

Changes in this version

+ var ErrBadPrincipal = errors.New(`principal must be "machines" or "users"`)

type Client

+ func (c *Client) RefreshToken(principal, key string, validTime time.Duration) (err error)

+ func (c *Client) StartTokenRefresh(principal, key string, refreshTime, validTime time.Duration) error

type R

+ func (r *R) SetHeaders(args ...string) *R

Aug 22, 2022

Changes in this version

type Client

+ func ClientCertSession(ctx context.Context, endpoint, clientCert, clientKey string, ...) (*Client, error)

+ func TokenSessionProxyServer(endpoint, token string, proxy bool, serverVerify bool, caCert string) (*Client, error)

+ func UserSessionTokenProxyContextServer(ctx context.Context, endpoint, username, password string, ...) (*Client, error)

Aug 14, 2022

Changes in this version

+ func ProcessCatalog(catalog, catalogSource string, res *models.Content)

Aug 8, 2022

Changes in this version

+ func CombineCatalogs(catalogs []*models.Content) (res *models.Content, err error)

+ func FetchCatalog(catalogUrls []string, session *Client) (res *models.Content, err error)

+ func FetchCatalogUrls(session *Client) (catalogUrls []string, err error)

+ func FixSource(source, catalogSource string) string

+ func GetCatalog(catalog string, session *Client) (res *models.Content, err error)

+ func GetCatalogSource(catalogUrl string, session *Client) (catalogSource string)

+ func GetManagerCatalogItem(name, version string, session *Client) (*models.CatalogItem, error)

type Client

+ func (c *Client) SignRackNUrl(oldUrl string) (newUrl string, err error)

+ type CloudiaUrlReq struct

+ Bucket string

+ Object string

+ Region string

+ type CloudiaUrlResp struct

+ Object CloudiaUrlReq

+ Url string

type TestFunc

+ func ParseAwaitFunctions(fnString string) ([]TestFunc, error)

Mar 1, 2022

Changes in this version

+ func BuildCatalog(baseDir, fileURL string) (*models.Content, error)

Sep 9, 2021

Changes in this version

+ const APIPATH

+ func DecodeYaml(buf []byte, ref interface{}) error

+ func FindOrFake(src, field string, args map[string]string) string

+ func GenPatch(source, target interface{}, paranoid bool) (jsonpatch2.Patch, error)

+ func Pretty(f string, obj interface{}) ([]byte, error)

+ func PrettyColor(f string, obj interface{}, useColor bool, colors [][]int) ([]byte, error)

+ func ValueInList(val, list string) bool

+ type Client struct

+ RoundTripTimeout time.Duration

+ func DisconnectedClient() *Client

+ func TokenSession(endpoint, token string) (*Client, error)

+ func TokenSessionProxy(endpoint, token string, proxy bool) (*Client, error)

+ func UserSession(endpoint, username, password string) (*Client, error)

+ func UserSessionContext(ctx context.Context, endpoint, username, password string) (*Client, error)

+ func UserSessionToken(endpoint, username, password string, usetoken bool) (*Client, error)

+ func UserSessionTokenContext(ctx context.Context, endpoint, username, password string, usetoken bool) (*Client, error)

+ func UserSessionTokenProxy(endpoint, username, password string, usetoken, useproxy bool) (*Client, error)

+ func UserSessionTokenProxyContext(ctx context.Context, endpoint, username, password string, ...) (*Client, error)

+ func (c *Client) AllIndexes() (map[string]map[string]models.Index, error)

+ func (c *Client) Authorize(req *http.Request) error

+ func (c *Client) BundleContent(src string, dst store.Store, params map[string]string) error

+ func (c *Client) Close()

+ func (c *Client) CreateContent(content *models.Content, replaceWritable bool) (*models.ContentSummary, error)

+ func (c *Client) CreateModel(ref models.Model) error

+ func (c *Client) DeleteBlob(at ...string) error

+ func (c *Client) DeleteContent(name string) error

+ func (c *Client) DeleteModel(prefix, key string) (models.Model, error)

+ func (c *Client) Endpoint() string

+ func (c *Client) Events() (*EventStream, error)

+ func (c *Client) ExistsModel(prefix, key string) (bool, error)

+ func (c *Client) File(pathParts ...string) (io.ReadCloser, error)

+ func (c *Client) FillModel(ref models.Model, key string) error

+ func (c *Client) GetBlob(dest io.Writer, at ...string) error

+ func (c *Client) GetBlobSum(at ...string) (string, error)

+ func (c *Client) GetContentItem(name string) (*models.Content, error)

+ func (c *Client) GetContentSummary() ([]*models.ContentSummary, error)

+ func (c *Client) GetModel(prefix, key string, params ...string) (models.Model, error)

+ func (c *Client) GetModelForPatch(prefix, key string, params ...string) (models.Model, models.Model, error)

+ func (c *Client) Host() string

+ func (c *Client) Indexes(prefix string) (map[string]models.Index, error)

+ func (c *Client) Info() (*models.Info, error)

+ func (c *Client) InstallBootEnvFromFile(src string) (*models.BootEnv, error)

+ func (c *Client) InstallISOForBootenv(env *models.BootEnv, src string, downloadOK bool) error

+ func (c *Client) InstallRawTemplateFromFile(src string) (*models.Template, error)

+ func (c *Client) InstallRawTemplateFromFileWithId(src, tid string) (*models.Template, error)

+ func (c *Client) ListBlobs(at string, params ...string) ([]string, error)

+ func (c *Client) ListModel(prefix string, params ...string) ([]models.Model, error)

+ func (c *Client) Logs() ([]logger.Line, error)

+ func (c *Client) MakeProxy(socketPath string) error

+ func (c *Client) Objects() ([]string, error)

+ func (c *Client) OneIndex(prefix, param string) (models.Index, error)

+ func (c *Client) PatchModel(prefix, key string, patch jsonpatch2.Patch) (models.Model, error)

+ func (c *Client) PatchTo(old models.Model, new models.Model) (models.Model, error)

+ func (c *Client) PatchToFull(old models.Model, new models.Model, paranoid bool) (models.Model, error)

+ func (c *Client) PostBlob(blob io.Reader, at ...string) (models.BlobInfo, error)

+ func (c *Client) PostBlobExplode(blob io.Reader, explode bool, at ...string) (models.BlobInfo, error)

+ func (c *Client) PostEvent(evt *models.Event) error

+ func (c *Client) PutModel(obj models.Model) error

+ func (c *Client) ReplaceContent(content *models.Content, replaceWritable bool) (*models.ContentSummary, error)

+ func (c *Client) Req() *R

+ func (c *Client) RunProxy(socketPath string) error

+ func (c *Client) SetLogger(l logger.Logger)

+ func (c *Client) Token() string

+ func (c *Client) TokenRefresh(prefix, key string)

+ func (c *Client) Trace(lvl string)

+ func (c *Client) TraceToken(t string)

+ func (c *Client) UnbundleContent(content store.Store, dst string) error

+ func (c *Client) UploadISOForBootEnv(env *models.BootEnv, src io.Reader, dest string) (models.BlobInfo, error)

+ func (c *Client) UrlFor(args ...string) (*url.URL, error)

+ func (c *Client) UrlForProxy(proxy string, args ...string) (*url.URL, error)

+ func (c *Client) UrlProxy(up string) *Client

+ func (c *Client) Username() string

+ func (c *Client) Websocket(at string) (*websocket.Conn, error)

+ type Decoder interface

+ Decode func(interface{}) error

+ type Encoder interface

+ Encode func(interface{}) error

+ type EventStream struct

+ func (es *EventStream) Close() error

+ func (es *EventStream) Deregister(handle int64) error

+ func (es *EventStream) Kill()

+ func (es *EventStream) Register(events ...string) (int64, <-chan RecievedEvent, error)

+ func (es *EventStream) Subscribe(handle int64, events ...string) error

+ func (es *EventStream) WaitFor(item models.Model, test TestFunc, timeout time.Duration) (string, error)

+ type R struct

+ Req *http.Request

+ Resp *http.Response

+ func (r *R) Body(b interface{}) *R

+ func (r *R) Context(c context.Context) *R

+ func (r *R) Del() *R

+ func (r *R) Delete(m models.Model) error

+ func (r *R) Do(val interface{}) error

+ func (r *R) FailFast() *R

+ func (r *R) Fill(m models.Model) error

+ func (r *R) Filter(prefix string, filterArgs ...string) *R

+ func (r *R) Get() *R

+ func (r *R) GetETag() string

+ func (r *R) Head() *R

+ func (r *R) Headers(args ...string) *R

+ func (r *R) List(prefix string) *R

+ func (r *R) Meth(v string) *R

+ func (r *R) Params(args ...string) *R

+ func (r *R) ParanoidPatch() *R

+ func (r *R) Patch(b jsonpatch2.Patch) *R

+ func (r *R) PatchObj(old, new interface{}) *R

+ func (r *R) PatchTo(old, new models.Model) *R

+ func (r *R) PatchToFull(old models.Model, new models.Model, paranoid bool) (models.Model, error)

+ func (r *R) Post(b interface{}) *R

+ func (r *R) Proxy(proxy string) *R

+ func (r *R) Put(b interface{}) *R

+ func (r *R) Response() (*http.Response, error)

+ func (r *R) Trace(lvl string) *R

+ func (r *R) TraceToken(t string) *R

+ func (r *R) UrlFor(args ...string) *R

+ func (r *R) UrlForM(m models.Model, rest ...string) *R

+ func (r *R) Wait(etag, dur string) *R

+ type RecievedEvent struct

+ E models.Event

+ Err error

+ type TestFunc func(interface{}) (bool, error)

+ func AndItems(fs ...TestFunc) TestFunc

+ func EqualItem(field string, value interface{}) TestFunc

+ func NotItem(f TestFunc) TestFunc

+ func OrItems(fs ...TestFunc) TestFunc