mesh

type ApplyLawsPayload struct {
	LawFiles []string `json:"law_files"`
	DryRun   bool     `json:"dry_run,omitempty"`
}

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

type Command struct {
	ID        string            `json:"id"`
	Type      CommandType       `json:"type"`
	Payload   json.RawMessage   `json:"payload"`
	Metadata  map[string]string `json:"metadata,omitempty"`
	Timestamp time.Time         `json:"timestamp"`
}

type CommandResult struct {
	ID        string          `json:"id"`
	Success   bool            `json:"success"`
	Output    json.RawMessage `json:"output,omitempty"`
	Error     string          `json:"error,omitempty"`
	Timestamp time.Time       `json:"timestamp"`
}

type CommandType string

type Config struct {
	ReplicaID          uint64
	ShardID            uint64
	RaftAddress        string
	DataDir            string
	InitialMembers     map[uint64]string
	Join               bool
	RTTMillisecond     uint64
	ElectionRTT        uint64
	HeartbeatRTT       uint64
	SnapshotEntries    uint64
	CompactionOverhead uint64
}

type ExecPayload struct {
	Command string            `json:"command"`
	Args    []string          `json:"args,omitempty"`
	Env     map[string]string `json:"env,omitempty"`
	WorkDir string            `json:"work_dir,omitempty"`
}

type ExecResult struct {
	ExitCode int    `json:"exit_code"`
	Stdout   string `json:"stdout"`
	Stderr   string `json:"stderr"`
}

type FactsPayload struct {
	Categories []string `json:"categories,omitempty"`
}

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

type MeshService interface {
	Start(ctx context.Context) error
	Stop() error
	ExecuteCommand(ctx context.Context, cmd Command) (*CommandResult, error)
	BroadcastCommand(ctx context.Context, cmd Command) (map[uint64]*CommandResult, error)
	GetStatus() (*MeshStatus, error)
	GetNodes() ([]Node, error)
}

type MeshStateMachine struct {
	ShardID   uint64
	ReplicaID uint64
	// contains filtered or unexported fields
}

type MeshStatus struct {
	NodeID    uint64    `json:"node_id"`
	ShardID   uint64    `json:"shard_id"`
	IsLeader  bool      `json:"is_leader"`
	Nodes     []Node    `json:"nodes"`
	Timestamp time.Time `json:"timestamp"`
}

type Node struct {
	ID      uint64 `json:"id"`
	Address string `json:"address"`
	Status  string `json:"status"`
}

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