client

Documentation

Index

• Constants
• type AppServiceState
• type AppState
• type AppStates
• type Device
• type DgTimeStamp
  • func (ts DgTimeStamp) AsTime() time.Time
• type GatewayClient
  • func NewGatewayClient(cfg *config.Config, apps []string, targetID string, ...) (*GatewayClient, error)
  • func (c *GatewayClient) Get(resourcePath string) (*transport.HttpRes, error)
  • func (c *GatewayClient) Post(resourcePath string, data any) (*transport.HttpRes, error)
  • func (c *GatewayClient) Put(resourcePath string, data any) (*transport.HttpRes, error)
  • func (c *GatewayClient) PutSysInfo() error
  • func (c *GatewayClient) ReportAppStates(ctx context.Context, cfg *compose.Config) error
  • func (c *GatewayClient) Self() (*Device, error)
  • func (c *GatewayClient) UpdateHeaders(apps []string, targetID string)
• type GatewayClientOpt
  • func WithHttpOperations(ops GwHttpOperations) GatewayClientOpt
• type GatewayClientOpts
• type GwHttpOperations

Constants

const (
	UserAgentPrefix = "fioup/"

	HeaderKeyTag    = "x-ats-tags"
	HeaderKeyApps   = "x-ats-dockerapps"
	HeaderKeyTarget = "x-ats-target"
)

Types

type AppServiceState

type AppServiceState struct {
	Name     string `json:"name"`
	Hash     string `json:"hash"`
	State    string `json:"state"`
	Status   string `json:"status"`
	Health   string `json:"health,omitempty"`
	ImageUri string `json:"image"`
	Logs     string `json:"logs,omitempty"`
}

type AppState

type AppState struct {
	Services []AppServiceState `json:"services"`
	State    string            `json:"state"`
	Uri      string            `json:"uri"`
}

type AppStates

type AppStates struct {
	Ostree     string              `json:"ostree"`
	DeviceTime string              `json:"deviceTime"`
	Apps       map[string]AppState `json:"apps"`
}

type Device

type Device struct {
	Factory   string      `json:"factory"`
	RepoId    string      `json:"repo_id"`
	Uuid      string      `json:"uuid"`
	Name      string      `json:"name"`
	CreatedAt DgTimeStamp `json:"created_at"`
	LastSeen  DgTimeStamp `json:"last_seen"`
	PubKey    string      `json:"pubkey"`
	Tag       string      `json:"tag"`
}

type DgTimeStamp

type DgTimeStamp float32

func (DgTimeStamp) AsTime

func (ts DgTimeStamp) AsTime() time.Time

type GatewayClient

type GatewayClient struct {
	BaseURL    *url.URL
	HttpClient *http.Client
	Headers    map[string]string
	// contains filtered or unexported fields
}

func NewGatewayClient

func NewGatewayClient(cfg *config.Config, apps []string, targetID string, options ...GatewayClientOpt) (*GatewayClient, error)

func (*GatewayClient) Get

func (c *GatewayClient) Get(resourcePath string) (*transport.HttpRes, error)

func (*GatewayClient) Post

func (c *GatewayClient) Post(resourcePath string, data any) (*transport.HttpRes, error)

func (*GatewayClient) Put

func (c *GatewayClient) Put(resourcePath string, data any) (*transport.HttpRes, error)

func (*GatewayClient) PutSysInfo

func (c *GatewayClient) PutSysInfo() error

PutSysInfo sends the "system-info" API data to the gateway. It only sends each piece of data if it has changed since the last time this function was invoked.

func (*GatewayClient) ReportAppStates

func (c *GatewayClient) ReportAppStates(ctx context.Context, cfg *compose.Config) error

func (*GatewayClient) Self

func (c *GatewayClient) Self() (*Device, error)

func (*GatewayClient) UpdateHeaders

func (c *GatewayClient) UpdateHeaders(apps []string, targetID string)

type GatewayClientOpt

type GatewayClientOpt func(*GatewayClientOpts)

func WithHttpOperations

func WithHttpOperations(ops GwHttpOperations) GatewayClientOpt

type GatewayClientOpts

type GatewayClientOpts struct {
	HttpOperations GwHttpOperations
}

type GwHttpOperations

type GwHttpOperations interface {
	HttpGet(client *http.Client, url string, headers map[string]string) (*transport.HttpRes, error)
	HttpDo(client *http.Client, method, url string, headers map[string]string, data any) (*transport.HttpRes, error)
}