Documentation
¶
Index ¶
- type Actors
- func (a *Actors) AppID() string
- func (a *Actors) Cleanup(t *testing.T)
- func (a *Actors) DB() *sqlite.SQLite
- func (a *Actors) Daprd() *daprd.Daprd
- func (a *Actors) GRPCClient(t *testing.T, ctx context.Context) rtv1.DaprClient
- func (a *Actors) GRPCConn(t *testing.T, ctx context.Context) *grpc.ClientConn
- func (a *Actors) Metrics(t *testing.T, ctx context.Context) map[string]float64
- func (a *Actors) Placement() *placement.Placement
- func (a *Actors) Run(t *testing.T, ctx context.Context)
- func (a *Actors) Scheduler() *scheduler.Scheduler
- func (a *Actors) WaitUntilRunning(t *testing.T, ctx context.Context)
- type EntityConfig
- type Option
- func WithActorIdleTimeout(timeout time.Duration) Option
- func WithActorTypeHandler(actorType string, handler http.HandlerFunc) Option
- func WithActorTypes(types ...string) Option
- func WithDB(db *sqlite.SQLite) Option
- func WithDaprdOptions(opts ...daprd.Option) Option
- func WithDrainOngoingCallTimeout(timeout time.Duration) Option
- func WithDrainRebalancedActors(drain bool) Option
- func WithEntityConfig(opts ...EntityConfig) Option
- func WithHandler(pattern string, handler http.HandlerFunc) Option
- func WithMaxBodySize(size string) Option
- func WithPeerActor(actor *Actors) Option
- func WithPlacement(placement *placement.Placement) Option
- func WithReentry(enabled bool) Option
- func WithReentryMaxDepth(maxDepth uint32) Option
- func WithResources(resources ...string) Option
- func WithScheduler(scheduler *scheduler.Scheduler) Option
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Actors ¶
type Actors struct {
// contains filtered or unexported fields
}
func (*Actors) GRPCClient ¶
type EntityConfig ¶
type EntityConfig func(*entityConfig)
func WithEntityConfigActorIdleTimeout ¶
func WithEntityConfigActorIdleTimeout(timeout time.Duration) EntityConfig
func WithEntityConfigDrainOngoingCallTimeout ¶
func WithEntityConfigDrainOngoingCallTimeout(timeout time.Duration) EntityConfig
func WithEntityConfigEntities ¶
func WithEntityConfigEntities(entities ...string) EntityConfig
func WithEntityConfigReentrancy ¶
func WithEntityConfigReentrancy(enabled bool, maxDepth *uint32) EntityConfig
type Option ¶
type Option func(*options)
func WithActorIdleTimeout ¶
func WithActorTypeHandler ¶
func WithActorTypeHandler(actorType string, handler http.HandlerFunc) Option
func WithActorTypes ¶
func WithDaprdOptions ¶ added in v1.17.7
func WithDrainOngoingCallTimeout ¶ added in v1.17.0
func WithDrainRebalancedActors ¶ added in v1.17.0
func WithEntityConfig ¶
func WithEntityConfig(opts ...EntityConfig) Option
func WithHandler ¶
func WithHandler(pattern string, handler http.HandlerFunc) Option
func WithMaxBodySize ¶ added in v1.15.1
func WithPeerActor ¶
func WithPlacement ¶
func WithReentry ¶
func WithReentryMaxDepth ¶
func WithResources ¶
func WithScheduler ¶
Source Files
Click to show internal directories.
Click to hide internal directories.