daprd

package
v0.0.0-...-949823d Latest Latest
Warning

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

 Go to latest Published: Nov 10, 2024 License: Apache-2.0 Imports: 30 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 

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

func (*Daprd) ActorReminderURL 

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

func (*Daprd) AppAddress 

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 

func (d *Daprd) GRPCAddress() string

func (*Daprd) GRPCClient 

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

func (*Daprd) GRPCConn 

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

func (*Daprd) GRPCPort 

func (d *Daprd) GRPCPort() int

func (*Daprd) GetMetaHTTPEndpoints 

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

func (*Daprd) GetMetaRegisteredComponents 

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

func (*Daprd) GetMetaSubscriptions 

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

func (*Daprd) GetMetaSubscriptionsWithType 

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

func (*Daprd) HTTPAddress 

func (d *Daprd) HTTPAddress() string

func (*Daprd) HTTPGet2xx 

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

func (*Daprd) HTTPPort 

func (d *Daprd) HTTPPort() int

func (*Daprd) HTTPPost2xx 

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

func (*Daprd) InternalGRPCAddress 

func (d *Daprd) InternalGRPCAddress() string

func (*Daprd) InternalGRPCPort 

func (d *Daprd) InternalGRPCPort() int

func (*Daprd) Metrics 

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 

func (d *Daprd) MetricsAddress() string

func (*Daprd) MetricsPort 

func (d *Daprd) MetricsPort() int

func (*Daprd) Namespace 

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 

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

type MetadataResponsePubsubSubscription 

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 

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 

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 

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

func WithConfigs 

func WithConfigs(configs ...string) Option

func WithControlPlaneAddress 

func WithControlPlaneAddress(address string) Option

func WithControlPlaneTrustDomain 

func WithControlPlaneTrustDomain(trustDomain string) Option

func WithDaprAPIToken 

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

func WithDaprBlockShutdownDuration 

func WithDaprBlockShutdownDuration(duration string) Option

func WithDaprGracefulShutdownSeconds 

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 

func WithExit1() Option

func WithGRPCPort 

func WithGRPCPort(port int) Option

func WithHTTPPort 

func WithHTTPPort(port int) Option

func WithInMemoryActorStateStore 

func WithInMemoryActorStateStore(storeName string) Option

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

func WithInMemoryStateStore 

func WithInMemoryStateStore(storeName string) Option

func WithInternalGRPCPort 

func WithInternalGRPCPort(port int) Option

func WithLogLevel 

func WithLogLevel(logLevel string) Option

func WithLogLineStdout 

func WithLogLineStdout(ll *logline.LogLine) Option

func WithMetricsPort 

func WithMetricsPort(port int) Option

func WithMode 

func WithMode(mode string) Option

func WithNamespace 

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 

func WithResourcesDir(dirs ...string) Option

func WithScheduler 

func WithScheduler(scheduler *scheduler.Scheduler) Option

func WithSchedulerAddresses 

func WithSchedulerAddresses(addresses ...string) Option

func WithSentry 

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

func WithSentryAddress 

func WithSentryAddress(address string) Option

func WithSocket 

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.