Documentation
¶
Index ¶
- Variables
- func DescriptorPath(dir string) string
- func LifecyclePath(dir string) string
- func LogPath(dir string) string
- func OpenLog(dir string) (io.WriteCloser, error)
- func OwnershipPath(dir string) string
- func PublishDescriptor(dir string, d Descriptor) error
- func RemoveDescriptor(dir, instanceID string) error
- func Run(ctx context.Context, settings Settings, runtimeDir string, ...) error
- func RunForeground(ctx context.Context, settings Settings, input ingestion.Request, ...) error
- func RuntimeDir() (string, error)
- type Client
- type Descriptor
- type Settings
- type Status
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func DescriptorPath ¶
func LifecyclePath ¶
func OwnershipPath ¶
func PublishDescriptor ¶
func PublishDescriptor(dir string, d Descriptor) error
func RemoveDescriptor ¶
func Run ¶
func Run(ctx context.Context, settings Settings, runtimeDir string, initial *ingestion.Request, ready func(Status, *contextservice.Submission)) error
func RunForeground ¶
func RunForeground(ctx context.Context, settings Settings, input ingestion.Request, confirm func(Status) (bool, error), ready func(Status, *contextservice.Submission)) error
RunForeground serializes discovery, replacement and publication. Shutdown uses the authenticated control endpoint, never an unverified operating-system PID.
func RuntimeDir ¶
Types ¶
type Descriptor ¶
type Descriptor struct {
Endpoint string `json:"endpoint"`
Token string `json:"token"`
Status Status `json:"status"`
}
func ReadDescriptor ¶
func ReadDescriptor(dir string) (Descriptor, error)
type Settings ¶
type Settings = controlapi.Settings
type Status ¶
type Status = controlapi.Status
Source Files
Click to show internal directories.
Click to hide internal directories.