actors

Documentation

Index

• type Actors
  • func New(t *testing.T, fopts ...Option) *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
  • func WithEntityConfigActorIdleTimeout(timeout time.Duration) EntityConfig
  • func WithEntityConfigDrainOngoingCallTimeout(timeout time.Duration) EntityConfig
  • func WithEntityConfigEntities(entities ...string) EntityConfig
  • func WithEntityConfigReentrancy(enabled bool, maxDepth *uint32) 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 WithEntityConfig(opts ...EntityConfig) Option
  • func WithFeatureSchedulerReminders(enabled bool) Option
  • func WithHandler(pattern string, handler http.HandlerFunc) 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

Types

type Actors

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

func New

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

func (*Actors) AppID

func (a *Actors) AppID() string

func (*Actors) Cleanup

func (a *Actors) Cleanup(t *testing.T)

func (*Actors) DB

func (a *Actors) DB() *sqlite.SQLite

func (*Actors) Daprd

func (a *Actors) Daprd() *daprd.Daprd

func (*Actors) GRPCClient

func (a *Actors) GRPCClient(t *testing.T, ctx context.Context) rtv1.DaprClient

func (*Actors) GRPCConn

func (a *Actors) GRPCConn(t *testing.T, ctx context.Context) *grpc.ClientConn

func (*Actors) Metrics

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

func (*Actors) Placement

func (a *Actors) Placement() *placement.Placement

func (*Actors) Run

func (a *Actors) Run(t *testing.T, ctx context.Context)

func (*Actors) Scheduler

func (a *Actors) Scheduler() *scheduler.Scheduler

func (*Actors) WaitUntilRunning

func (a *Actors) WaitUntilRunning(t *testing.T, ctx context.Context)

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 WithActorIdleTimeout(timeout time.Duration) Option

func WithActorTypeHandler

func WithActorTypeHandler(actorType string, handler http.HandlerFunc) Option

func WithActorTypes

func WithActorTypes(types ...string) Option

func WithDB

func WithDB(db *sqlite.SQLite) Option

func WithEntityConfig

func WithEntityConfig(opts ...EntityConfig) Option

func WithFeatureSchedulerReminders

func WithFeatureSchedulerReminders(enabled bool) Option

func WithHandler

func WithHandler(pattern string, handler http.HandlerFunc) Option

func WithPeerActor

func WithPeerActor(actor *Actors) Option

func WithPlacement

func WithPlacement(placement *placement.Placement) Option

func WithReentry

func WithReentry(enabled bool) Option

func WithReentryMaxDepth

func WithReentryMaxDepth(maxDepth uint32) Option

func WithResources

func WithResources(resources ...string) Option

func WithScheduler

func WithScheduler(scheduler *scheduler.Scheduler) Option