manager

package
v0.0.0-...-2a7ec10 Latest Latest
Warning

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

 Go to latest Published: May 7, 2024 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 ActorContainer deprecated 

type ActorContainer interface {
	Invoke(methodName string, param []byte) ([]reflect.Value, actorErr.ActorErr)
	//nolint:staticcheck // SA1019 Deprecated: use ActorContainerContext instead.
	GetActor() actor.Server
}

Deprecated: use ActorContainerContext instead.

func NewDefaultActorContainer 

func NewDefaultActorContainer(actorID string, impl actor.Server, serializer codec.Codec) (ActorContainer, actorErr.ActorErr)

NewDefaultActorContainer creates a new ActorContainer with provider impl actor and serializer. Deprecated: use NewDefaultActorContainerContext instead.

type ActorContainerContext 

type ActorContainerContext interface {
	Invoke(ctx context.Context, methodName string, param []byte) ([]reflect.Value, actorErr.ActorErr)
	GetActor() actor.ServerContext
}

func NewDefaultActorContainerContext 

func NewDefaultActorContainerContext(ctx context.Context, actorID string, impl actor.ServerContext, serializer codec.Codec) (ActorContainerContext, actorErr.ActorErr)

NewDefaultActorContainerContext is the same as NewDefaultActorContainer, but with initial context.

type ActorManager 

type ActorManager interface {
	RegisterActorImplFactory(f actor.Factory)
	InvokeMethod(actorID, methodName string, request []byte) ([]byte, actorErr.ActorErr)
	DeactivateActor(actorID string) actorErr.ActorErr
	InvokeReminder(actorID, reminderName string, params []byte) actorErr.ActorErr
	InvokeTimer(actorID, timerName string, params []byte) actorErr.ActorErr
}

func NewDefaultActorManager deprecated 

func NewDefaultActorManager(serializerType string) (ActorManager, actorErr.ActorErr)

Deprecated: use DefaultActorManagerContext instead.

type ActorManagerContext 

type ActorManagerContext interface {
	RegisterActorImplFactory(f actor.FactoryContext)
	InvokeMethod(ctx context.Context, actorID, methodName string, request []byte) ([]byte, actorErr.ActorErr)
	DeactivateActor(ctx context.Context, actorID string) actorErr.ActorErr
	InvokeReminder(ctx context.Context, actorID, reminderName string, params []byte) actorErr.ActorErr
	InvokeTimer(ctx context.Context, actorID, timerName string, params []byte) actorErr.ActorErr
}

func NewDefaultActorManagerContext 

func NewDefaultActorManagerContext(serializerType string) (ActorManagerContext, actorErr.ActorErr)

type DefaultActorContainer 

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

DefaultActorContainer contains actor instance and methods type info generated from actor. Deprecated: use DefaultActorContainerContext instead.

func (*DefaultActorContainer) GetActor deprecated 

func (d *DefaultActorContainer) GetActor() actor.Server

Deprecated: use NewDefaultActorContainerContext instead.

func (*DefaultActorContainer) Invoke 

func (d *DefaultActorContainer) Invoke(methodName string, param []byte) ([]reflect.Value, actorErr.ActorErr)

Invoke call actor method with given methodName and param. Deprecated: use NewDefaultActorContainerContext instead.

type DefaultActorContainerContext 

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

DefaultActorContainerContext contains actor instance and methods type info generated from actor.

func (*DefaultActorContainerContext) GetActor 

func (d *DefaultActorContainerContext) GetActor() actor.ServerContext

func (*DefaultActorContainerContext) Invoke 

func (d *DefaultActorContainerContext) Invoke(ctx context.Context, methodName string, param []byte) ([]reflect.Value, actorErr.ActorErr)

Invoke call actor method with given context, methodName and param.

type DefaultActorManager 

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

DefaultActorManager is to manage one type of actor. Deprecated: use DefaultActorManagerContext instead.

func (*DefaultActorManager) DeactivateActor deprecated 

func (m *DefaultActorManager) DeactivateActor(actorID string) actorErr.ActorErr

Deprecated: use DefaultActorManagerContext instead.

func (*DefaultActorManager) InvokeMethod deprecated 

func (m *DefaultActorManager) InvokeMethod(actorID, methodName string, request []byte) ([]byte, actorErr.ActorErr)

Deprecated: use DefaultActorManagerContext instead.

func (*DefaultActorManager) InvokeReminder deprecated 

func (m *DefaultActorManager) InvokeReminder(actorID, reminderName string, params []byte) actorErr.ActorErr

Deprecated: use DefaultActorManagerContext instead.

func (*DefaultActorManager) InvokeTimer deprecated 

func (m *DefaultActorManager) InvokeTimer(actorID, timerName string, params []byte) actorErr.ActorErr

Deprecated: use DefaultActorManagerContext instead.

func (*DefaultActorManager) RegisterActorImplFactory deprecated 

func (m *DefaultActorManager) RegisterActorImplFactory(f actor.Factory)

Deprecated: use DefaultActorManagerContext instead.

type DefaultActorManagerContext 

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

DefaultActorManagerContext is to manage one type of actor.

func (*DefaultActorManagerContext) DeactivateActor 

func (m *DefaultActorManagerContext) DeactivateActor(_ context.Context, actorID string) actorErr.ActorErr

DeactivateActor removes actor from actor manager.

func (*DefaultActorManagerContext) InvokeMethod 

func (m *DefaultActorManagerContext) InvokeMethod(ctx context.Context, actorID, methodName string, request []byte) ([]byte, actorErr.ActorErr)

InvokeMethod to invoke local function by @actorID, @methodName and @request request param.

func (*DefaultActorManagerContext) InvokeReminder 

func (m *DefaultActorManagerContext) InvokeReminder(ctx context.Context, actorID, reminderName string, params []byte) actorErr.ActorErr

InvokeReminder invoke reminder function with given params.

func (*DefaultActorManagerContext) InvokeTimer 

func (m *DefaultActorManagerContext) InvokeTimer(ctx context.Context, actorID, timerName string, params []byte) actorErr.ActorErr

InvokeTimer invoke timer callback function with given params.

func (*DefaultActorManagerContext) RegisterActorImplFactory 

func (m *DefaultActorManagerContext) RegisterActorImplFactory(f actor.FactoryContext)

RegisterActorImplFactory registers the action factory f.

type MethodType 

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

MethodType is description of service method.

type Service 

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

Service is description of service.

Source Files

View all Source files

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.