remoteactorregistry

Documentation

Index

• Constants
• func Push(inv invoke.TransportInvoker, hosts []string, request PushRequest) error
• type ActorInfo
• type ActorPlacement
• type ActorPushInfo
• type ApplicationInfo
• type ObtainRequest
• type ObtainResponse
  • func Obtain(inv invoke.TransportInvoker, hosts []string) (*ObtainResponse, error)
• type PushRequest
• type RemoteActorRegistryFetcher
  • func NewFetcher(hosts []string, invoker invoke.TransportInvoker) *RemoteActorRegistryFetcher
  • func (registry *RemoteActorRegistryFetcher) Get(actorType string) *actorregistry.ActorInfo
  • func (registry *RemoteActorRegistryFetcher) Start()
  • func (registry *RemoteActorRegistryFetcher) Stop()
• type RemoteActorRegistryPusher
  • func NewPusher(hosts []string, appId string, invoker invoke.TransportInvoker) *RemoteActorRegistryPusher
  • func (registry *RemoteActorRegistryPusher) Set(info map[string]actorregistry.ActorPushInfo)
  • func (registry *RemoteActorRegistryPusher) Start()
  • func (registry *RemoteActorRegistryPusher) Stop()

Constants

const ACTION_OBTAIN = "obtain"

const ACTION_PUSH = "push"

const SERVICE = "io.darlean.actorregistryservice"

Functions

func Push

func Push(inv invoke.TransportInvoker, hosts []string, request PushRequest) error

Types

type ActorInfo

type ActorInfo struct {
	Applications []ApplicationInfo `json:"applications"`
	Placement    ActorPlacement    `json:"Placement"`
}

type ActorPlacement

type ActorPlacement struct {
	AppBindIdx *int  `json:"appBindIdx"`
	Sticky     *bool `json:"sticky"`
}

type ActorPushInfo

type ActorPushInfo struct {
	Placement        ActorPlacement `json:"placement"`
	MigrationVersion string         `json:"migrationVersion"`
}

type ApplicationInfo

type ApplicationInfo struct {
	Name             string  `json:"name"`
	MigrationVersion *string `json:"migrationVersion"`
}

type ObtainRequest

type ObtainRequest struct {
}

type ObtainResponse

type ObtainResponse struct {
	Nonce     string               `json:"nonce"`
	ActorInfo map[string]ActorInfo `json:"actorInfo"`
}

func Obtain

func Obtain(inv invoke.TransportInvoker, hosts []string) (*ObtainResponse, error)

type PushRequest

type PushRequest struct {
	Application string                   `json:"application"`
	ActorInfo   map[string]ActorPushInfo `json:"actorInfo"`
}

type RemoteActorRegistryFetcher

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

func NewFetcher

func NewFetcher(hosts []string, invoker invoke.TransportInvoker) *RemoteActorRegistryFetcher

func (*RemoteActorRegistryFetcher) Get

func (registry *RemoteActorRegistryFetcher) Get(actorType string) *actorregistry.ActorInfo

func (*RemoteActorRegistryFetcher) Start

func (registry *RemoteActorRegistryFetcher) Start()

func (*RemoteActorRegistryFetcher) Stop

func (registry *RemoteActorRegistryFetcher) Stop()

type RemoteActorRegistryPusher

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

func NewPusher

func NewPusher(hosts []string, appId string, invoker invoke.TransportInvoker) *RemoteActorRegistryPusher

func (*RemoteActorRegistryPusher) Set

func (registry *RemoteActorRegistryPusher) Set(info map[string]actorregistry.ActorPushInfo)

func (*RemoteActorRegistryPusher) Start

func (registry *RemoteActorRegistryPusher) Start()

func (*RemoteActorRegistryPusher) Stop

func (registry *RemoteActorRegistryPusher) Stop()