daprd

package

v1.13.0-rc.7 Latest Latest Go to latest Published: Feb 21, 2024 License: Apache-2.0 Imports: 24 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/dapr/dapr

Documentation ¶

Index ¶

type Daprd
- func New(t *testing.T, fopts ...Option) *Daprd
type Option

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Daprd ¶

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

func New ¶

func New(t *testing.T, fopts ...Option) *Daprd

func (*Daprd) AppAddress ¶ added in v1.13.0

func (d *Daprd) AppAddress() string

func (*Daprd) AppID ¶

func (d *Daprd) AppID() string

func (*Daprd) AppPort ¶

func (d *Daprd) AppPort() int

func (*Daprd) Cleanup ¶

func (d *Daprd) Cleanup(t *testing.T)

func (*Daprd) GRPCAddress ¶ added in v1.13.0

func (d *Daprd) GRPCAddress() string

func (*Daprd) GRPCClient ¶ added in v1.13.0

func (d *Daprd) GRPCClient(t *testing.T, ctx context.Context) rtv1.DaprClient

func (*Daprd) GRPCConn ¶ added in v1.13.0

func (d *Daprd) GRPCConn(t *testing.T, ctx context.Context) *grpc.ClientConn

func (*Daprd) GRPCPort ¶

func (d *Daprd) GRPCPort() int

func (*Daprd) HTTPAddress ¶ added in v1.13.0

func (d *Daprd) HTTPAddress() string

func (*Daprd) HTTPPort ¶

func (d *Daprd) HTTPPort() int

func (*Daprd) InternalGRPCAddress ¶ added in v1.13.0

func (d *Daprd) InternalGRPCAddress() string

func (*Daprd) InternalGRPCPort ¶

func (d *Daprd) InternalGRPCPort() int

func (*Daprd) MetricsPort ¶

func (d *Daprd) MetricsPort() int

func (*Daprd) Namespace ¶ added in v1.13.0

func (d *Daprd) Namespace() string

func (*Daprd) ProfilePort ¶

func (d *Daprd) ProfilePort() int

func (*Daprd) PublicPort ¶

func (d *Daprd) PublicPort() int

func (*Daprd) RegistedComponents ¶ added in v1.13.0

func (d *Daprd) RegistedComponents(t *assert.CollectT, ctx context.Context) []*rtv1.RegisteredComponents

func (*Daprd) Run ¶

func (d *Daprd) Run(t *testing.T, ctx context.Context)

func (*Daprd) WaitUntilAppHealth ¶

func (d *Daprd) WaitUntilAppHealth(t *testing.T, ctx context.Context)

func (*Daprd) WaitUntilRunning ¶

func (d *Daprd) WaitUntilRunning(t *testing.T, ctx context.Context)

func (*Daprd) WaitUntilTCPReady ¶ added in v1.13.0

func (d *Daprd) WaitUntilTCPReady(t *testing.T, ctx context.Context)

type Option ¶

type Option func(*options)

Option is a function that configures the dapr process.

func WithAppHealthCheck ¶

func WithAppHealthCheck(enabled bool) Option

func WithAppHealthCheckPath ¶

func WithAppHealthCheckPath(path string) Option

func WithAppHealthProbeInterval ¶

func WithAppHealthProbeInterval(interval int) Option

func WithAppHealthProbeThreshold ¶

func WithAppHealthProbeThreshold(threshold int) Option

func WithAppID ¶

func WithAppID(appID string) Option

func WithAppPort ¶

func WithAppPort(port int) Option

func WithAppProtocol ¶

func WithAppProtocol(protocol string) Option

func WithConfigs ¶

func WithConfigs(configs ...string) Option

func WithControlPlaneAddress ¶

func WithControlPlaneAddress(address string) Option

func WithDaprBlockShutdownDuration ¶ added in v1.13.0

func WithDaprBlockShutdownDuration(duration string) Option

func WithDaprGracefulShutdownSeconds ¶ added in v1.13.0

func WithDaprGracefulShutdownSeconds(seconds int) Option

func WithDisableK8sSecretStore ¶

func WithDisableK8sSecretStore(disable bool) Option

func WithEnableMTLS ¶

func WithEnableMTLS(enable bool) Option

func WithExecOptions ¶

func WithExecOptions(execOptions ...exec.Option) Option

func WithExit1 ¶ added in v1.13.0

func WithExit1() Option

func WithGRPCPort ¶

func WithGRPCPort(port int) Option

func WithHTTPPort ¶

func WithHTTPPort(port int) Option

func WithInMemoryActorStateStore ¶ added in v1.13.0

func WithInMemoryActorStateStore(storeName string) Option

WithInMemoryActorStateStore adds an in-memory state store component, which is also enabled as actor state store.

func WithInternalGRPCPort ¶

func WithInternalGRPCPort(port int) Option

func WithLogLevel ¶

func WithLogLevel(logLevel string) Option

func WithLogLineStdout ¶ added in v1.13.0

func WithLogLineStdout(ll *logline.LogLine) Option

func WithMetricsPort ¶

func WithMetricsPort(port int) Option

func WithMode ¶

func WithMode(mode string) Option

func WithNamespace ¶ added in v1.13.0

func WithNamespace(namespace string) Option

func WithPlacementAddresses ¶

func WithPlacementAddresses(addresses ...string) Option

func WithProfilePort ¶

func WithProfilePort(port int) Option

func WithPublicPort ¶

func WithPublicPort(port int) Option

func WithResourceFiles ¶

func WithResourceFiles(files ...string) Option

func WithResourcesDir ¶ added in v1.13.0

func WithResourcesDir(dirs ...string) Option

func WithSentryAddress ¶

func WithSentryAddress(address string) Option

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL