instances

Documentation

Index

• type Instance
• type Instances
  • func NewInstances(platform platforms.Platform, kubeClient *kubernetes.Clientset, ...) Instances
• type MetadataActiveActorsCount
• type MetadataComponents
• type MetadataOutput
• type MetadataSubscriptions
• type StatusOutput

Types

type Instance

type Instance struct {
	AppID            string `json:"appID"`
	HTTPPort         int    `json:"httpPort"`
	GRPCPort         int    `json:"grpcPort"`
	AppPort          int    `json:"appPort"`
	Command          string `json:"command"`
	Age              string `json:"age"`
	Created          string `json:"created"`
	PID              int    `json:"pid"`
	Replicas         int    `json:"replicas"`
	Address          string `json:"address"`
	SupportsDeletion bool   `json:"supportsDeletion"`
	SupportsLogs     bool   `json:"supportsLogs"`
	Manifest         string `json:"manifest"`
	Status           string `json:"status"`
	Labels           string `json:"labels"`
	Selector         string `json:"selector"`
	Config           string `json:"config"`
}

Instance describes a Dapr sidecar instance information

type Instances

type Instances interface {
	Supported() bool
	GetInstances(scope string) []Instance
	GetInstance(scope string, id string) Instance
	DeleteInstance(scope string, id string) error
	GetContainers(scope string, id string) []string
	GetLogStream(scope, id, containerName string) ([]io.ReadCloser, error)
	GetDeploymentConfiguration(scope string, id string) string
	GetControlPlaneStatus() []StatusOutput
	GetMetadata(scope string, id string) MetadataOutput
	GetScopes() []string
	CheckPlatform() platforms.Platform
}

Instances is an interface to interact with running Dapr instances in Kubernetes or Standalone modes

func NewInstances

func NewInstances(platform platforms.Platform, kubeClient *kubernetes.Clientset, dockerComposePath string) Instances

NewInstances returns an Instances instance

type MetadataActiveActorsCount

type MetadataActiveActorsCount struct {
	Type  string `json:"type"`
	Count int    `json:"count"`
}

MetadataActiveActorsCount represents actor metadata: type and count

type MetadataComponents

type MetadataComponents struct {
	Name         string   `json:"name"`
	Type         string   `json:"type"`
	Version      string   `json:"version"`
	Capabilities []string `json:"capabilities"`
}

MetadataComponents represents component metadata: name, type, version an capabilities

type MetadataOutput

type MetadataOutput struct {
	ID              string                      `json:"id"`
	RuntimeVersion  string                      `json:"runtimeVersion"`
	EnabledFeatures []string                    `json:"enabledFeatures"`
	Actors          []MetadataActiveActorsCount `json:"actors"`
	Components      []MetadataComponents        `json:"components"`
	Subscriptions   []MetadataSubscriptions     `json:"subscriptions"`
	Extended        map[string]interface{}      `json:"extended"`
}

MetadataOutput represents a metadata api call response

type MetadataSubscriptions

type MetadataSubscriptions struct {
	PubsubName      string                   `json:"pubsubname"`
	Topic           string                   `json:"topic"`
	DeadLetterTopic string                   `json:"deadLetterTopic"`
	Metadata        map[string]interface{}   `json:"metadata"`
	Rules           []map[string]interface{} `json:"rules"`
}

MetadataSubscriptions represents subscriptions

type StatusOutput

type StatusOutput struct {
	Service   string `json:"service"`
	Name      string `json:"name"`
	Namespace string `json:"namespace"`
	Healthy   string `json:"healthy"`
	Status    string `json:"status"`
	Version   string `json:"version"`
	Age       string `json:"age"`
	Created   string `json:"created"`
}

StatusOutput represents the status of a named Dapr resource.