agentapi

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

type AgentStartedEvent struct {
	AgentVersion string `json:"agent_version"`
}

type AgentStoppedEvent struct {
	Message string `json:"message"`
	Code    int    `json:"code"`
}

type DeployRequest struct {
	Argv            []string          `json:"argv,omitempty"`
	DecodedClaims   jwt.GenericClaims `json:"-"`
	Description     *string           `json:"description"`
	Environment     map[string]string `json:"environment"`
	Essential       *bool             `json:"essential,omitempty"`
	Hash            string            `json:"hash,omitempty"`
	Namespace       *string           `json:"namespace,omitempty"`
	RetriedAt       *time.Time        `json:"retried_at,omitempty"`
	RetryCount      *uint             `json:"retry_count,omitempty"`
	TotalBytes      int64             `json:"total_bytes,omitempty"`
	TriggerSubjects []string          `json:"trigger_subjects"`
	WorkloadName    *string           `json:"workload_name,omitempty"`
	WorkloadType    *string           `json:"workload_type,omitempty"`

	Stderr      io.Writer `json:"-"`
	Stdout      io.Writer `json:"-"`
	TmpFilename *string   `json:"-"`

	EncryptedEnvironment *string  `json:"-"`
	JsDomain             *string  `json:"-"`
	Location             *url.URL `json:"-"`
	SenderPublicKey      *string  `json:"-"`
	TargetNode           *string  `json:"-"`
	WorkloadJwt          *string  `json:"-"`

	Errors []error `json:"errors,omitempty"`
}

type DeployResponse struct {
	Accepted bool    `json:"accepted"`
	Message  *string `json:"message"`
}

type EventCallback func(string, cloudevents.Event)

type ExecutionProviderParams struct {
	DeployRequest
	TriggerSubjects []string `json:"trigger_subjects"`

	// Fail channel receives bool upon command failing to start
	Fail chan bool `json:"-"`

	// Run channel receives bool upon command successfully starting
	Run chan bool `json:"-"`

	// Exit channel receives int exit code upon command exit
	Exit chan int `json:"-"`

	Stderr io.Writer `json:"-"`
	Stdout io.Writer `json:"-"`

	TmpFilename *string `json:"-"`
	VmID        string  `json:"-"`

	// NATS connection which be injected into the execution provider
	NATSConn *nats.Conn `json:"-"`
}

type HandshakeCallback func(string)

type HandshakeRequest struct {
	ID        *string   `json:"id"`
	StartTime time.Time `json:"start_time"`
	Message   *string   `json:"message,omitempty"`
}

type HandshakeResponse struct {
}

type HostServicesHTTPRequest struct {
	Method string `json:"method"`
	URL    string `json:"url"`

	Body    *string          `json:"body,omitempty"`
	Headers *json.RawMessage `json:"headers,omitempty"`

	// FIXME-- this is very poorly named currently...
	//these params are parsed as an object and serialized as part of the query string
	Params *json.RawMessage `json:"params,omitempty"`
}

type HostServicesHTTPResponse struct {
	Status  int              `json:"status"`
	Headers *json.RawMessage `json:"headers,omitempty"`
	Body    string           `json:"body"`

	Error *string `json:"error,omitempty"`
}

type HostServicesKeyValueResponse struct {
	Revision int64 `json:"revision,omitempty"`
	Success  *bool `json:"success,omitempty"`

	Errors []string `json:"errors,omitempty"`
}

type HostServicesMessagingRequest struct {
	Subject *string          `json:"key"`
	Payload *json.RawMessage `json:"payload,omitempty"`
}

type HostServicesMessagingResponse struct {
	Errors  []string `json:"errors,omitempty"`
	Success bool     `json:"success,omitempty"`
}

type HostServicesObjectStoreResponse struct {
	Errors  []string `json:"errors,omitempty"`
	Success bool     `json:"success,omitempty"`
}

type LogCallback func(string, LogEntry)

type LogEntry struct {
	Source string   `json:"source,omitempty"`
	Level  LogLevel `json:"level,omitempty"`
	Text   string   `json:"text,omitempty"`
}

type LogLevel int32

type MachineMetadata struct {
	VmID         *string `json:"vmid"`
	NodeNatsHost *string `json:"node_nats_host"`
	NodeNatsPort *int    `json:"node_nats_port"`
	Message      *string `json:"message"`

	Errors []error `json:"errors,omitempty"`
}

type WorkloadStatusEvent struct {
	WorkloadName string `json:"workload_name"`
	Code         int    `json:"code"`
	Message      string `json:"message,omitempty"`
}