standalone

Documentation

Index

• Constants
• func DefaultComponentsDirPath() string
• func DefaultConfigFilePath() 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, data, verb string) (string, error)
  • func (s *Standalone) Publish(publishAppID, pubsubName, topic, payload 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"
)

Functions

func DefaultComponentsDirPath

func DefaultComponentsDirPath() string

func DefaultConfigFilePath

func DefaultConfigFilePath() string

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, data, verb string) (string, error)
	// Publish is used to publish event to a topic in a pubsub for an app ID.
	Publish(publishAppID, pubsubName, topic, payload 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"`
	HTTPPort       int    `csv:"HTTP PORT"`
	GRPCPort       int    `csv:"GRPC PORT"`
	AppPort        int    `csv:"APP PORT"`
	MetricsEnabled bool   `csv:"-"` // Not displayed, consumed by dashboard.
	Command        string `csv:"COMMAND"`
	Age            string `csv:"AGE"`
	Created        string `csv:"CREATED"`
	PID            int
}

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
	PlacementHost   string
	ComponentsPath  string
	AppSSL          bool
	MetricsPort     int
}

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, data, verb 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, payload string) error

Publish publishes payload to topic in pubsub referenced by pubsubName.