daprd

package
v1.14.2-rc.1 Latest Latest
Warning

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

 Go to latest Published: Aug 29, 2024 License: Apache-2.0 Imports: 28 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) 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) 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) 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) HTTPAddress added in v1.13.0 

func (d *Daprd) HTTPAddress() string

func (*Daprd) HTTPGet2xx added in v1.13.3 

func (d *Daprd) HTTPGet2xx(t *testing.T, ctx context.Context, path string)

func (*Daprd) HTTPPort 

func (d *Daprd) HTTPPort() int

func (*Daprd) HTTPPost2xx added in v1.13.3 

func (d *Daprd) HTTPPost2xx(t *testing.T, 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) Metrics added in v1.13.2 

func (d *Daprd) Metrics(t *testing.T, ctx context.Context) map[string]float64

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) 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 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 Option 

type Option func(*options)

Option is a function that configures the dapr process.

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 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 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 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 WithSchedulerAddresses added in v1.14.0 

func WithSchedulerAddresses(addresses ...string) Option

func WithSentry added in v1.14.0 

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

func WithSentryAddress 

func WithSentryAddress(address string) Option

func WithSocket added in v1.13.2 

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

Source Files

View all Source files

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.