daprd

package
v1.17.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 15, 2026 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

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) ActorInvokeURL added in v1.15.0 

func (d *Daprd) ActorInvokeURL(actorType, actorID, method string) string

func (*Daprd) ActorReminderURL added in v1.15.0 

func (d *Daprd) ActorReminderURL(actorType, actorID, method string) string

func (*Daprd) AppAddress added in v1.13.0 

func (d *Daprd) AppAddress(t *testing.T) string

func (*Daprd) AppID 

func (d *Daprd) AppID() string

func (*Daprd) AppPort 

func (d *Daprd) AppPort(t *testing.T) 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) GetMetaActorRuntime added in v1.15.2 

func (d *Daprd) GetMetaActorRuntime(t assert.TestingT, ctx context.Context) *MetadataActorRuntime

func (*Daprd) GetMetaHTTPEndpoints added in v1.13.6 

func (d *Daprd) GetMetaHTTPEndpoints(t assert.TestingT, ctx context.Context) []*rtv1.MetadataHTTPEndpoint

func (*Daprd) GetMetaRegisteredComponents added in v1.13.6 

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

func (*Daprd) GetMetaScheduler added in v1.15.0 

func (d *Daprd) GetMetaScheduler(t assert.TestingT, ctx context.Context) *rtv1.MetadataScheduler

func (*Daprd) GetMetaSubscriptions added in v1.13.6 

func (d *Daprd) GetMetaSubscriptions(t assert.TestingT, ctx context.Context) []MetadataResponsePubsubSubscription

func (*Daprd) GetMetaSubscriptionsWithType added in v1.14.0 

func (d *Daprd) GetMetaSubscriptionsWithType(t assert.TestingT, ctx context.Context, subType string) []MetadataResponsePubsubSubscription

func (*Daprd) GetMetadata added in v1.16.0 

func (d *Daprd) GetMetadata(t assert.TestingT, ctx context.Context) *Metadata

func (*Daprd) HTTPAddress added in v1.13.0 

func (d *Daprd) HTTPAddress() string

func (*Daprd) HTTPDelete2xx added in v1.14.5 

func (d *Daprd) HTTPDelete2xx(t assert.TestingT, ctx context.Context, path string, body io.Reader, headers ...string)

func (*Daprd) HTTPGet added in v1.15.0 

func (d *Daprd) HTTPGet(t assert.TestingT, ctx context.Context, path string, expectedCode int)

func (*Daprd) HTTPGet2xx added in v1.13.3 

func (d *Daprd) HTTPGet2xx(t assert.TestingT, ctx context.Context, path string)

func (*Daprd) HTTPPort 

func (d *Daprd) HTTPPort() int

func (*Daprd) HTTPPost added in v1.15.0 

func (d *Daprd) HTTPPost(t assert.TestingT, ctx context.Context, path string, body io.Reader, expectedCode int, headers ...string)

func (*Daprd) HTTPPost2xx added in v1.13.3 

func (d *Daprd) HTTPPost2xx(t assert.TestingT, ctx context.Context, path string, body io.Reader, headers ...string)

func (*Daprd) InternalGRPCAddress added in v1.13.0 

func (d *Daprd) InternalGRPCAddress() string

func (*Daprd) InternalGRPCPort 

func (d *Daprd) InternalGRPCPort() int

func (*Daprd) Kill added in v1.16.0 

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

func (*Daprd) MetricResidentMemoryMi added in v1.14.5 

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

func (*Daprd) Metrics added in v1.13.2 

func (d *Daprd) Metrics(t assert.TestingT, ctx context.Context) *metrics.Metrics

Metrics Returns a subset of metrics scraped from the metrics endpoint

func (*Daprd) MetricsAddress added in v1.13.2 

func (d *Daprd) MetricsAddress() string

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) ReplaceArg added in v1.17.7 

func (d *Daprd) ReplaceArg(t *testing.T, flag, value string)

ReplaceArg sets `--<flag>=<value>` on the daprd command line for the next Run/Restart, replacing any existing occurrence of that flag. Existing args remain in place, so this is safe to call between Kill and Restart.

func (*Daprd) Restart added in v1.17.0 

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

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) WaitUntilExit added in v1.17.7 

func (d *Daprd) WaitUntilExit(t *testing.T, timeout time.Duration)

WaitUntilExit waits for daprd to exit on its own (e.g. via the shutdown API) and asserts the expected exit code via the framework. The HTTP port is polled; once dialing fails, the process has exited. Unlike Cleanup, no signal is sent to the process, which avoids racing with self-exit paths where signaling an already-reaped PID would fail.

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 Metadata added in v1.16.0 

type Metadata struct {
	RegisteredComponents []*rtv1.RegisteredComponents         `json:"components,omitempty"`
	Subscriptions        []MetadataResponsePubsubSubscription `json:"subscriptions,omitempty"`
	HTTPEndpoints        []*rtv1.MetadataHTTPEndpoint         `json:"httpEndpoints,omitempty"`
	Scheduler            *rtv1.MetadataScheduler              `json:"scheduler,omitempty"`
	ActorRuntime         *MetadataActorRuntime                `json:"actorRuntime,omitempty"`
	Workflows            *MetadataWorkflows                   `json:"workflows"`
}

Metadata is a subset of metadataResponse defined in pkg/api/http/metadata.go:160

type MetadataActorRuntime added in v1.15.2 

type MetadataActorRuntime struct {
	RuntimeStatus string                             `json:"runtimeStatus"`
	HostReady     bool                               `json:"hostReady"`
	Placement     string                             `json:"placement"`
	ActiveActors  []*MetadataActorRuntimeActiveActor `json:"activeActors"`
}

type MetadataActorRuntimeActiveActor added in v1.15.2 

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

type MetadataResponsePubsubSubscription added in v1.13.6 

type MetadataResponsePubsubSubscription struct {
	PubsubName      string                                   `json:"pubsubname"`
	Topic           string                                   `json:"topic"`
	Metadata        map[string]string                        `json:"metadata,omitempty"`
	Rules           []MetadataResponsePubsubSubscriptionRule `json:"rules,omitempty"`
	DeadLetterTopic string                                   `json:"deadLetterTopic"`
	Type            string                                   `json:"type"`
}

MetadataResponsePubsubSubscription copied from pkg/api/http/metadata.go:172 to be able to use in integration tests until we move to Proto format

type MetadataResponsePubsubSubscriptionRule added in v1.13.6 

type MetadataResponsePubsubSubscriptionRule struct {
	Match string `json:"match,omitempty"`
	Path  string `json:"path,omitempty"`
}

type MetadataWorkflows added in v1.16.0 

type MetadataWorkflows struct {
	ConnectedWorkers int `json:"connectedWorkers,omitempty"`
}

type Option 

type Option func(*options)

Option is a function that configures the dapr process.

func WithAllowedOrigins added in v1.16.0 

func WithAllowedOrigins(t *testing.T, origins string) Option

func WithAppAPIToken added in v1.13.3 

func WithAppAPIToken(t *testing.T, token string) Option

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 WithConfigManifests added in v1.13.3 

func WithConfigManifests(t *testing.T, manifests ...string) Option

func WithConfigs 

func WithConfigs(configs ...string) Option

func WithControlPlaneAddress 

func WithControlPlaneAddress(address string) Option

func WithControlPlaneTrustDomain added in v1.13.2 

func WithControlPlaneTrustDomain(trustDomain string) Option

func WithDaprAPIToken added in v1.15.0 

func WithDaprAPIToken(t *testing.T, token 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 WithDisableInitEndpoints added in v1.17.0 

func WithDisableInitEndpoints(endpoints ...string) Option

func WithDisableK8sSecretStore 

func WithDisableK8sSecretStore(disable bool) Option

func WithEnableMTLS 

func WithEnableMTLS(enable bool) Option

func WithErrorCodeMetrics added in v1.15.0 

func WithErrorCodeMetrics(t *testing.T) 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 WithInMemoryStateStore added in v1.13.3 

func WithInMemoryStateStore(storeName string) Option

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 WithMaxBodySize added in v1.15.1 

func WithMaxBodySize(size string) 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 WithPlacement added in v1.17.0 

func WithPlacement(placement *placement.Placement) 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 WithScheduler added in v1.14.2 

func WithScheduler(scheduler *scheduler.Scheduler) Option

func WithSchedulerAddresses added in v1.14.0 

func WithSchedulerAddresses(addresses ...string) Option

func WithSchedulerAddressesReset added in v1.17.7 

func WithSchedulerAddressesReset(addresses ...string) Option

WithSchedulerAddressesReset replaces any previously configured scheduler addresses with the supplied set. Use this when a later option layer needs to redirect daprd away from a scheduler address an earlier layer already added (for example pointing daprd at a scheduler proxy instead of the real scheduler).

func WithSentry added in v1.14.0 

func WithSentry(t *testing.T, sentry *sentry.Sentry) Option

func WithSentryAddress 

func WithSentryAddress(address string) Option

func WithSkipStateStoreReminderMigration added in v1.16.2 

func WithSkipStateStoreReminderMigration(t *testing.T) Option

func WithSocket added in v1.13.2 

func WithSocket(t *testing.T, socket *socket.Socket) Option

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.