standalone

Documentation

Index

• Constants
• func DefaultComponentsDirPath() string
• func DefaultConfigFilePath() string
• func GetBuildInfo(version string) string
• func GetDashboardVersion() string
• func GetRuntimeVersion() string
• func Init(runtimeVersion, dashboardVersion string, dockerNetwork string, slimMode bool) error
• func NewDashboardCmd(port int) *exec.Cmd
• func Stop(appID string) error
• func Uninstall(uninstallAll bool, dockerNetwork string) error
• type Client
  • func NewClient() Client
• type DaprProcess
• type ListOutput
  • func List() ([]ListOutput, error)
• type RunConfig
• type RunOutput
  • func Run(config *RunConfig) (*RunOutput, error)
• type Standalone
  • func (s *Standalone) Invoke(appID, method string, data []byte, verb string, path string) (string, error)
  • func (s *Standalone) Publish(publishAppID, pubsubName, topic string, payload []byte, socket string) error

Constants

const (

	// DaprPlacementContainerName is the container name of placement service.
	DaprPlacementContainerName = "dapr_placement"
	// DaprRedisContainerName is the container name of redis.
	DaprRedisContainerName = "dapr_redis"
	// DaprZipkinContainerName is the container name of zipkin.
	DaprZipkinContainerName = "dapr_zipkin"
)

const SocketFormat = "/tmp/dapr-%s-http.socket"

Functions

func DefaultComponentsDirPath

func DefaultComponentsDirPath() string

func DefaultConfigFilePath

func DefaultConfigFilePath() string

func GetBuildInfo

func GetBuildInfo(version string) string

GetBuildInfo returns build info for the CLI and the local Dapr runtime.

func GetDashboardVersion

func GetDashboardVersion() string

GetDashboardVersion returns the version for the local Dapr dashboard.

func GetRuntimeVersion

func GetRuntimeVersion() string

GetRuntimeVersion returns the version for the local Dapr runtime.

func Init

func Init(runtimeVersion, dashboardVersion string, dockerNetwork string, slimMode bool) error

Init installs Dapr on a local machine using the supplied runtimeVersion.

func NewDashboardCmd

func NewDashboardCmd(port int) *exec.Cmd

NewDashboardCmd creates the command to run dashboard.

func Stop

func Stop(appID string) error

Stop terminates the application process.

func Uninstall

func Uninstall(uninstallAll bool, dockerNetwork string) error

Uninstall reverts all changes made by init. Deletes all installed containers, removes default dapr folder, removes the installed binary and unsets env variables.

Types

type Client

type Client interface {
	// Invoke is a command to invoke a remote or local dapr instance
	Invoke(appID, method string, data []byte, verb string, socket string) (string, error)
	// Publish is used to publish event to a topic in a pubsub for an app ID.
	Publish(publishAppID, pubsubName, topic string, payload []byte, socket string) error
}

Client is the interface the wraps all the methods exposed by the Dapr CLI.

func NewClient

func NewClient() Client

type DaprProcess

type DaprProcess interface {
	List() ([]ListOutput, error)
}

type ListOutput

type ListOutput struct {
	AppID          string `csv:"APP ID"    json:"appId"          yaml:"appId"`
	HTTPPort       int    `csv:"HTTP PORT" json:"httpPort"       yaml:"httpPort"`
	GRPCPort       int    `csv:"GRPC PORT" json:"grpcPort"       yaml:"grpcPort"`
	AppPort        int    `csv:"APP PORT"  json:"appPort"        yaml:"appPort"`
	MetricsEnabled bool   `csv:"-"         json:"metricsEnabled" yaml:"metricsEnabled"` // Not displayed in table, consumed by dashboard.
	Command        string `csv:"COMMAND"   json:"command"        yaml:"command"`
	Age            string `csv:"AGE"       json:"age"            yaml:"age"`
	Created        string `csv:"CREATED"   json:"created"        yaml:"created"`
	PID            int    `csv:"PID"       json:"pid"            yaml:"pid"`
}

ListOutput represents the application ID, application port and creation time.

func List

func List() ([]ListOutput, error)

List outputs all the applications.

type RunConfig

type RunConfig struct {
	AppID              string
	AppPort            int
	HTTPPort           int
	GRPCPort           int
	ConfigFile         string
	Protocol           string
	Arguments          []string
	EnableProfiling    bool
	ProfilePort        int
	LogLevel           string
	MaxConcurrency     int
	PlacementHostAddr  string
	ComponentsPath     string
	AppSSL             bool
	MetricsPort        int
	MaxRequestBodySize int
	UnixDomainSocket   string
}

RunConfig represents the application configuration parameters.

type RunOutput

type RunOutput struct {
	DaprCMD      *exec.Cmd
	DaprHTTPPort int
	DaprGRPCPort int
	AppID        string
	AppCMD       *exec.Cmd
}

RunOutput represents the run output.

func Run

func Run(config *RunConfig) (*RunOutput, error)

type Standalone

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

func (*Standalone) Invoke

func (s *Standalone) Invoke(appID, method string, data []byte, verb string, path string) (string, error)

Invoke is a command to invoke a remote or local dapr instance.

func (*Standalone) Publish

func (s *Standalone) Publish(publishAppID, pubsubName, topic string, payload []byte, socket string) error

Publish publishes payload to topic in pubsub referenced by pubsubName.