def

package
v0.0.0-...-1837d0f Latest Latest
Warning

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

Go to latest
Published: Jan 7, 2022 License: Apache-2.0 Imports: 3 Imported by: 1

Documentation

Index

Constants

View Source
const (
	ATSample         = "sample"
	ATNats           = "NATS"
	ATEtcd           = "etcd"
	ATPrometheus     = "Prometheus"
	ATQuic           = "QUIC"
	ATSocketListener = "SocketListener"
	ATTcp            = "TCP"
	ATUdp            = "UDP"

	AIDUser = 1000
)

Variables

View Source
var KernelActors = []struct {
	ActorType
	ActorID
}{
	{ATEtcd, 1},
	{ATNats, 2},
	{ATPrometheus, 3},
}

KernelActors It use actor type as actor ID because of only one actor each type

Functions

func DecodeID

func DecodeID(id FullID) (NodeID, ActorID)

Types

type ActorID

type ActorID = uint32

type ActorType

type ActorType string

type Application

type Application interface {
	//ChangeConfig(Changed, New, Removed) error
	PrepareStop()
	Name() string
	Start(v *viper.Viper) error
	Stop()
}

type FullID

type FullID = uint64

func EncodeID

func EncodeID(id NodeID, actorID ActorID) FullID

type ID

type ID int64

type Message

type Message = gostatechart.Event

type MessageQueue

type MessageQueue chan struct {
	context.Context
	Message
}

type NewApplication

type NewApplication func(v *viper.Viper) (Application, error)

type NodeID

type NodeID = uint16

type Reply

type Reply struct {
	Message
	// contains filtered or unexported fields
}

Jump to

Keyboard shortcuts

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