runtime

Documentation

Index

• type ActorRunTime
  • func GetActorRuntimeInstance() *ActorRunTime
  • func NewActorRuntime() *ActorRunTime
  • func (r *ActorRunTime) Deactivate(actorTypeName, actorID string) actorErr.ActorErr
  • func (r *ActorRunTime) GetJSONSerializedConfig() ([]byte, error)
  • func (r *ActorRunTime) InvokeActorMethod(actorTypeName, actorID, actorMethod string, payload []byte) ([]byte, actorErr.ActorErr)
  • func (r *ActorRunTime) InvokeReminder(actorTypeName, actorID, reminderName string, params []byte) actorErr.ActorErr
  • func (r *ActorRunTime) InvokeTimer(actorTypeName, actorID, timerName string, params []byte) actorErr.ActorErr
  • func (r *ActorRunTime) RegisterActorFactory(f actor.Factory, opt ...config.Option)
• type ActorRunTimeContext
  • func GetActorRuntimeInstanceContext() *ActorRunTimeContext
  • func NewActorRuntimeContext() *ActorRunTimeContext
  • func (r *ActorRunTimeContext) Deactivate(ctx context.Context, actorTypeName, actorID string) actorErr.ActorErr
  • func (r *ActorRunTimeContext) GetJSONSerializedConfig() ([]byte, error)
  • func (r *ActorRunTimeContext) InvokeActorMethod(ctx context.Context, actorTypeName, actorID, actorMethod string, ...) ([]byte, actorErr.ActorErr)
  • func (r *ActorRunTimeContext) InvokeReminder(ctx context.Context, actorTypeName, actorID, reminderName string, ...) actorErr.ActorErr
  • func (r *ActorRunTimeContext) InvokeTimer(ctx context.Context, actorTypeName, actorID, timerName string, params []byte) actorErr.ActorErr
  • func (r *ActorRunTimeContext) RegisterActorFactory(f actor.FactoryContext, opt ...config.Option)

Types

type ActorRunTime

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

Deprecated: use ActorRunTimeContext instead.

func GetActorRuntimeInstance

func GetActorRuntimeInstance() *ActorRunTime

GetActorRuntimeInstance gets or create runtime instance. Deprecated: use GetActorRuntimeInstanceContext instead.

func NewActorRuntime

func NewActorRuntime() *ActorRunTime

NewActorRuntime creates an empty ActorRuntime. Deprecated: use NewActorRuntimeContext instead.

func (*ActorRunTime) Deactivate

func (r *ActorRunTime) Deactivate(actorTypeName, actorID string) actorErr.ActorErr

Deprecated: use ActorRunTimeContext instead.

func (*ActorRunTime) GetJSONSerializedConfig

func (r *ActorRunTime) GetJSONSerializedConfig() ([]byte, error)

Deprecated: use ActorRunTimeContext instead.

func (*ActorRunTime) InvokeActorMethod

func (r *ActorRunTime) InvokeActorMethod(actorTypeName, actorID, actorMethod string, payload []byte) ([]byte, actorErr.ActorErr)

Deprecated: use ActorRunTimeContext instead.

func (*ActorRunTime) InvokeReminder

func (r *ActorRunTime) InvokeReminder(actorTypeName, actorID, reminderName string, params []byte) actorErr.ActorErr

Deprecated: use ActorRunTimeContext instead.

func (*ActorRunTime) InvokeTimer

func (r *ActorRunTime) InvokeTimer(actorTypeName, actorID, timerName string, params []byte) actorErr.ActorErr

Deprecated: use ActorRunTimeContext instead.

func (*ActorRunTime) RegisterActorFactory

func (r *ActorRunTime) RegisterActorFactory(f actor.Factory, opt ...config.Option)

Deprecated: use ActorRunTimeContext instead.

type ActorRunTimeContext

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

func GetActorRuntimeInstanceContext

func GetActorRuntimeInstanceContext() *ActorRunTimeContext

GetActorRuntimeInstanceContext gets or create runtime instance.

func NewActorRuntimeContext

func NewActorRuntimeContext() *ActorRunTimeContext

NewActorRuntimeContext creates an empty ActorRuntimeContext.

func (*ActorRunTimeContext) Deactivate

func (r *ActorRunTimeContext) Deactivate(ctx context.Context, actorTypeName, actorID string) actorErr.ActorErr

func (*ActorRunTimeContext) GetJSONSerializedConfig

func (r *ActorRunTimeContext) GetJSONSerializedConfig() ([]byte, error)

func (*ActorRunTimeContext) InvokeActorMethod

func (r *ActorRunTimeContext) InvokeActorMethod(ctx context.Context, actorTypeName, actorID, actorMethod string, payload []byte) ([]byte, actorErr.ActorErr)

func (*ActorRunTimeContext) InvokeReminder

func (r *ActorRunTimeContext) InvokeReminder(ctx context.Context, actorTypeName, actorID, reminderName string, params []byte) actorErr.ActorErr

func (*ActorRunTimeContext) InvokeTimer

func (r *ActorRunTimeContext) InvokeTimer(ctx context.Context, actorTypeName, actorID, timerName string, params []byte) actorErr.ActorErr

func (*ActorRunTimeContext) RegisterActorFactory

func (r *ActorRunTimeContext) RegisterActorFactory(f actor.FactoryContext, opt ...config.Option)

RegisterActorFactory registers the given actor factory from user, and create new actor manager if not exists.