Documentation ¶
Index ¶
- Constants
- func NewCoordinatorActor(plg plugin.Plugin, workerProps *actor.Props, shutdown func(), ...) actor.Actor
- func NewPartitionActor(plg plugin.Plugin, vertexProps *actor.Props, logger *logrus.Logger) actor.Actor
- func NewVertexActor(plugin plugin.Plugin, logger *logrus.Logger) actor.Actor
- func NewWorkerActor(plugin plugin.Plugin, partitionProps *actor.Props, shutdown func(), ...) actor.Actor
- func Run(ctx context.Context, plg plugin.Plugin, envPrefix string) error
- func RunMaster(ctx context.Context, plg plugin.Plugin, conf *config.MasterEnv) error
- func RunWorker(ctx context.Context, plg plugin.Plugin, conf *config.WorkerEnv) error
- type CtrlServer
- type ErrRes
Constants ¶
View Source
const ( // WorkerActorKind is actor kind of worker WorkerActorKind = "worker" // CoordinatorActorID is actor id of coordinator CoordinatorActorID = "coordinator" // VertexStatsName is aggregator name of VertexStatsAggregator VertexStatsName = "prerogel/vertex-stats" )
View Source
const ( // CoordinatorStateInit describes state: on initializing CoordinatorStateInit = "initializing cluster" // CoordinatorStateIdle describes state: idle CoordinatorStateIdle = "idle" // CoordinatorStateLoadingVertices describes state: loading vertices CoordinatorStateLoadingVertices = "loading vertices of each partition" // CoordinatorStateProcessing describes state: processing superstep CoordinatorStateProcessing = "processing superstep" // CoordinatorStateProcessingComputing describes state: computing CoordinatorStateProcessingComputing = "processing superstep - computing" )
View Source
const ( // APIPathStats is path for stats APIPathStats = "/ctl/stats" // APIPathLoadVertex is path for loading vertex APIPathLoadVertex = "/ctl/load-vertex" // APIPathLoadPartitionVertices is path for loading vertices of each partition APIPathLoadPartitionVertices = "/ctl/load-partition" // APIPathStartSuperStep is path for starting super step APIPathStartSuperStep = "/ctl/start-superstep" // APIPathShowAggregatedValue is path for showing aggregator values APIPathShowAggregatedValue = "/ctl/agg" // APIPathShutdown is path for shutdown APIPathShutdown = "/ctl/shutdown" // APIPathGetVertexValue is path for getting vertex valu APIPathGetVertexValue = "/ctl/vertex/value" )
Variables ¶
This section is empty.
Functions ¶
func NewCoordinatorActor ¶
func NewCoordinatorActor(plg plugin.Plugin, workerProps *actor.Props, shutdown func(), logger *logrus.Logger) actor.Actor
NewCoordinatorActor returns an actor instance
func NewPartitionActor ¶
func NewPartitionActor(plg plugin.Plugin, vertexProps *actor.Props, logger *logrus.Logger) actor.Actor
NewPartitionActor returns an actor instance
func NewVertexActor ¶
NewVertexActor returns an actor instance
func NewWorkerActor ¶
func NewWorkerActor(plugin plugin.Plugin, partitionProps *actor.Props, shutdown func(), logger *logrus.Logger) actor.Actor
NewWorkerActor returns a new actor instance
Types ¶
type CtrlServer ¶
type CtrlServer struct {
// contains filtered or unexported fields
}
CtrlServer is server that provides management API
Click to show internal directories.
Click to hide internal directories.