raftnode

type CertificateLockCommand struct {
	Name        string    `json:"name"`
	Owner       string    `json:"owner"`
	RequestedAt time.Time `json:"requested_at,omitzero"`
	ExpiresAt   time.Time `json:"expires_at,omitzero"`
}

type CertificateLockRecord struct {
	Name      string    `json:"name"`
	Owner     string    `json:"owner"`
	ExpiresAt time.Time `json:"expires_at,omitzero"`
}

type CertificateRecord struct {
	Key      string    `json:"key"`
	Value    []byte    `json:"value,omitempty"`
	Modified time.Time `json:"modified,omitzero"`
}

type Command struct {
	Type        string                            `json:"type"`
	Snapshot    *SnapshotUpdate                   `json:"snapshot,omitempty"`
	Routes      *collectionlist.List[RouteRecord] `json:"routes,omitempty"`
	Certificate *CertificateRecord                `json:"certificate,omitempty"`
	Lock        *CertificateLockCommand           `json:"lock,omitempty"`
	Raw         json.RawMessage                   `json:"raw,omitempty"`
}

type CommandResult struct {
	OK      bool   `json:"ok"`
	Reason  string `json:"reason,omitempty"`
	Version uint64 `json:"version,omitempty"`
}

type Config struct {
	NodeID         string
	BindAddr       string
	DataDir        string
	Bootstrap      bool
	DeploymentID   uint64
	RTTMillisecond uint64
	NodeHost       *dragonboat.NodeHost
	LogDB          dragonconfig.LogDBConfig
	Groups         *collectionlist.List[GroupConfig]
	Discovery      Discovery

	DiscoveryReconcileInterval time.Duration
	DiscoveryJoinTimeout       time.Duration
}

type Discovery interface {
	Start(ctx context.Context, local DiscoveryNode, onChange func()) error
	Peers() *collectionlist.List[DiscoveryNode]
	Shutdown() error
}

type DiscoveryNode struct {
	ID           string
	RaftAddress  string
	DeploymentID uint64
	Groups       *collectionlist.List[string]
}

type GroupConfig struct {
	Name           string
	ID             uint64
	Bootstrap      bool
	Join           bool
	InitialMembers *mapping.Map[string, string]
}

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

type MemberlistDiscoveryConfig struct {
	BindAddr      string
	AdvertiseAddr string
	Seeds         *collectionlist.List[string]
	JoinInterval  time.Duration
}

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

type Peer = mapping.Map[string, string]

type RouteRecord struct {
	Name       string `json:"name"`
	Entrypoint string `json:"entrypoint"`
	Host       string `json:"host,omitempty"`
	PathPrefix string `json:"path_prefix,omitempty"`
	Method     string `json:"method,omitempty"`
	Service    string `json:"service"`
}

type SnapshotUpdate struct {
	BuiltAt     string `json:"built_at"`
	Services    int    `json:"services"`
	Routes      int    `json:"routes"`
	ProxyEngine string `json:"proxy_engine"`
}

type State struct {
	Version      uint64                                      `json:"version"`
	AppliedAt    time.Time                                   `json:"applied_at"`
	Snapshot     *SnapshotUpdate                             `json:"snapshot,omitempty"`
	Routes       *collectionlist.List[RouteRecord]           `json:"routes,omitempty"`
	Certificates *collectionlist.List[CertificateRecord]     `json:"certificates,omitempty"`
	Locks        *collectionlist.List[CertificateLockRecord] `json:"locks,omitempty"`
	Raw          json.RawMessage                             `json:"raw,omitempty"`
}