table

package
v1.18.3 Latest Latest
Warning

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

Go to latest
Published: Aug 14, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ActorHostOptions

type ActorHostOptions struct {
	EntityConfigs map[string]api.EntityConfig
}

type ActorTypeFactory

type ActorTypeFactory struct {
	Type       string
	Reentrancy config.ReentrancyConfig
	Factory    targets.Factory
}

type Interface

type Interface interface {
	io.Closer

	Types() []string
	IsActorTypeHosted(actorType string) bool
	GetOrCreate(actorType, actorID string) (targets.Interface, error)
	ActorExists(actorType, actorKey string) bool
	RegisterActorTypes(opts RegisterActorTypeOptions)
	UnRegisterActorTypes(actorTypes ...string) error
	SubscribeToTypeUpdates(ctx context.Context) (<-chan []string, []string)
	HaltAll(ctx context.Context) error
	HaltNonHosted(ctx context.Context, fn func(*api.LookupActorRequest) bool) error
	Len() map[string]int
	SuspendHosting(ctx context.Context) error
	ResumeHosting()
}

func New

func New(opts Options) Interface

type Options

type Options struct {
	ReentrancyStore *reentrancystore.Store

	// StartSuspended starts the table with hosting suspended: registered actor
	// types are not advertised and no actor instances can be created until
	// ResumeHosting is called. Used when no actor state store is configured at
	// startup.
	StartSuspended bool
}

type RegisterActorTypeOptions

type RegisterActorTypeOptions struct {
	HostOptions *ActorHostOptions
	Factories   []ActorTypeFactory
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL